package com.wgcloud.common;
|
|
import io.netty.bootstrap.ServerBootstrap;
|
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.EventLoopGroup;
|
import io.netty.channel.nio.NioEventLoopGroup;
|
import io.netty.channel.socket.nio.NioServerSocketChannel;
|
|
/**
|
* @version v3.3
|
* @ClassName:NettyServer.java
|
* @author: http://www.wgstart.com
|
* @date: 2021年4月22日
|
* @Description: netty服务器
|
* @Copyright: 2019-2021 wgcloud. All rights reserved.
|
*/
|
public class NettyServer {
|
|
public static void start(int port) throws InterruptedException {
|
//创建主线程组，接收请求
|
EventLoopGroup bossGroup = new NioEventLoopGroup();
|
//创建从线程组，处理主线程组分配下来的io操作
|
EventLoopGroup workerGroup = new NioEventLoopGroup();
|
//创建netty服务器
|
try {
|
ServerBootstrap serverBootstrap = new ServerBootstrap();
|
serverBootstrap.group(bossGroup, workerGroup)//设置主从线程组
|
.channel(NioServerSocketChannel.class)//设置通道
|
.childHandler(new NettyServerInitializer());//子处理器，用于处理workerGroup中的操作
|
//启动server
|
ChannelFuture channelFuture = serverBootstrap.bind(port).sync();
|
//监听关闭channel
|
channelFuture.channel().closeFuture().sync();
|
} finally {
|
bossGroup.shutdownGracefully();//关闭主线程
|
workerGroup.shutdownGracefully();//关闭从线程
|
}
|
}
|
|
}
|
