多客户端连接连接至同一个服务器的时候，如果有一个客户端断开了，服务端就会停止广播，即使客户端重新连接，服务端也收不到任何的连接信息，需要服务端重启才能解决此问题

[FlashFeiFei]

go：kcp-go作为服务端 java：kcp-base作为客户端

go作为游戏数据转发

[FlashFeiFei]

服务端代码 `package main

import ( "github.com/xtaci/kcp-go/v5" room2 "kcp/demo3/room" "log" "time" )

func main() {

listener, err := kcp.ListenWithOptions("127.0.0.1:12345", nil, 10, 3)
listener.SetDeadline(time.Now().Add(1 * time.Second))
if err != nil {
    log.Fatal(err)
}

room := room2.NewGameRoom()
go room.Run()
for {
    s, err := listener.AcceptKCP()
    if err != nil {
        continue
    }
    room.JoinChan() <- s
}

} `

[FlashFeiFei]

客户端代码 `package com.laughingZhu.api;

import com.backblaze.erasure.FecAdapt; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufAllocator; import io.netty.buffer.Unpooled; import kcp.ChannelConfig; import kcp.KcpClient; import kcp.KcpListener; import kcp.Ukcp;

import java.net.InetSocketAddress; import java.nio.charset.StandardCharsets;

/**

• 与go版本兼容的客户端
• Created by JinMiao

• 2019/11/29. */ public class Kcp4GoExampleClient implements KcpListener {

  private final ByteBuf data = Unpooled.buffer(200);

  private final long startTime = System.currentTimeMillis(); private volatile int count;

  public static void main(String[] args) { ChannelConfig channelConfig = new ChannelConfig(); channelConfig.nodelay(true, 10, 2, true); channelConfig.setSndwnd(1024); channelConfig.setRcvwnd(1024); channelConfig.setMtu(1400); channelConfig.setFecAdapt(new FecAdapt(10, 3)); channelConfig.setAckNoDelay(false); channelConfig.setTimeoutMillis(10000);

  //禁用参数
  channelConfig.setCrc32Check(false);
  channelConfig.setAckMaskSize(0);
  
  KcpClient kcpClient = new KcpClient();
  kcpClient.init(channelConfig);
  
  Kcp4GoExampleClient kcpGoExampleClient = new Kcp4GoExampleClient();
  Ukcp ukcp = kcpClient.connect(new InetSocketAddress("127.0.0.1", 12345), channelConfig, kcpGoExampleClient);

  }

  @Override public void onConnected(Ukcp ukcp) {

  //链接成功发送数据
  String msg = "hello!!!!!2222222222";
  byte[] bytes = msg.getBytes();
  ByteBuf byteBuf = ByteBufAllocator.DEFAULT.ioBuffer(bytes.length);
  byteBuf.writeBytes(bytes);
  ukcp.write(byteBuf);

  }

  @Override public void handleReceive(ByteBuf byteBuf, Ukcp ukcp) { //读取数据 byte[] bytes = new byte[byteBuf.readableBytes()]; byteBuf.getBytes(byteBuf.readerIndex(),bytes); System.out.println("收到消息: "+new String(bytes,StandardCharsets.UTF_8));

  //写入数据

  // buf.writeShort(++count); // buf.writeInt((int) (System.currentTimeMillis() - startTime)); ++count; String msg = "--发送数据java" + count; ByteBuf buf = Unpooled.buffer(msg.length()); buf.writeCharSequence(msg, StandardCharsets.UTF_8); ukcp.write(buf); }

  @Override public void handleException(Throwable ex, Ukcp ukcp) { ex.printStackTrace(); }

  @Override public void handleClose(Ukcp ukcp) { System.out.println("链接关闭: " + ukcp); ukcp.close();

  }

}`

[FlashFeiFei]

先运行服务端，然后运行客户端，一切正常

[FlashFeiFei]

这时候，断开客户端重新运行客户端之后，数据会发送几秒，之后就不在发送数据了，卡主了；重新开启一个客户端，debug服务端发现s, err := listener.AcceptKCP()没有链接进来

[luodaoyi]

求个c++的例子

[FlashFeiFei]