标签：sockets io netty java

我有一个简单的netty客户(套接字).每次将数据发送到服务器时,我必须检查客户端是否登录.如果没有,我必须发送用户凭据,并等待服务器返回true或false.但是我必须在阻止模式下执行此操作,并且如果我从服务器收到真实消息,则可以继续发送其他数据.
我当前的代码是：

EventLoopGroup workerGroup = new NioEventLoopGroup();   
try {
    Bootstrap bootstrap = new Bootstrap();
    bootstrap.group(workerGroup)
        .channel(NioSocketChannel.class)
        .option(ChannelOption.SO_KEEPALIVE, true)
        .handler(new TRSClientInterfaceInitializer());

    Channel ch = bootstrap.connect(host, port).sync().channel();
    ChannelFuture lastWriteFuture = null;

    for (Message message : list) {
        if (!isLoggedIn) {
            lastWriteFuture = ch.writeAndFlush("loginpassword");
        }
        //if login is success, I must loop through all data in list and send other data to server
        lastWriteFuture = ch.writeAndFlush(message.getDataString);
    }

    if (lastWriteFuture != null) {
        lastWriteFuture.sync();
    }
} catch ////

这是我的处理程序：

//handler extended from SimpleChannelInboundHandler<String>
@Override
protected void channelRead0(ChannelHandlerContext ctx, String data) throws Exception {
    System.out.println(data);
    System.out.flush();
    if ("success".equals(data)) {
        isLoggedIn = true
    }
}

如何在阻止模式下实现此逻辑？我在网络上找不到任何解决方案.有什么帮助吗？请

解决方法:

阻止客户端直到写操作完成：

lastWriteFuture = ch.writeAndFlush(message.getDataString);
lastWriteFuture.await();

您的服务器可能会写一些响应以指示请求是否成功：

//handler extended from SimpleChannelInboundHandler<String>
@Override
protected void channelRead0(ChannelHandlerContext ctx, String data) throws  Exception {
  System.out.println(data);
  System.out.flush();
  if ("success".equals(data)) {
    isLoggedIn = true
    ctx.channel().writeAndFlush("success!");
    return;
  }
  ctx.channel().writeAndFlush("fail!");
}

在TRSClientInterfaceInitializer处理程序中处理服务器的响应.

标签：sockets,io,netty,java
来源： https://codeday.me/bug/20191120/2040942.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。