保安员新增同步编号问题

Administrator

2022-06-16 2ebca060a47784db76369a4aa84f63293da9be33

 src/main/java/org/springblade/modules/nettyServer/Server.java

@@ -1,86 +1,86 @@
package org.springblade.modules.nettyServer;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.ServerSocketChannel;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;


public class Server {
   private int port;
   private ServerSocketChannel serverSocketChannel;

   public Server(int port){
      this.port = port;
      bind();
   }

   private void bind() {
      Thread thread = new Thread(new Runnable() {
         @Override
         public void run() {
            //服务端要建立两个group，一个负责接收客户端的连接，一个负责处理数据传输
            //连接处理group
            EventLoopGroup boss = new NioEventLoopGroup();
            //事件处理group
            EventLoopGroup worker = new NioEventLoopGroup();
            ServerBootstrap bootstrap = new ServerBootstrap();
            // 绑定处理group
            bootstrap.group(boss, worker).channel(NioServerSocketChannel.class)
               //保持连接数
               .option(ChannelOption.SO_BACKLOG, 1024)
               //有数据立即发送
               .option(ChannelOption.TCP_NODELAY, true)
               //保持连接
               .childOption(ChannelOption.SO_KEEPALIVE, true)
               //处理新连接
               .childHandler(new ChannelInitializer<SocketChannel>() {
                  @Override
                  protected void initChannel(SocketChannel sc) throws Exception {
                     // 增加任务处理
                     ChannelPipeline p = sc.pipeline();
                     p.addLast(
//                                        //使用了netty自带的编码器和解码器
//                                        new StringDecoder(),
//                                        new StringEncoder(),
                        //心跳检测，读超时，写超时，读写超时
                        //new IdleStateHandler(5, 0, 0, TimeUnit.SECONDS),
                        //自定义的处理器
                        new ServerHandler());
                  }
               });

            //绑定端口，同步等待成功
            ChannelFuture future;
            try {
               future = bootstrap.bind(port).sync();
               if (future.isSuccess()) {
                  serverSocketChannel = (ServerSocketChannel) future.channel();
                  System.out.println("服务端启动成功，端口："+port);
               } else {
                  System.out.println("服务端启动失败！");
               }

               //等待服务监听端口关闭,就是由于这里会将线程阻塞，导致无法发送信息，所以我这里开了线程
               future.channel().closeFuture().sync();
            } catch (Exception e) {
               e.printStackTrace();
            }
            finally {
               //优雅地退出，释放线程池资源
               boss.shutdownGracefully();
               worker.shutdownGracefully();
            }
         }
      });
      thread.start();
   }

   public void sendMessage(Object msg){
      if(serverSocketChannel != null){
         serverSocketChannel.writeAndFlush(msg);
      }
   }
}
//package org.springblade.modules.nettyServer;
//
//import io.netty.bootstrap.ServerBootstrap;
//import io.netty.channel.*;
//import io.netty.channel.nio.NioEventLoopGroup;
//import io.netty.channel.socket.ServerSocketChannel;
//import io.netty.channel.socket.SocketChannel;
//import io.netty.channel.socket.nio.NioServerSocketChannel;
//
//
//public class Server {
//   private int port;
//   private ServerSocketChannel serverSocketChannel;
//
//   public Server(int port){
//      this.port = port;
//      bind();
//   }
//
//   private void bind() {
//      Thread thread = new Thread(new Runnable() {
//         @Override
//         public void run() {
//            //服务端要建立两个group，一个负责接收客户端的连接，一个负责处理数据传输
//            //连接处理group
//            EventLoopGroup boss = new NioEventLoopGroup();
//            //事件处理group
//            EventLoopGroup worker = new NioEventLoopGroup();
//            ServerBootstrap bootstrap = new ServerBootstrap();
//            // 绑定处理group
//            bootstrap.group(boss, worker).channel(NioServerSocketChannel.class)
//               //保持连接数
//               .option(ChannelOption.SO_BACKLOG, 1024)
//               //有数据立即发送
//               .option(ChannelOption.TCP_NODELAY, true)
//               //保持连接
//               .childOption(ChannelOption.SO_KEEPALIVE, true)
//               //处理新连接
//               .childHandler(new ChannelInitializer<SocketChannel>() {
//                  @Override
//                  protected void initChannel(SocketChannel sc) throws Exception {
//                     // 增加任务处理
//                     ChannelPipeline p = sc.pipeline();
//                     p.addLast(
////                                        //使用了netty自带的编码器和解码器
////                                        new StringDecoder(),
////                                        new StringEncoder(),
//                        //心跳检测，读超时，写超时，读写超时
//                        //new IdleStateHandler(5, 0, 0, TimeUnit.SECONDS),
//                        //自定义的处理器
//                        new ServerHandler());
//                  }
//               });
//
//            //绑定端口，同步等待成功
//            ChannelFuture future;
//            try {
//               future = bootstrap.bind(port).sync();
//               if (future.isSuccess()) {
//                  serverSocketChannel = (ServerSocketChannel) future.channel();
//                  System.out.println("服务端启动成功，端口："+port);
//               } else {
//                  System.out.println("服务端启动失败！");
//               }
//
//               //等待服务监听端口关闭,就是由于这里会将线程阻塞，导致无法发送信息，所以我这里开了线程
//               future.channel().closeFuture().sync();
//            } catch (Exception e) {
//               e.printStackTrace();
//            }
//            finally {
//               //优雅地退出，释放线程池资源
//               boss.shutdownGracefully();
//               worker.shutdownGracefully();
//            }
//         }
//      });
//      thread.start();
//   }
//
//   public void sendMessage(Object msg){
//      if(serverSocketChannel != null){
//         serverSocketChannel.writeAndFlush(msg);
//      }
//   }
//}