zhenjunma / javahotfix Goto Github PK

在接受完所有三种类型数据的时候，需要重新监听/tmp/hotfix.sock，当接受到热更新信号的时候，需要将ServerStatus status变更为ServerStatus.HOT_FIX，源代码补充如下
public void startHotFixServer() { new Thread(() -> { try { ServerBootstrap b = new ServerBootstrap(); b.group(bossGroup, workerGroup) .channel(EpollServerDomainSocketChannel.class) .childHandler(new ChannelInboundHandlerAdapter() { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ByteBuf buf = (ByteBuf) msg; if (buf.readInt() == 1){ //关闭监听 hotFixServerChannelFuture.channel().close().addListener(future -> { if (!future.isSuccess()){ future.cause().printStackTrace(); } }); /* 老者接收到迁移信号：1，开始迁移连接信息 */ System.out.println("老者接收到迁移信号：1，开始迁移连接信息"); status = ServerStatus.HOT_FIX; //这里就是遗漏的地方 startListenerTransferTask(); } } }); SocketAddress s = new DomainSocketAddress(DomainSocketAddressEnum.TAG_HOTFIX.path()); hotFixServerChannelFuture = b.bind(s).sync(); }catch (Exception e){ e.printStackTrace(); } }).start(); System.out.println("启动监听hot-fix"); }

目前我在调研Netty的fd迁移方案，有幸看到大佬的Netty实现。想请问一下，之前貌似是使用的SO_REUSEPORT的方案来实现的，后来又改成了基于uds来实现的，请问如果是基于SO_REUSEPORT来实现的话，是有什么问题吗？