YitianJiang issues

Results 10 issues of


                                            YitianJiang

it cannot work in centos7.6 whenredis version is 6.0.3 ,because gcc version is too low, in this case ,the gcc version should be upgraded.

[BUG] MarkMessage没有具体实现

你这个mongodb 和mysql消费消息的时候，为了避免重复消费消息，你写了个 history_msg_handler.go 97行 sess.MarkMessage(msg, "") **但是saram提供的这个接口是让你自己去实现 saram 并没有实现这MarkMessage个接口** 我觉得你想做的应该是：消费完消息后把消息的唯一标识写进redis里面然后，每次消费消息前都去redis里面查这条消息的标识，有，就被消费过，会导致重复消费 ![Snipaste_2022-04-07_15-54-41](https://user-images.githubusercontent.com/36124775/162149926-8aa05ad1-1736-4b0b-aa61-93242927e060.png)

if !isSenderSync && msgKey == msgFromMQ.MsgData.SendID 这种情况什么时候会出现

history_msg_handler.go 67行 ![Snipaste_2022-04-07_21-33-45](https://user-images.githubusercontent.com/36124775/162211476-03e7bd82-60ce-4da4-ac65-8d34aa567ea9.png)

B在线 A登录显示B在线这时B下线 A还是显示B在线

为什么单聊，自己的其他设备要收到消息，而群聊，自己的其他设备就不需要收到消息

if in.GetSessionType() == constant.SingleChatType { userIDList = genUidPlatformArray(in.SendID) for _, v := range userIDList { UIDAndPID = strings.Split(v, " ") if conn := ws.getUserConn(v); conn != nil { _ =...

isOfflinePush 没被写过只有这个地方读了一次

if sendPbData.ContentType != constant.Typing && sendPbData.ContentType != constant.HasReadReceipt { if **_isOfflinePush_** { for _, v := range wsResult { if v.ResultCode == 0 { continue

isHistory 没被写过只有这一个地方读了一次

isPersist := utils.GetSwitchFromOptions(Options, "persistent") switch pbData.SessionType { case constant.SingleChatType: log.NewDebug(pbSaveData.OperationID, "msg_transfer chat type = SingleChatType", isHistory, isPersist) if **_isHistory_** { if msgKey == pbSaveData.RecvID { err := saveUserChat(pbData.RecvID, &pbSaveData) if...

连接池写了又没用上为什么idleTimeout+ timeUsed >当前时间 ClientConn要关掉重建直接把新建的grpc连接塞里面不就行了

这块： **If the wrapper was idle too long, close the connection and create a new one.** // If the wrapper was idle too long, close the connection and create a...

GetPrefix和GetPrefix4Unique这两个方法内容一模一样一个不就够了为什么要来两个

// "%s:///%s/" func GetPrefix(schema, serviceName string) string { return fmt.Sprintf("%s:///%s/", schema, serviceName) } // "%s:///%s" func GetPrefix4Unique(schema, serviceName string) string { return fmt.Sprintf("%s:///%s", schema, serviceName) }

bug fix

这里有一个bug 279行在slave上执行shell脚本的时候没有用sh filename的方式，提示权限不够 slave加入不成功这一行： scp base.config hwclock_ntp.sh node_install_k8s.sh ssh_trust_init.exp ssh_trust_add.exp root@$host:/root && scp /etc/hosts root@$host:/etc/hosts && ssh root@$host "hostnamectl set-hostname $hostname$num" && ssh root@$host **_/root/hwclock_ntp.sh_** && ssh root@$host **_/root/node_install_k8s.sh_**...