//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);
|
// }
|
// }
|
//}
|
