java - Netty TCP服务器字符变成垃圾

Question

我已分配在我的组织中做 TCP 服务器来接收短信并拆分它们。但不幸的是我的一些消息字符变成垃圾(我使用 JMeter 作为我的 TCP 客户端)。我有两个与此问题相关的问题。非常感谢任何帮助。

1. Why we can not split my message using "»" (u00BB) character? It never worked and how we could use "»" as delimiter in DelimiterBasedFrameDecoder?

2. Why we receive garbage characters although I used UTF-8 in encoding/decoding? (Only manage to receive messages when I comment "pipeline.addLast("frameDecoder", new io.netty.handler.codec.DelimiterBasedFrameDecoder( 500000, byteDeli)" )

示例请求:

pov1‹1‹202030‹81056581‹0‹6‹565810000011‹0‹130418135639‹3‹4‹0‹cha7373737›chaE15E2512380›1›1«ban7373737›banE15E2512380›2›2«ind7373737›indE15E2512380›3›3»

Eclipse 控制台:已收到请求::::::

pov1�1�202030�81056581�0�6�565810000011�0�130418135639�3�4�0�cha7373737�chaE15E2512380�1�1�ban7373737�banE15E2512380�2�2�ind7373737�indE15E2512380�3�3�

服务器类别:-

public void run() {
            try {
                System.out.println("2:run");
                bootstrap
                        .group(bossGroup, workerGroup)
                        .channel(NioServerSocketChannel.class)
                        .childHandler(new ChannelInitializer<SocketChannel>() {
                            @Override
                            public void initChannel(SocketChannel ch)
                                    throws Exception {
                                ChannelPipeline pipeline = ch.pipeline();
                                DTMTCPServiceHandler serviceHandler = context
                                        .getBean(DTMTCPServiceHandler.class);
                                pipeline.addFirst(new LoggingHandler(
                                        LogLevel.INFO));
                                
                                byte[] delimiter = "\u00BB".getBytes(CharsetUtil.UTF_8);//»
                                ByteBuf byteDeli = Unpooled.copiedBuffer(delimiter);                                
                                
                                pipeline.addLast(
                                        "frameDecoder",
                                        new io.netty.handler.codec.DelimiterBasedFrameDecoder(
                                                500000, byteDeli)); // Decoders
                                pipeline.addLast("stringDecoder",
                                        new StringDecoder(CharsetUtil.UTF_8));
                                pipeline.addLast("stringEncoder",
                                        new StringEncoder(CharsetUtil.UTF_8));
                                pipeline.addLast("messageHandler",
                                        serviceHandler);

                            }
                        }).option(ChannelOption.SO_BACKLOG, 128)
                        .childOption(ChannelOption.SO_KEEPALIVE, true);
                serverChannel = bootstrap.bind(7070).sync().channel()
                        .closeFuture().sync().channel();
            } catch (InterruptedException e) {
                //error
                logger.error("POSGatewayServiceThread : InterruptedException",
                        e);
                System.out.println(e);
            } finally {
                //finally
                System.out.println("finally");
                serverChannel.close();
                workerGroup.shutdownGracefully();
                bossGroup.shutdownGracefully();
            }

        }

处理程序类

public class DTMTCPServiceHandler extends ChannelInboundHandlerAdapter {
    
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        String posMessage = msg.toString();
        
        System.out.println("Recieved Request :::::: " + posMessage);
        String response = "-";
        ByteBuf copy = null;
        try {
            //Called to separate splitter class
            response = dtmtcpServiceManager.manageDTMTCPMessage(posMessage);
            copy = Unpooled.copiedBuffer(response.getBytes());

        } finally {
            logger.info("Recieved Response :::::: " + response);
            ctx.write(copy);
            ctx.flush();
        }

    }       
    
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        //Open
        super.channelActive(ctx);
    }       
    
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        //End
        super.channelReadComplete(ctx);
    }
    
            @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        //exception
        ctx.close();
    }
}

Answer 1

发现问题，与netty无关。错误在于 JMeter 编码。修改“jmeter.properties”属性文件@\apache-jmeter-x.xx\bin后成功解决了这个问题。

tcp.charset=UTF-8

很抱歉打扰你们，因为我是假的。