#

whycq

2024-08-17 20245e35da8a9d809b2de91f4ec29dd39127f9d5

 app/src/main/java/com/example/agvcontroller/socket/NettyServer.java

@@ -1,5 +1,6 @@
package com.example.agvcontroller.socket;

import com.example.agvcontroller.protocol.MessageBodyHandler;
import com.example.agvcontroller.protocol.ProtocolDecoder;
import com.example.agvcontroller.protocol.ProtocolEncoder;

@@ -35,7 +36,10 @@
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) throws Exception {
                            ch.pipeline().addLast(new NettyServerHandler()).addLast(new ProtocolEncoder());
                            ch.pipeline().addLast(new ProtocolEncoder())
                                    .addLast(new ProtocolDecoder(4096))
                                    .addLast(new MessageBodyHandler())
                                    .addLast(new NettyServerHandler());
                        }
                    })
//                    .addLast(new NettyServerHandler())