package com.ruoyi.netty.communication;
|
|
|
import io.netty.bootstrap.ServerBootstrap;
|
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.ChannelOption;
|
import io.netty.channel.ChannelPipeline;
|
import io.netty.channel.EventLoopGroup;
|
import io.netty.channel.nio.NioEventLoopGroup;
|
import io.netty.channel.socket.SocketChannel;
|
import io.netty.channel.socket.nio.NioServerSocketChannel;
|
import io.netty.handler.timeout.ReadTimeoutHandler;
|
import io.netty.util.concurrent.DefaultEventExecutorGroup;
|
import io.netty.util.concurrent.EventExecutorGroup;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* @author 86175
|
*/
|
@Slf4j
|
public class TcpServer {
|
|
|
/**
|
* 用于分配处理业务线程的线程组个数
|
*/
|
protected static final int BIZGROUPSIZE = Runtime.getRuntime().availableProcessors() * 2;
|
/**
|
* 业务出现线程大小
|
*/
|
protected static final int BIZTHREADSIZE = 4;
|
/**
|
* 监听客户端请求
|
*/
|
private static final EventLoopGroup BOSS_GROUP = new NioEventLoopGroup(BIZGROUPSIZE);
|
/**
|
* 处理请求
|
*/
|
private static final EventLoopGroup WORKER_GROUP = new NioEventLoopGroup(BIZTHREADSIZE);
|
|
private static final EventExecutorGroup EXEC_GROUP = new DefaultEventExecutorGroup(100);
|
|
|
public void init(String iP, Integer port) {
|
|
log.info("-----------正在启动服务器，请稍后-----------");
|
|
try {
|
ServerBootstrap b = new ServerBootstrap();
|
b.group(BOSS_GROUP, WORKER_GROUP);
|
b.channel(NioServerSocketChannel.class);
|
|
b.childHandler(new ChannelInitializer<SocketChannel>() {
|
@Override
|
protected void initChannel(SocketChannel socketChannel) {
|
|
ChannelPipeline pipeline = socketChannel.pipeline();
|
|
pipeline.addLast(new SocketDecoder());//服务端：接受数据
|
pipeline.addLast(new SocketEncoder());//服务端：发送数据
|
|
pipeline.addLast(new ReadTimeoutHandler(ServerPeriod.TIMEOUT.getValue(), TimeUnit.SECONDS));
|
|
pipeline.addLast(EXEC_GROUP, new OptometerServerHandler());
|
|
}
|
});
|
//缓冲区
|
b.option(ChannelOption.SO_BACKLOG, 1024);
|
b.bind(iP, port).sync();
|
log.info("启动tcp服务器启动成功，正在监听端口:" + port + "服务器ip地址：" + iP);
|
} catch (InterruptedException e) {
|
log.info("tcp服务器出现异常：");
|
|
}
|
|
|
}
|
|
}
|
