传统的客户端IO和服务器端NIO，如果客户端在同一个套接字中发送多个消息，如何得到特定的消息？

Question

我正在服务器端使用Apache Mina。我有一个客户是用传统的IO写的。下面是将数据发送到服务器的客户端代码。

class SomeClass extends Thread
{
    Socket socket;

    //Constructor
    SomeClass()
    {
        Socket socket = ...
    }

    public void run()
    {
        while (j++ & lt; 10)
        {
            System.out.println("CLIENT[" + clientNo + "] Send Message =>" + requests[clientNo][j]);
            OutputStream oStrm = socket.getOutputStream();
            byte[] byteSendBuffer = (requests[clientNo][j]).getBytes();
            oStrm.write(byteSendBuffer);
            oStrm.flush();
        }
    }
}

上面的线程运行了20次。因此创建了20个套接字。在一个套接字中，发送许多消息。通过使用IO套接字类编写的服务器，我能够完美地检索数据。

问题出现在使用缓冲区的基于Apache Mina的服务器中！我无法获得单个消息。

我如何获得单个消息（如果我不能在客户端更改任何内容，并且单个消息的长度不知道）

服务器端代码
套接字创建

    public static void main(String[] args) throws IOException, SQLException {           
        System.out.println(Charset.defaultCharset().name());
        IoAcceptor acceptor = new NioSocketAcceptor();
        ProtocolCodecFilter(charset.newEncoder(),charset.newDecoder() ));
        acceptor.setHandler( new TimeServerHandler() );
        acceptor.getSessionConfig().setReadBufferSize(64 );
        acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
        acceptor.bind( new InetSocketAddress(PORT) );
    }

处理程序代码

    public void messageReceived(IoSession session, Object message) throws Exception {
            AbstractIoBuffer bf = (AbstractIoBuffer)message;
            Charset charset = Charset.forName("UTF-8");
            CharsetDecoder decoder = charset.newDecoder();
            String outString = bf.getString(decoder);

    }

Answer 1

MINA实际上是一个非常精细的框架，以一种优雅的方式解决你的问题。它的基本概念是一个过滤器链，在这个链中，一系列的过滤器被应用在一个传入的消息上。

您应该实现一个协议解码器（实现messageDecoder)并将其注册到您的MINA过滤器链中。解码器应该将字节缓冲区解析为您选择的对象表示形式。

然后，您可以注册一个处理完整消息的消息处理程序。

Answer 2

如何获取单个消息

你不知道。TCP中没有消息这回事。它是一种字节流协议。没有消息边界，也不能保证另一端的一个读等于一个写。

（鉴于我无法更改客户端中的任何内容，并且不知道单个消息的长度）

您将不得不根据应用程序协议的定义解析消息以找到它们停止的位置。如果这是不可能的，因为，例如，协议是不明确的，客户端将不得不垃圾。然而，由于你不能改变客户机，它必须已经与一个现有的系统工作，所以在你之前的家伙有相同的问题，并解决了它。