From 9f1ceb8cd03ecf412a9a373c9f520cbd22527291 Mon Sep 17 00:00:00 2001 From: x-shadow-man <1494445739@qq.com> Date: Wed, 27 Jul 2022 20:02:40 +0800 Subject: [PATCH] =?UTF-8?q?kafka=20topic=E4=BC=98=E5=8C=96=E5=8F=8A?= =?UTF-8?q?=E8=A7=A3=E9=87=8A=EF=BC=8C=E5=88=A0=E9=99=A4=E5=BA=9F=E5=BC=83?= =?UTF-8?q?topic=E7=9A=84=E5=86=97=E4=BD=99=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config/config.yaml | 10 +++++----- internal/rpc/msg/rpcChat.go | 6 +++--- pkg/common/config/config.go | 8 ++++---- 3 files changed, 12 insertions(+), 12 deletions(-) diff --git a/config/config.yaml b/config/config.yaml index c552a954d..9374994f7 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -45,16 +45,16 @@ redis: kafka: ws2mschat: addr: [ 127.0.0.1:9092 ] #kafka配置,默认即可 - topic: "ws2ms_chat" - ws2mschatoffline: - addr: [ 127.0.0.1:9092 ] #kafka配置,默认即可 - topic: "ws2ms_chat_offline" + topic: "ws2ms_chat" #用于mongo和mysql保存消息 +# ws2mschatoffline: +# addr: [ 127.0.0.1:9092 ] #kafka配置,默认即可 +# topic: "ws2ms_chat_offline" #原为离线用户消息处理,目前暂时弃用 msgtomongo: addr: [ 127.0.0.1:9092 ] #kafka配置,默认即可 topic: "msg_to_mongo" ms2pschat: addr: [ 127.0.0.1:9092 ] #kafka配置,默认即可 - topic: "ms2ps_chat" + topic: "ms2ps_chat" #消息push consumergroupid: msgToTransfer: mongo msgToMongo: mongo_ex diff --git a/internal/rpc/msg/rpcChat.go b/internal/rpc/msg/rpcChat.go index e7ae283ab..1d306b673 100644 --- a/internal/rpc/msg/rpcChat.go +++ b/internal/rpc/msg/rpcChat.go @@ -21,8 +21,8 @@ type rpcChat struct { etcdSchema string etcdAddr []string onlineProducer *kafka.Producer - offlineProducer *kafka.Producer - delMsgCh chan deleteMsg + //offlineProducer *kafka.Producer + delMsgCh chan deleteMsg } type deleteMsg struct { @@ -41,7 +41,7 @@ func NewRpcChatServer(port int) *rpcChat { etcdAddr: config.Config.Etcd.EtcdAddr, } rc.onlineProducer = kafka.NewKafkaProducer(config.Config.Kafka.Ws2mschat.Addr, config.Config.Kafka.Ws2mschat.Topic) - rc.offlineProducer = kafka.NewKafkaProducer(config.Config.Kafka.Ws2mschatOffline.Addr, config.Config.Kafka.Ws2mschatOffline.Topic) + //rc.offlineProducer = kafka.NewKafkaProducer(config.Config.Kafka.Ws2mschatOffline.Addr, config.Config.Kafka.Ws2mschatOffline.Topic) rc.delMsgCh = make(chan deleteMsg, 1000) return &rc } diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go index 508720a2b..c7b76541b 100644 --- a/pkg/common/config/config.go +++ b/pkg/common/config/config.go @@ -203,10 +203,10 @@ type config struct { Addr []string `yaml:"addr"` Topic string `yaml:"topic"` } - Ws2mschatOffline struct { - Addr []string `yaml:"addr"` - Topic string `yaml:"topic"` - } + //Ws2mschatOffline struct { + // Addr []string `yaml:"addr"` + // Topic string `yaml:"topic"` + //} MsgToMongo struct { Addr []string `yaml:"addr"` Topic string `yaml:"topic"`