Netty：在ctx之后保持服务器套接字打开。刷新（）

Question

我有两个服务器“A”（由我的朋友构建）和“B”（由我构建，使用Netty 4.1）。当客户端发送命令时，此服务器“A”和“B”会返回一些响应。我尝试使用简单的JAVA客户端套接字访问该服务器。以下是java客户端代码：

public class SocketClient
{
    public void run()
    {
        try {
            ClassLoader classLoader = getClass().getClassLoader();
            File file = new File(classLoader.getResource("request.txt").getFile());
            String content = new String(Files.readAllBytes(file.toPath()));

            System.out.println("Connecting to server:8888");
            Socket socket = new Socket("myserver.com", 8888);
            DataOutputStream out = new DataOutputStream(socket.getOutputStream());
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            out.write(content.getBytes());
            out.flush();

            while(true) {
                int response = in.read();
                System.out.println(response);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

当将客户机连接到服务器A（非netty）时，read（）方法会给出如下输出：

48
48
57
56
48
50
49
48

但是，当我尝试连接到服务器“B”（使用netty）时，输出如下：

48
48
57
56
48
50
49
48
-1
-1
-1
-1

为什么会发生这种情况？顺便说一下，在服务器B中，我使用的是ctx。write（）和ctx。flush（）以及如何使服务器B获得与服务器A相同的行为（不关闭连接，因此不会返回-1）

编辑：其他信息

实际上，在服务器“B”中，我使用的是ChannelInboundHandlerAdapter和ChannelOutboundHandlerAdapter。在做了一些实验后，问题出现在ChannelOutboundHandlerAdapter上。当我使用ctx发送响应时。writeAndFlush（）从InboundAdapter中，套接字未关闭。但是当响应被传递到OutboundAdapter时，然后我使用ctx发送响应。writeAndFlush（）内部外部适配器写入（ChannelHandlerContext ctx，Object msg，ChannelPromise promise）方法。插座已关闭

这是我的OutboundAdapter的示例：

public class OutboundHandler extends ChannelOutboundHandlerAdapter {

    private static final Logger logger = LogManager.getLogger(OutboundHandler.class);

    //Sending or forwarding message to channel which is already configured
    //condition is depends on which model instance
    //packaging is worked on its packager class
    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception
    {
        String response = "Response form OutboundHandler";
        ctx.writeAndFlush(Unpooled.copiedBuffer(response.getBytes()));
    } }

谢谢




Answer 1

经过一整天的调试，我找到了问题的根本原因。我不小心把ctx.close（）放在了我的InbnAdapter中的某个地方，所以当我将消息传递到OutbnAdapter并将消息刷新到客户端时，它将关闭连接

try {
   //some code
}
} catch (Exception ex) {
        logger.error(ex);
        ErrorData error = new ErrorData();
        error.setCode("99");
        error.setMessage("General System Error");

        //pass the message to OutboundAdapter
        ctx.writeAndFlush(error);
} finally {
  ctx.close();
}

所以，我只需要删除ctx.close（），服务器停止关闭套接字连接

Answer 2

你们并没有检查流的结尾，所以你们在无休止地重复它read（）返回一个值。检查一下。它在流的末尾返回-1。结束了。菲尼斯。菲尼托。停在那里。不要打印它。不要一直看书。不要传球。不要收取200美元。

Answer 3

匿名用户

在Netty服务器实现上，例如，您可能必须通过ChannelHandlerContext更恰当地处理读写操作，而不是使用ctx。write（）ctx。通道（）。writeandflush（）应该是更合适的方式，也是在结束使用ctx时。通道（）。close（）或ctx。通道（）。关闭（）。sync（）可能会产生差异。。。