Netty - операция записи и чтения клиента - PullRequest
Новая
       7

Netty - операция записи и чтения клиента

0 голосов
/ 03 октября 2018

Я пытаюсь отправить и получить сообщение с сервера.Сервер был построен в удаленной среде.

На сервере есть несколько специальных сигнальных кодов, например: enter image description here

Эти коды отправляются как байт .В этот момент начинается проблема.

Когда клиент подключается к серверу, сервер немедленно отправляет 100000050, а через несколько мс отправляет 10000051.

Я должен отправить 10000060 после получения 10000051, но я не знаю, как.

CLIENT.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();
        }
    }

CLIENTHANDLER.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());
    }*/
}

Спасибо.

1 Ответ

0 голосов
/ 03 октября 2018

Вы можете сделать это, обновив метод 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);
    }
}
...