| File was renamed from ZuulQYTTravel/src/main/java/com/sinata/zuul/util/echo/NettyServer.java |
| | |
|---|
| | | package com.sinata.zuul.util.echo; |
|---|
| | | package com.sinata.push.util.echo; |
|---|
| | | |
|---|
| | | import io.netty.bootstrap.ServerBootstrap; |
|---|
| | | import io.netty.channel.ChannelFuture; |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 获取即时通讯启动端口 |
|---|
| | | */ |
|---|
| | | private Integer nettyPort = 5200; |
|---|
| | | private Integer nettyPort = 9999; |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | EventLoopGroup bossGroup = new NioEventLoopGroup(); |
|---|
| | |
|---|
| | | bootstrap.channel(NioServerSocketChannel.class); |
|---|
| | | bootstrap.option(ChannelOption.SO_BACKLOG, 1024); |
|---|
| | | // 通过TCP_NODELAY禁用NAGLE,使消息立即发出去，不用等待到一定的数据量才发出去 |
|---|
| | | bootstrap.option(ChannelOption.TCP_NODELAY, true); |
|---|
| | | bootstrap.childOption(ChannelOption.TCP_NODELAY, true); |
|---|
| | | // 保持长连接状态 |
|---|
| | | bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true); |
|---|
| | | bootstrap.childHandler(new ServerInit() { |
|---|
