从Netty SocketServer获取日期

Question

我有一个通过Netty.io创建的简单套接字服务器，当我从终端写东西时，一切都像一个魅力一样工作。但是我也有一个自定义套接字客户端，不使用netty.io，我如何从网络服务器获取数据？这是我的网络处理器：

public class DiscardServerHandler extends SimpleChannelInboundHandler<String> {

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String message) throws Exception {
        String msg = message;
        try {
            System.out.println(msg);
            System.out.flush();
            ctx.writeAndFlush("Response from server");
        } finally {
            ReferenceCountUtil.retain(msg);
        }
    }

}

这是我的客户端套接字类：

public class ClientSideSocket2 {
    public static void main(String[] args) {
        String serverName = "localhost";
        int port = 9999;
        String line = "";
        Socket client = null;
        PrintWriter toServer = null;
        BufferedReader fromServer = null;

        try {
            System.out.println("Connecting to " + serverName + " on port " + port);
            client = new Socket(serverName, port);
            System.out.println("Just connected to " + client.getRemoteSocketAddress());

            toServer = new PrintWriter(client.getOutputStream(), true);
            fromServer = new BufferedReader(new InputStreamReader(client.getInputStream()));

            for (int i = 0; i < 6; i++) {
                toServer.println("simple string: " + i);
                if ((line = fromServer.readLine()) != null) {
                    System.out.println("Responce from server: " + line);
                }
            }           

        } catch (IOException ex) {
            ex.printStackTrace();
        } finally {
            try {
                toServer.close();
                fromServer.close();
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

我不能从行读取数据if（（line=fromServer.readLine()) ! = null）.有其他方法吗？

Answer 1

首先，我假设您正确设置了ChannelPipeline，并且触发了channelRead0。fromerver.readLine（）被阻塞，直到它读取换行（\n）、回车（\r）或回车，然后立即换行。

那么问题是你应该做出回应

ctx.writeAndFlush("Response from server\n");

如果事件未触发，请尝试通过以下方式设置您的ChannelPipeline：

ch.pipeline().addLast(
    new StringDecoder(),
    new StringEncoder(),
    new DiscardServerHandler());

然后终止响应字符串，您的客户机将正常工作。