如何忽略来自断开信道的消息

Question

我正在为多人游戏实现简单的网络服务器。我只是想搞清楚Netty

我通过telnet测试服务器。我所做的是向所有频道广播信息。工作很顺利。此外，我从地图上删除通道关闭事件，这是罚款。

但问题是，如果其中一个客户端意外断开连接，则在关闭回调之前，MessageRec的回调调用其发送方断开连接的信道。

如何正确忽略来自断开连接的客户端的消息？我在messagedReceived中使用StringBuffer，但用于StringBuffer的情况。toString也不是正确的字符串。在断开连接的通道结束时，将无意义的消息广播到其他通道和自身，当接收器通道本身处于关闭状态时，会引发异常由对等方重置连接，这是正常的，因为此时通道本身不可用。

这是代码；

     @Override
     public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {

            System.out.println();
            System.out.println("------------------");


            Channel current = e.getChannel();
            System.out.println("SenderChannel:"+current.getId());

            if(!current.isOpen())
                System.out.println("Not Open");

            ChannelBuffer buf = (ChannelBuffer) e.getMessage();

            StringBuffer sbs = new StringBuffer();

            while(buf.readable()) {
                sbs.append((char) buf.readByte());
            }

            String s = sbs.toString();


            System.out.println(s);

            String you = "You:" + s;
            String other = "Other:" + s;



            byte [] uResponse = you.getBytes();
            byte [] otherResponse = other.getBytes();


            Iterator iterator = channelList.entrySet().iterator();
            while(iterator.hasNext()){
                  Map.Entry pairs = (Map.Entry)iterator.next();

                  Integer key = (Integer)pairs.getKey();
                  Channel c = (Channel)pairs.getValue();

                  System.out.println("ReceiverChannel:"+c.getId());

                  if(key != current.getId())
                      c.write(ChannelBuffers.wrappedBuffer(otherResponse));
                  else
                      c.write(ChannelBuffers.wrappedBuffer(uResponse));

            }

     }


    @Override
    public void channelDisconnected(ChannelHandlerContext ctx,
            ChannelStateEvent e){

        Channel ch = e.getChannel();


            channelList.remove(ch.getId());
            System.out.println();
            System.out.println("*****************");
            System.out.println("DisconnectEvent:"+ch.getId());
            System.out.println("*****************");
            System.out.println();
            ch.close();

    }

Answer 1

如果这是一个多人游戏服务器，它可能更好地使用现有的Netty游戏服务器解决方案，如java游戏服务器。断开连接成为发送到会话的事件，由于它是事件驱动的，您可以编写自己的处理程序来决定是否在同一会话上接收更多的事件。由于事件按照先进先出的顺序排队，如果发生断开连接，则不需要继续进行后续广播。

Answer 2

只需在每次发送周围放一个尝试/捕捉。如果其中一个失败，关闭相应的通道。

Answer 3

你不能以你想要的方式解决这个问题。例如，如果有网络问题，那么从技术上讲，发送者可以随时断开连接

• 一旦线程输入messageReceived
• 当您在频道列表中迭代时
• 当您在频道列表中迭代时，但在您回显给发件人后
• 在你广播完信息之后

Netty不能引发断开连接的事件，因为你正在运行的线程将引发事件（除非你有一个无序的执行处理程序在你的管道）。正确的解决方案取决于您的应用程序。如果广播导致所有其他接收器响应，那么让服务器禁止发送给不再连接的客户端的任何消息可能会更好/更容易。

此外，如果您真的要使用字符串，请看一下StringEncoder/StringDecoder。代码中不能保证消息事件缓冲区包含完整的html" target="_blank">字符串。