java - Netty - 客户端读写操作
问题描述
我正在尝试从服务器发送和接收消息。该服务器已构建在远程环境中。
这些代码作为字节发送。此时,问题开始了。
当客户端与服务器连接时,服务器立即发送 100000050 并在几毫秒后发送 10000051。
我应该在收到 10000051 后发送 10000060 但我不知道如何。
客户端.JAVA
public static void main(String[] args) throws Exception {
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap clientBootstrap = new Bootstrap();
clientBootstrap.group(group);
clientBootstrap.channel(NioSocketChannel.class);
clientBootstrap.remoteAddress(new InetSocketAddress("10.80.15.70", 55102));
clientBootstrap.handler(new ChannelInitializer<SocketChannel>() {
protected void initChannel(SocketChannel socketChannel) throws Exception {
socketChannel.pipeline().addLast(new ClientHandler());
}
});
ChannelFuture channelFuture = clientBootstrap.connect().sync();
channelFuture.channel().closeFuture().sync();
}
finally {
group.shutdownGracefully().sync();
}
}
客户端处理程序.JAVA
public class ClientHandler extends SimpleChannelInboundHandler<ByteBuf> {
private static final Logger LOGGER = Logger.getLogger( ClientHandler.class.getName() );
@Override
public void channelActive(ChannelHandlerContext channelHandlerContext){
//System.out.println("\nhelloo");
//channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer("Netty Rocks!", CharsetUtil.UTF_8));
byte [] test = new byte[9];
test[0] = 0;
test[1] = 6;
test[2] = 0;
test[3] = 0;
test[4] = 0;
test[5] = 0;
test[6] = 0;
test[7] = 0;
test[8] = 1;
//byte [] message = "100000060".getBytes();
channelHandlerContext.writeAndFlush(test);
}
@Override
public void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf in) {
System.out.println("Client received: " + in.toString(CharsetUtil.UTF_8));
}
@Override
public void exceptionCaught(ChannelHandlerContext channelHandlerContext, Throwable cause){
cause.printStackTrace();
LOGGER.info("Exception Occurred in ChannelHandler A");
channelHandlerContext.close();
}
/*@Override
protected void channelRead0(ChannelHandlerContext channelHandlerContext, Object o) throws Exception {
System.out.println("Client received: " + o.toString());
}*/
}
谢谢。
解决方案
您可以通过更新您的channelRead0
方法来检查收到的消息,然后在收到您正在寻找的消息时回复。
@Override
public void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf in) {
String message = in.toString(CharsetUtil.UTF_8);
if (message.equals("10000051")) { //Now do what you were doing in channel active
byte [] test = new byte[9];
test[0] = 0;
test[1] = 6;
test[2] = 0;
test[3] = 0;
test[4] = 0;
test[5] = 0;
test[6] = 0;
test[7] = 0;
test[8] = 1;
//byte [] message = "100000060".getBytes();
channelHandlerContext.writeAndFlush(test);
}
}
推荐阅读
- angular - Angular BehaviorSubject 事件多次发出
- python - 给定特定值,如何返回字典中的前一个键?
- html - 标签不会显示在单选按钮旁边
- typescript - 在 Typescript 中跨模块共享类型的最佳实践是什么?
- oculus - MRTK Gaze Provider Pointer 在 Oculus Rift 和 Touch 中消失
- django - Django如何将实例传递给查看
- c++ - 在 Windows 上使用 ReadDirectoryChangesW 丢失一些事件
- spring-cloud-gateway - 如何移除响应头,例如 Access-Control-Allow-Origin、Access-Control-Allow-Credentials
- ejabberd - Ejabberd Rest-api - Rest-API 调用上的 JSON 输入无效
- javascript - 如何在不使用js方法的情况下使用for循环从数组数组中删除项目?