Netty客户端服务器登录，如何让channelRead返回布尔值

Question

我正在netty之上编写客户机-服务器应用程序。

我从一个简单的客户端登录服务器开始，该服务器通过数据库验证从客户端发送的信息。这一切都很好。

在客户端，我希望在收到来自服务器的响应后使用If语句，以确定登录凭据是否有效。这也很好用。我的问题是ChannelRead方法不返回任何内容。我不能改变这个。我需要它返回一个布尔值，允许登录尝试成功或失败。

一旦channelRead（）返回，我就会丢失数据的内容。

我尝试将msg添加到列表中，但是由于某种原因，消息数据没有存储在列表中。

欢迎提出任何建议。我是新来的。。。这是我想出的唯一办法。我也尝试过在channelRead（）中使用布尔语句，但是这些方法是无效的，所以一旦它关闭，布尔变量就会被清除。

以下是我试图将消息数据插入到我创建的列表中的最后一次尝试...

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.ListIterator;

public class LoginClientHandler extends ChannelInboundHandlerAdapter {
    Player player = new Player();
    String response;
    public volatile boolean loginSuccess;
//    Object message = new Object();
    private Object msg;
    public static final List<Object> incomingMessage = new List<Object>() {

       
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
//        incomingMessage.clear();
        response = (String) msg;
        System.out.println("channel read response = " + response);
        incomingMessage.add(0, msg);
        System.out.println("incoming message = " + incomingMessage.get(0));
    }    

如何从channelRead（）方法中“取出”消息数据，或使用此方法在业务逻辑中创建更改？我希望它要么显示一条消息，告诉客户端登录失败并重试，要么成功并加载下一个场景。我的业务逻辑运行良好，但我无法让它与netty一起工作，因为没有任何方法返回任何我可以用来影响我的业务逻辑的东西。

通道初始化器

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.DelimiterBasedFrameDecoder;
import io.netty.handler.codec.Delimiters;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;

public class LoginClientInitializer extends ChannelInitializer <SocketChannel> {


    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());

        pipeline.addLast("handler", new LoginClientHandler());
    }
}

Answer 1

要让服务器向客户端写入数据，请调用ctx。写这是一个基本的echo服务器和客户机示例，摘自《Netty in Action》一书。https://github.com/normanmaurer/netty-in-action/blob/2.0-SNAPSHOT/chapter2/Server/src/main/java/nia/chapter2/echoserver/EchoServerHandler.java回购协议中还有其他几个好例子。

如果你是从netty开始的，我强烈建议你阅读《netty in action》一书。它将使您对该框架以及如何使用它有一个坚实的基础性理解。