mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-11-07 14:32:13 +08:00
396729fc24
{"level":"warn","ts":"2022-04-22T17:37:26.375+0800","logger":"etcd-client","caller":"v3@v3.5.2/retry_interceptor.go:62","msg":"retrying of unary invoker failed","target":"etcd-endpoints://0xc00cf55c00/127.0.0.1:2379","attempt":0,"error":"rpc error: code = DeadlineExceeded desc = latest balancer error: last connection error: connection closed before server preface received"}
42 lines
1012 B
Go
42 lines
1012 B
Go
/*
|
|
** description("").
|
|
** copyright('open-im,www.open-im.io').
|
|
** author("fg,Gordon@open-im.io").
|
|
** time(2021/3/22 15:33).
|
|
*/
|
|
package logic
|
|
|
|
import (
|
|
"Open_IM/pkg/common/config"
|
|
"Open_IM/pkg/common/constant"
|
|
"Open_IM/pkg/common/kafka"
|
|
"Open_IM/pkg/grpc-etcdv3/getcdv3"
|
|
"Open_IM/pkg/statistics"
|
|
"fmt"
|
|
)
|
|
|
|
var (
|
|
watcher *getcdv3.Watcher
|
|
rpcServer RPCServer
|
|
pushCh PushConsumerHandler
|
|
pushTerminal []int32
|
|
producer *kafka.Producer
|
|
count uint64
|
|
)
|
|
|
|
func Init(rpcPort int) {
|
|
watcher = getcdv3.NewWatcher()
|
|
rpcServer.Init(rpcPort)
|
|
pushCh.Init()
|
|
pushTerminal = []int32{constant.IOSPlatformID, constant.AndroidPlatformID}
|
|
}
|
|
func init() {
|
|
producer = kafka.NewKafkaProducer(config.Config.Kafka.Ws2mschat.Addr, config.Config.Kafka.Ws2mschat.Topic)
|
|
statistics.NewStatistics(&count, config.Config.ModuleName.PushName, fmt.Sprintf("%d second push to msg_gateway count", 300), 300)
|
|
}
|
|
|
|
func Run() {
|
|
go rpcServer.run()
|
|
go pushCh.pushConsumerGroup.RegisterHandleAndConsumer(&pushCh)
|
|
}
|