使用ForceBind

liuxiaolong

2021-01-06 2a97c1246d8276fc790c881b2c58d467e4c7b6c6

 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)