使用ForceBind

liuxiaolong

2021-01-06 2a97c1246d8276fc790c881b2c58d467e4c7b6c6

使用ForceBind

 hbusc.go

@@ -181,7 +181,7 @@
    for _, v := range ri.Channel {
        if k,ok := regR.ChannelKey[v];ok {
            s := bhomebus.OpenSocket()
            s.Bind(int(k))
            s.ForceBind(int(k))
            handle.m[v] = &sockServer{
                sock: s,
                info: &ri.Proc,
@@ -192,7 +192,7 @@
    handle.wg = &sync.WaitGroup{}

    sockReply := bhomebus.OpenSocket()
    sockReply.Bind(int(regR.ReplyKey))
    sockReply.ForceBind(int(regR.ReplyKey))
    handle.wg.Add(1)
    //serve server reply
    go recvRoutine(ctx, sockReply, handle.wg, handle.chReply)