slow_wild_queue/etc/task-mq.yaml

# 模块名称
Name: task-mq
# 模块监听的ip和端口
ListenOn: 0.0.0.0:10001
# 用户消息消费配置，这里是采用go-zero自带的kafka配置，可以参考https://go-zero.dev/docs/tutorials/message-queue/kafka
MsgChatTransfer:
  # service的名称
  Name: MsgChatTransfer
  # kafka 的多个 Broker 节点
  Brokers:
    - 192.168.50.14:19094
  # 消费者组
  Group: kafka
  # 订阅的 Topic 主题
  Topic: msgChatTransfer
  # 从头开始消费
  Offset: first
  # go-queue 内部是起多个 goroutine 从 kafka 中获取信息写入进程内的 channel，这个参数是控制此处的 goroutine 数量（⚠️ 并不是真正消费时的并发 goroutine 数量）
  Consumers: 1
# 如上的配置参数；此配置用于消息已读
MsgReadTransfer:
  Name: MsgReadTransfer
  Brokers:
    - 192.168.50.14:19094
  Group: kafka
  Topic: msgReadTransfer
  Offset: first
  Consumers: 1
# 如上的配置参数；此配置用于资讯模块的异步写es和缓存
TweetTransfer:
  Name: TweetTransfer
  Brokers:
    - 192.168.50.14:19094
  Group: kafka
  Topic: tweetTransfer
  Offset: first
  Consumers: 1
# 如上的配置参数；此配置用于用户购买附件之后的异步处理
UserBillTransfer:
  Name: UserBillTransfer
  Brokers:
    - 192.168.50.14:19094
  Group: kafka
  Topic: userBillTransfer
  Offset: first
  Consumers: 1
# 消息已读处理的配置
MsgReadHandler:
  GroupMsgReadHandler: 1
  GroupMsgReadRecordDelayTime: 60
  GroupMsgReadRecordDelayCount: 2
# redis的配置参数
Redisx:
  Host: 192.168.50.14:16379
  Type: node
  Pass: easy-chat
# mongo的配置信息
Mongo:
  url: "mongodb://root:123456@192.168.50.14:47017"
  Db: easy-chat
# websocket的地址
Ws:
  Host: paopao-im-ws-svc:10003
# 好友模块的地址
SocialRpc:
  Target: k8s://paopao-im/paopao-social-rpc-svc:10002
# 用户模块的地址
UserRpc:
  Target: k8s://paopao-im/paopao-user-rpc-svc:10000
# es的连接配置参数
ElasticsearchConf:
  # es ip地址
  Host: 192.168.50.14
  # es 的端口
  Port: 19200
  # es的用户名
  Username: elastic
  # es的账号密码
  Password: huang123456
  # es中需要写入的索引
  TweetIndex: "es_index_tweet"

Log:
  ServiceName: task-mq
  Mode: file
  Encoding: json
  Path: "/var/logs"
  Level: "info"
  Compress: true
  KeepDays: 30
  StackCooldownMillis: 100
  Rotation: daily