执法记录仪移动位置插入新增

zhongrj

2023-03-04 6c05d0bde1a620e355d8543e909d99e6487e333c

 src/main/java/com/genersoft/iot/vmp/netty/server/UdpServer.java

@@ -31,15 +31,16 @@
      Thread thread = new Thread(new Runnable() {
         @Override
         public void run() {
            //InetSocketAddress socketAddress = new InetSocketAddress("s16s652780.51mypc.cn", 21403);
            //启动服务
            EventLoopGroup workerGroup = new NioEventLoopGroup();
            //优化使用的线程
            final EventExecutorGroup group = new DefaultEventExecutorGroup(16);

            try {
               Bootstrap b = new Bootstrap();//udp不能使用ServerBootstrap
               b.group(workerGroup).channel(NioDatagramChannel.class)//设置UDP通道
               //udp不能使用ServerBootstrap
               Bootstrap b = new Bootstrap();
               //设置UDP通道
               b.group(workerGroup).channel(NioDatagramChannel.class)
                  //设置udp的管道工厂
                  .handler(new ChannelInitializer<NioDatagramChannel>() {
                     //NioDatagramChannel标志着是UDP格式的
@@ -57,9 +58,11 @@

                  })//初始化处理器
                  //true / false 多播模式(UDP适用),可以向多个主机发送消息
                  .option(ChannelOption.SO_BROADCAST, true)// 支持广播
                  .option(ChannelOption.SO_RCVBUF, 2048 * 1024)// 设置UDP读缓冲区为2M
                  .option(ChannelOption.SO_SNDBUF, 1024 * 1024);// 设置UDP写缓冲区为1M
                  .option(ChannelOption.SO_BROADCAST, true)
                  // 设置UDP读缓冲区为2M
                  .option(ChannelOption.SO_RCVBUF, 2048 * 1024)
                  // 设置UDP写缓冲区为1M
                  .option(ChannelOption.SO_SNDBUF, 1024 * 1024);

               // 绑定端口，开始接收进来的连接
               ChannelFuture f = b.bind(port).sync();