- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我正在开发 Netty 应用程序。我想在不同的端口上运行多个服务器,如果没有(阻塞)closeFuture().sync()
就无法工作。
我使用以下代码在我的 ServerManager
类中启动服务器:
gpcmServer = new GpcmServer(port);
gpspServer = new GpspServer(port);
在这些类中,我按如下方式启动服务器:
public GpspServer(int port) throws InterruptedException {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
// Add the server handler and its decoder
ch.pipeline().addLast(new GpspDecoder(), new GpspServerHandler());
}
})
.option(ChannelOption.SO_BACKLOG, 128)
.childOption(ChannelOption.SO_KEEPALIVE, true);
// Bind and start to accept incoming connections.
bindFuture = bootstrap.bind(port).sync();
bindFuture.channel().closeFuture();
} finally {
workerGroup.shutdownGracefully();
bossGroup.shutdownGracefully();
}
}
但是,当我不调用closeFuture().sync()
时,我无法连接到服务器。当我将 .sync()
添加到 bindFuture.channel().closeFuture()
时,我可以连接到服务器。我怎样才能继续这样做并使服务器正常工作?
最佳答案
当您调用 EventLoopGroup.shutdown*()
方法时,事件循环将在终止自身之前关闭它管理的所有套接字和服务器套接字。因此,如果您没有等到服务器套接字关闭,您的 finally
block 将完全终止您的服务器。
运行多个服务器实际上需要做的是:
shutdownGracefully()
,直到您想关闭服务器。关于java - 在没有 closeFuture().sync() 的情况下在 Netty 中运行多个服务器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28947127/
public class ChannelActiveHandler extends SimpleChannelInboundHandler { @Override public voi
我正在学习 Netty,并开始使用 Spring Boot 进行一些教程。我的目标是创建一个应用程序,该应用程序设置一个用于接收消息的 tcp 端口并通过 rest api 呈现它们。 大多数教程都说
我正在开发 Netty 应用程序。我想在不同的端口上运行多个服务器,如果没有(阻塞)closeFuture().sync() 就无法工作。 我使用以下代码在我的 ServerManager 类中启动服
我目前正在使用 Netty 用 Java 编写一个程序,我偶然发现了以下问题: 每当我在“引导”完成后尝试使用channel#closeFuture().sync()时,它永远不会完成任务并永远锁
当我尝试关闭 io.netty.channel.Channel TCP/IP 客户端连接时,我的 Netty 应用挂起。 我愿意: ch.isOpen(); //this is TRUE ch.clo
我是一名优秀的程序员,十分优秀!