| | |
|---|
| | | public void run() { |
|---|
| | | thread.start(); |
|---|
| | | } |
|---|
| | | }, 10000); |
|---|
| | | }, 3999); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 获取即时通讯启动端口 |
|---|
| | | */ |
|---|
| | | private Integer nettyPort = 9999; |
|---|
| | | private Integer nettyPort = 9909; |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | EventLoopGroup bossGroup = new NioEventLoopGroup(); |
|---|
| | |
|---|
| | | bootstrap.channel(NioServerSocketChannel.class); |
|---|
| | | bootstrap.option(ChannelOption.SO_BACKLOG, 1024); |
|---|
| | | // 通过TCP_NODELAY禁用NAGLE,使消息立即发出去，不用等待到一定的数据量才发出去 |
|---|
| | | bootstrap.childOption(ChannelOption.TCP_NODELAY, true); |
|---|
| | | bootstrap.option(ChannelOption.TCP_NODELAY, true); |
|---|
| | | // 保持长连接状态 |
|---|
| | | bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true); |
|---|
| | | bootstrap.childHandler(new ServerInit() { |
|---|
