初级会员
  • 第 76140 位会员
  • xzd20
  • 2022-11-09 05:46:49
  • 33
  • Offline
  • 19 95

最近发布的主题

    暂无

最近发布的文章

    暂无

最近分享的资源

    暂无

最近发布的项目

    暂无

最近的评论

  • 请问如果实现轮询发送的话应该怎么做呢?就是第一次发给服务器A,接收它的返回;第二次发给服务器B,接收它的返回,以此类推,基于您的基础上改了改发现有问题 ```go func (p *pipeline) serve() { defer p.close() //master := p.backs[0] //go p.readFrom(master) // //discards := p.backs[1:] //if len(discards) != 0 { // go p.discard(discards) //} buf := make([]byte, 1024) bufRead := make([]byte, 1024) index := 0 for { n, err := p.conn.Read(buf) if err != nil { return } if _, err := p.backs[index].Write(buf[:n]); err != nil { break } fmt.Println("index: ", index) n, err = p.backs[index].Read(bufRead) if err != nil { break } if _, err = p.conn.Write(bufRead[:n]); err != nil { break } index = (index + 1) % len(p.backs) } } ```