Нетные двоичные данные не очищаются до 0x0a

Question

Моему приложению netty server нужно ответить клиенту двоичными данными, но оно кажется сброшенным только при достижении 0x0a.

private Logger _log = LoggerFactory.getLogger(getClass());
private EventLoopGroup _masterGroup = new NioEventLoopGroup();
private EventLoopGroup _workerGroup = new NioEventLoopGroup();
private ByteArrayDecoder _decoder = new ByteArrayDecoder();
private ByteArrayEncoder _encoder = new ByteArrayEncoder();
private Channel _channel;

@PostConstruct
public void start() throws InterruptedException {
    _log.info("component ready");

    ServerBootstrap bootstrap = new ServerBootstrap()
            .channel(NioServerSocketChannel.class)
            .group(_masterGroup, _workerGroup)
            .option(ChannelOption.SO_BACKLOG, 100)
            .option(ChannelOption.TCP_NODELAY, true)
            .option(ChannelOption.SO_KEEPALIVE, true)
            .childHandler(new ChannelInitializer<SocketChannel>() {

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

                    pipe.addLast(_decoder);
                    pipe.addLast(_encoder);
                    pipe.addLast(new ChannelDuplexHandler() {
                        @Override
                        public void channelRead(ChannelHandlerContext ctx, Object msg) {
                            byte[] data = (byte[])msg;
                            StringBuffer buf = new StringBuffer();

                            for(byte b : data) {
                                buf.append(String.format("%02x", b)).append(" ");
                            }

                            _log.info(buf.toString());

                            ctx.writeAndFlush(new byte[] { 0x31, 0x32, 0x33, 0x34, 0x35, 0x0a, 0x36, 0x37 });
                        }
                    });
                }

            });

    _channel = bootstrap.bind(8090).sync().channel().closeFuture().sync().channel();
    _log.info("server readey, listening port: 8090");
}

Ожидаемый результат должен быть массивом из 8 байтов, но я получил только 5 байтов. Итак, как правильно отправить мой буфер?

редактировать: добавить мою программу тестирования

private String send(byte[] msg) {
    InputStream in = null;
    OutputStream out = null;
    Socket socket = null;
    String result = null;

    try {
        _log.debug("connecting...");
        socket = new Socket();
        socket.connect(new InetSocketAddress(_ip, _port), 500);
        socket.setKeepAlive(false);

        _log.debug("sending message...");
        out = socket.getOutputStream();
        out.write(msg);
        out.flush();

        _log.debug("reading response...");
        in = socket.getInputStream();
        BufferedReader reader = new BufferedReader(new InputStreamReader(in));

        while(null != (result = reader.readLine())) {
            printBuffer("server response", result.getBytes());
        }
    } catch(Exception e) {
        _log.error(e.getMessage());
    } finally {
        try {
            if(null != in) in.close();
            if(null != out) out.close();
            if(null != socket) socket.close();
        } catch(IOException e) {
            _log.error(e.getMessage());
        }
    }

    return result;
}

Answer 1

Сервер работает правильно, как тестовая программа. Но вы читаете ответ, используя метод readLine(), который читает байты построчно. Первая ваша строка - [0x31, 0x32, 0x33, 0x34, 0x35], затем [0x0a] - символ "новой строки", который не включен в результат readLine(). Затем новая строка [0x36, 0x37], но эта строка не имеет конца, такого как "перевод строки" или "возврат каретки", поэтому она также не отображается.

Вам следует переписать вашу тестовую программу так, чтобы она читала и отображала поток байтов вместо строк.