前言
因?yàn)槟芰τ邢蓿€是有很多東西（SO_REUSEADDR和SO_REUSEPORT的區(qū)別等）沒有能夠在一篇文字中表達(dá)清楚，作為補(bǔ)遺，也方便以后自己回過頭來復(fù)習(xí)。
SO_REUSADDR VS SO_REUSEPORT
兩者不是一碼事，沒有可比性。有時(shí)也會(huì)被其搞暈，自己總結(jié)的不好，推薦StackOverflow的Socket options SO_REUSEADDR and SO_REUSEPORT, how do they differ?資料，總結(jié)的很全面。
簡(jiǎn)單來說：
- 設(shè)置了SO_REUSADDR的應(yīng)用可以避免TCP 的 TIME_WAIT 狀態(tài) 時(shí)間過長(zhǎng)無法復(fù)用端口，尤其表現(xiàn)在應(yīng)用程序關(guān)閉-重啟交替的瞬間
- SO_REUSEPORT更強(qiáng)大，隸屬于同一個(gè)用戶（防止端口劫持）的多個(gè)進(jìn)程/線程共享一個(gè)端口，同時(shí)在內(nèi)核層面替上層應(yīng)用做數(shù)據(jù)包進(jìn)程/線程的處理均衡
若有困惑，推薦兩者都設(shè)置，不會(huì)有沖突。
Netty多線程使用SO_REUSEPORT
上一篇講到SO_REUSEPORT，多個(gè)程綁定同一個(gè)端口，可以根據(jù)需要控制進(jìn)程的數(shù)量。這里講講基于Netty 4.0.25+Epoll navtie transport在單個(gè)進(jìn)程內(nèi)多個(gè)線程綁定同一個(gè)端口的情況，也是比較實(shí)用的。
TCP服務(wù)器，同一個(gè)進(jìn)程多線程綁定同一個(gè)端口
這是一個(gè)PING-PONG示范應(yīng)用：
public void run() throws Exception {
final EventLoopGroup bossGroup = new EpollEventLoopGroup();
final EventLoopGroup workerGroup = new EpollEventLoopGroup();
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(EpollServerSocketChannel. class)
.childHandler( new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(
new StringDecoder(CharsetUtil.UTF_8 ),
new StringEncoder(CharsetUtil.UTF_8 ),
new PingPongServerHandler());
}
}).option(ChannelOption. SO_REUSEADDR, true)
.option(EpollChannelOption. SO_REUSEPORT, true)
.childOption(ChannelOption. SO_KEEPALIVE, true);
int workerThreads = Runtime.getRuntime().availableProcessors();
ChannelFuture future;
for ( int i = 0; i < workerThreads; ++i) {
future = b.bind( port).await();
if (!future.isSuccess())
throw new Exception(String. format("fail to bind on port = %d.",
port), future.cause());
}
Runtime. getRuntime().addShutdownHook (new Thread(){
@Override
public void run(){
workerGroup.shutdownGracefully();
bossGroup.shutdownGracefully();
}
});
}
打成jar包，在CentOS 7下面運(yùn)行，檢查同一個(gè)端口所打開的文件句柄。
# lsof -i:8000
COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME
java 3515 root 42u IPv6 29040 0t0 TCP *:irdmi (LISTEN)
java 3515 root 43u IPv6 29087 0t0 TCP *:irdmi (LISTEN)
java 3515 root 44u IPv6 29088 0t0 TCP *:irdmi (LISTEN)
java 3515 root 45u IPv6 29089 0t0 TCP *:irdmi (LISTEN)
同一進(jìn)程，但打開的文件句柄是不一樣的。
UDP服務(wù)器，多個(gè)線程綁同一個(gè)端口
/**
* UDP諺語(yǔ)服務(wù)器，單進(jìn)程多線程綁定同一端口示范
*/
public final class QuoteOfTheMomentServer {
private static final int PORT = Integer.parseInt(System. getProperty("port" ,
"9000" ));
public static void main(String[] args) throws Exception {
final EventLoopGroup group = new EpollEventLoopGroup();
Bootstrap b = new Bootstrap();
b.group(group).channel(EpollDatagramChannel. class)
.option(EpollChannelOption. SO_REUSEPORT, true )
.handler( new QuoteOfTheMomentServerHandler());
int workerThreads = Runtime.getRuntime().availableProcessors();
for (int i = 0; i < workerThreads; ++i) {
ChannelFuture future = b.bind( PORT).await();
if (!future.isSuccess())
throw new Exception(String.format ("Fail to bind on port = %d.",
PORT), future.cause());
}
Runtime. getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
group.shutdownGracefully();
}
});
}
}
}
@Sharable
class QuoteOfTheMomentServerHandler extends
SimpleChannelInboundHandler<DatagramPacket> {
private static final String[] quotes = {
"Where there is love there is life." ,
"First they ignore you, then they laugh at you, then they fight you, then you win.",
"Be the change you want to see in the world." ,
"The weak can never forgive. Forgiveness is the attribute of the strong.", };
private static String nextQuote() {
int quoteId = ThreadLocalRandom.current().nextInt( quotes .length );
return quotes [quoteId];
}
@Override
public void channelRead0(ChannelHandlerContext ctx, DatagramPacket packet)
throws Exception {
if ("QOTM?" .equals(packet.content().toString(CharsetUtil. UTF_8))) {
ctx.write( new DatagramPacket(Unpooled.copiedBuffer( "QOTM: "
+ nextQuote(), CharsetUtil. UTF_8), packet.sender()));
}
}
@Override
public void channelReadComplete(ChannelHandlerContext ctx) {
ctx.flush();
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
}
}
同樣也要檢測(cè)一下端口文件句柄打開情況：
COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME
java 3181 root 26u IPv6 27188 0t0 UDP *:cslistener
java 3181 root 27u IPv6 27217 0t0 UDP *:cslistener
java 3181 root 28u IPv6 27218 0t0 UDP *:cslistener
java 3181 root 29u IPv6 27219 0t0 UDP *:cslistener
小結(jié)
以上為Netty+SO_REUSEPORT多線程綁定同一端口的一些情況，是為記載。