Netty 5.0.0 closeFuture().sync()从不结束
Netty是一个基于Java的高性能网络应用框架，用于快速开发可扩展的网络服务器和客户端。它提供了一种简单而强大的方式来处理异步事件驱动的网络应用程序，具有高度的灵活性和可扩展性。
在Netty中，closeFuture().sync()是一个用于同步关闭Channel的方法。它会阻塞当前线程，直到Channel关闭完成才会继续执行后续代码。closeFuture()返回一个ChannelFuture对象，它表示Channel的关闭操作，而sync()方法则会等待该操作完成。
在使用Netty时，通常会在需要关闭Channel的地方调用close()方法来关闭它。而closeFuture().sync()的作用是等待Channel关闭完成，以确保在继续执行后续代码之前，Channel已经完全关闭。
这种方式的使用场景包括：
- 在应用程序中需要等待Channel关闭完成后再执行后续操作，例如在关闭网络连接之前需要先发送一些数据。
- 在进行单元测试时，可以使用closeFuture().sync()来确保测试代码在Channel关闭后再执行断言或验证操作。
腾讯云提供了一系列与Netty相关的产品和服务，例如云服务器、负载均衡、弹性伸缩等，可以帮助开发者构建高性能的网络应用。具体产品和服务的介绍可以参考腾讯云官方文档：腾讯云产品与服务。
相关·内容
我目前正在使用Netty用Java编写一个程序，我偶然发现了以下问题：
每当我在"bootstrap“完成后尝试使用channel#closeFuture().sync()时，它永远不会完成任务并永远锁定主线程。任何异常都不会抛出。
我的启动代码：
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap serverBootstrap = new ServerBootstr
浏览 16提问于2017-02-16得票数 0
回答已采纳
我试图在Spigot服务器上启动外部Netty服务器。
我唯一试过的就是一开始就启动它，但问题是用户无法加入，服务器超时。
这是Netty-Client的代码，它应该连接到工作正常的Netty-Server。
EventLoopGroup eventLoopGroup = EPOLL ? new EpollEventLoopGroup() : new NioEventLoopGroup();
try {
Bootstrap bootstrap = new Bootstrap()
.group( eventLoopGroup )
.option( Chan
浏览 0提问于2017-10-12得票数 0
当我试图关闭io.netty.channel.Channel TCP/IP客户端连接时，我的Netty应用程序挂起。
我知道：
ch.isOpen(); //this is TRUE
ch.closeFuture().sync(); //never returns
这里是线程调用同步的堆栈跟踪。
JavaFX Application Thread@583, prio=5, in group 'main', status: 'WAIT'
at java.lang.Object.wait(Object.java:-1)
at java.lang.Object.wai
浏览 1提问于2014-06-16得票数 2
回答已采纳
在调用这些函数时，我需要期待任何异常吗？
io.netty.channel.Channel.write(...)
io.netty.channel.Channel.flush(...)
io.netty.channel.Channel.writeAndFlush(...)
io.netty.channel.ChannelHandlerContext.write(...)
io.netty.channel.ChannelHandlerContext.writeAndFlush(...)
看起来不是。没有检查异常，没有记录抛出，我也没有在任何示例代码中看到任何try/catch块。然而，我似乎找不
浏览 1提问于2014-01-25得票数 2
我想关闭Netty服务器上的服务器套接字，然后等待所有子节点在执行资源清理之前完成处理。
步骤1等待Netty服务器套接字使用以下代码关闭主线程，其中b是ServerBootstrap的实例
b.bind ( getPort ( p ) ).sync ().channel ().closeFuture ().sync ()
步骤2指示服务器套接字从应用程序中的其他线程关闭。
步骤3指示所有客户端关闭，我将有执行此操作的应用程序代码。
步骤4等待所有客户端套接字关闭，这是我想知道如何做。如何获得所有客户端套接字(服务器的子节点)的列表，然后等待所有客户端套接字关闭？
Netty版本4.1.1.终
浏览 3提问于2016-06-19得票数 1
回答已采纳
我在做一个Netty应用程序。我希望在不同的端口上运行多个服务器，如果没有(阻塞) closeFuture().sync()，这是无法工作的。
我使用以下代码启动ServerManager类中的服务器：
gpcmServer = new GpcmServer(port);
gpspServer = new GpspServer(port);
在这些类中，我按照以下方式启动服务器：
public GpspServer(int port) throws InterruptedException {
EventLoopGroup bossGroup = new NioEventLo
浏览 3提问于2015-03-09得票数 3
回答已采纳
我有一个问题，就是如何在创建TCP服务器套接字时在Netty中获得主线程。
在下面从获取的代码中，" Hello“将永远不会写入输出中，因为启动服务器的线程在这一行上等待：f.channel().closeFuture().sync();。在这种情况下，我是否需要创建一个单独的线程来获取主线程，还是在Netty中有任何允许我这样做的方法(在后台运行TCP时获取主线程)？
public void start() throws Exception {
NioEventLoopGroup group = new NioEventLoopGroup();
try {
浏览 3提问于2016-03-21得票数 5
回答已采纳
我想绑定两个服务器套接字(例如。端口8000,8001)在一个Netty应用程序中。
我尝试将DiscardServer和EchoServer示例合并来测试。
但是在第一个服务器初始化代码中，
ChannelFuture f = bootstrap1.bind(port).sync();
f.channel().closeFuture().sync(); // <-- program blocks here
程序执行阻塞，因此第二个服务器初始化代码无法到达。
如何使用Netty4.0启动两个不同的端口服务器？
浏览 2提问于2013-11-07得票数 0
回答已采纳
我正在学习Netty，我开始了一些使用spring引导的教程。我的目标是创建一个应用程序，该应用程序设置用于接收消息的tcp端口，并通过rest呈现它们。
大多数教程都说我应该添加这样的内容
serverChannel = serverBootstrap.bind(tcpPort).sync().channel().closeFuture().sync().channel();
开始上网。当我这样做时，我所实现的其他服务都无法工作。现在，当我使用以下代码片段启动应用程序时：
serverChannel = serverBootstrap.bind(tcpPort).sync().channel
浏览 12提问于2017-01-06得票数 7
回答已采纳
我有一个Netty的服务，是“冲刺”。该服务运行良好，并处理请求/响应。
我不添加单元测试/集成测试。我看到，春季的环境并没有在测试后关闭。也就是说，在测试完成后，netty服务器正在运行。我可以打电话到端口，并看到它仍然连接到它。
这是我的SpringBootApp文件
@SpringBootApplication
public class NettyService {
//Autowired all the required fields
//I made this static so I can access from integration tests to shu
浏览 0提问于2019-04-26得票数 0
回答已采纳
1回答
我有一个netty套接字客户端。从该客户端，我必须首先发送登录和密码，并等待来自服务器的答案，如果它成功，只有当它成功，我可以继续工作。有没有办法以同步的方式运行登录方法？这是我的客户端代码：
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(workerGroup)
.channel(NioSocketChannel.class)
.option(ChannelOption.SO_KEEPALIVE, true)
.handler(new TRSClientInterfaceInitializer());
浏览 2提问于2015-07-07得票数 0
1回答
我正在使用教程学习netty工具，但我遇到了一个问题，我认为它可能与Netty包和JDK的版本有关。现在，我的jdk是1.8，Netty版本是netty 4.0.0 Final.jar，这是我从netty官方网站下载的。
下面是错误代码，，我在错误行后面使用了注释。因为我不知道如何在代码段中突出显示，所以您可能需要仔细注意注释，幸运的是只有两行。
EventLoopGroup pGroup = new NioEventLoopGroup();
EventLoopGroup cGroup = new NioEventLoopGroup();
ServerB
浏览 0提问于2018-09-18得票数 0
我正在努力解决Netty 5.0.0Alpha1的问题。目前，我正在升级我们的一个API，以使用SSL。当我设置示例中所示的所有内容时，服务器将处理一个请求并崩溃。基本上，我能够在firefox上获得不受信任的证书警告，并且服务器在每个后续请求上重置连接。日志里也没有更多有用的信息。我已经将io.netty设置为调试级别。
下面是我的服务器初始化的代码示例：
引导：
String cfgKsLocation = ; // .....
String cfgKsPassword = ; // .....
KeyStore keystore = KeyStore.getInstance("
浏览 3提问于2014-07-24得票数 0
回答已采纳
我正在努力学习如何使用Netty来构建MITM代理。我的目标是让代理在同一个端口上同时处理HTTP和HTTPS。为了简单起见，代理将只对任何入站消息使用hello-world消息进行响应。我做了很多研究，但我仍然很难实现我的目标。
下面是我写的相关代码。
// HTTP/HTTPS proxy service handler
public class InboundFrontHandler extends ByteToMessageDecoder {
private static final HttpResponse CONNECT_RESPONSE = new DefaultHttp
浏览 2提问于2014-10-20得票数 2
回答已采纳
1回答
好吧，我的问题是：
为了学习，我正在构建一个netty 5服务器，但是我遇到了这个问题，它是在绑定问题之后出现的：
因此，当我在中绑定一个端口时，我按照以下代码操作：
bind(port).channel().closeFuture().sync();
现在，该行后面的代码将不会执行，代码如下：
System.out.println("Server bound!");
如何使它在绑定后执行该代码？
浏览 1提问于2015-12-10得票数 0
回答已采纳
我试图使用Java中的Protobuf消息交换格式在普通TCP客户端和Netty之间创建一个TCP套接字连接，但它不起作用。当我使用Netty (而不是TCP客户端)& Netty时，它可以工作。
在Netty 端，在ServerHandler类中，我获得对象"msg“类型为现在，当我试图将它转换为我的自定义Protobuf对象时，它失败了--“java.lang.ClassCastException: io.netty.buffer.PooledUnsafeDirectByteBuf类不能转换为类ProtoModel”。
public class ServerHandler
浏览 11提问于2019-10-21得票数 0
1回答
我使用netty连接到多个服务器，查询一个项，并在我的客户机中聚合结果。下面的代码工作，但我不确定这是否是实现我的目标的最佳方式。而且，我也不确定我该如何结束期货。有人能提供指导吗？我使用的是Netty 4.0.25，using。
public void start() throws InterruptedException
{
EventLoopGroup group = new NioEventLoopGroup();
try
{
ArrayList<ChannelFuture> channelFutures =
浏览 0提问于2015-03-02得票数 4
1回答
我希望实现三方之间的以下沟通：
通信过程为：(1) A向B (2) B发送M1，接收M1后转发C (3) C，接收M1后用M2 (4) B响应，接收M2后转发M2到A (5)，最后A输出M2
我已经实现了使用Netty的所有代码，但目前的问题是:B从C接收到M2后，我试图将M2放到A和B之间的通信通道上，希望A可以直接接收它，但似乎失败了。如果有人能帮忙，请提前感谢，下面是我的代码的基本实现：
A.java向B发送M1，AHandler.java监听B发送的内容：
// A.java
import io.netty.bootstrap.Bootstrap;
import i
浏览 2提问于2020-11-09得票数 1
我正在尝试使用Netty连接到Docker域套接字。这是我目前为止的尝试。
@PostConstruct
public void init() throws Exception {
io.netty.bootstrap.Bootstrap bootstrap = new io.netty.bootstrap.Bootstrap();
bootstrap
.group(new NioEventLoopGroup())
.channel(NioSocketChannel.class)
.option(Chann
浏览 1提问于2019-10-18得票数 2
我对netty很陌生，并且学习了netty的基础，但是当我添加一些内容时。
sendResponseHtml(请求、ctx.channel()、HttpResponseStatus.OK、数组)；
在我被跟踪错误之后。有谁能说出例外的原因吗。我无法处理异常发生的地方。
io.netty.util.concurrent.BlockingOperationException: AbstractChannel$CloseFuture@3b8e2477(incomplete)
at io.netty.util.concurrent.DefaultPromise.checkDeadLock(De
浏览 4提问于2014-07-08得票数 0
回答已采纳
众所周知，当我们编写Netty时，我们通常在finally区域调用bossGroup.shutdownGracefully();。我看到shutdownGracefully()的评论，上面写着：
向该执行器发出信号，表示调用方希望该执行器被关闭。
public final class EchoServer {
static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
public static void main(String[] ar
浏览 0提问于2020-02-11得票数 0
我有一个netty客户端，连接到远程服务器进行请求-响应。我想阻塞，直到远程连接成功，并解析响应。我的处理程序在检索结果方面类似于Netty factorial example。 这是我所拥有的 Channel ch = bootstrap.connect(addr).sync().channel();
ChannelFuture f = ch.writeAndFlush(obj);
//blocking operation
ch.closeFuture().sync();
MyHandler handler = (MyHandler) f.channel().pipeline().last
浏览 31提问于2019-06-01得票数 0
回答已采纳
1回答
我使用Netty服务器来解决这个问题:逐行读取一个大文件并对其进行处理。在单机上做这件事仍然很慢，所以我决定使用服务器为客户端提供大块数据。这已经可以工作了，但我还想让服务器在处理整个文件时自动关闭。我现在使用的源代码是：
public static void main(String[] args) {
new Thread(() -> {
//reading the big file and populating 'dq' - data queue
}).start();
final EventLoopGroup bGrp =
浏览 0提问于2019-08-14得票数 1
我正在尝试将Mina项目转换为使用Netty，但在尝试提出适当的代码来建模时遇到了困难。
在虚拟“会话”期间，我的NioDatagram客户端必须与服务器交换许多身份验证数据包。我正在尝试重用通道，并避免创建和拆除通道的开销。
在我遇到的为数不多的NioDatagram示例中，大多数都是quailfy作为玩具。它们发送一个单独的数据包来做很多事情，比如：
try {
handleRxDatagram(ctx, packet);
} finally {
**ctx.close();**
}
ch.writeAndFlush(new DatagramPacket(bbuf, t
浏览 19提问于2020-05-11得票数 0
我试图使用Netty设置一个简单的UDP服务器，如示例所示，但使用Spring连接依赖项。
我的Spring配置类：
@Configuration
@ComponentScan("com.example.netty")
public class SpringConfig {
@Value("${netty.nThreads}")
private int nThreads;
@Autowired
private MyHandlerA myHandlerA;
@Autowired
private MyHandle
浏览 2提问于2014-05-28得票数 0
在我们的Netty客户机中，有一些我们调用的实例：
channel.closeFuture().sync();
在它完成之后，我们看到更多的数据进入到我们的处理程序中。我们已经编写了一个Http2ConnectionHandler，即使在不久的将来完成之后，它也是接收数据的处理程序。
我的问题是:不久的将来什么时候才能完成更多的工作？
答:是的，关闭未来的火灾，然后管道被拆除，正如诺曼说的。
浏览 0提问于2018-03-09得票数 0
回答已采纳
1回答
我正在用编写Netty教程。
我有下面的服务器代码-
package yt.ingrim.p01;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.epoll.Epoll;
import io.netty.channel.epoll.EpollEventLoopGroup;
import io.netty.channel.epoll.EpollServerSocketChannel;
import io.netty.channel.nio.NioEven
浏览 10提问于2022-09-23得票数 0
回答已采纳
1回答
我在网络上找不到答案。
有人知道如何在netty服务器中获得动态分配的端口信息吗？
以这种方式引导服务器：
override fun startSocket() {
try {
val serverBootstrap = ServerBootstrap()
serverBootstrap.group(group)
serverBootstrap.channel(NioServerSocketChannel::class.java)
if(peerInfo is DynamicPortPeerInfo) {
浏览 0提问于2018-11-02得票数 1
回答已采纳
我正在尝试用Netty编写一个简单的echo服务器。我正在阅读，以了解一些理论并学习Netty的核心基础知识。客户端连接成功，但没有消息从客户端通过。我能够告诉服务器一条信息并接收响应，所以我想问题在客户端，我只是不知道哪里出了问题，因为我是Netty的新手。
这是客户端：
public class Client {
private final String host;
private final int port;
public Client(String host, int port) {
this.host = host;
th
浏览 3提问于2014-09-08得票数 6
回答已采纳
我想在端口9061上创建一个web，并在同一个应用程序中使用其他端口(例如，1066)上的netty启动一个套接字服务器，以便侦听我从其他系统需要的一些信息。我尝试了一些东西，但是我将servlet端口绑定到netty服务器端口，这是我不知道的。
以下是代码：
@Component
public class TCPServer {
@Autowired
@Qualifier("serverBootstrap")
private ServerBootstrap serverBootstrap;
@Autowired
@Qualifier
浏览 1提问于2016-06-28得票数 0
回答已采纳
2回答
我想对一个用Netty构建的套接字服务器进行一些单元测试。
套接字服务器有以下简单代码：
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
imp
浏览 2提问于2015-12-30得票数 1
回答已采纳
2回答
Netty关闭/停止UDP服务器
、、、、
我正在尝试创建Netty UDP侦听器。我面临的问题是我不能像tcp那样停止udp服务器，udp总是在运行，即使调用了stop，停止它的唯一方法就是抛出异常。
private int port;
private UDPViewModel viewModel;
private DefaultEventLoopGroup defaultEventLoopGroup;
public UdpServer(UDPViewModel viewModel, int port) {
this.port = port;
this.viewModel = viewModel;
}
@Overrid
浏览 0提问于2018-10-22得票数 0
1回答
Netty 4多客户端
、、、
我需要使客户端能够进行许多连接。我使用Netty 4.0。不幸的是，所有现有的示例都没有展示如何创建大量连接。
public class TelnetClient {
private Bootstrap b;
public TelnetClient() {
b = new Bootstrap();
}
public void connect(String host, int port) throws Exception {
try {
b.group(new NioEventLoopGroup()).cha
浏览 1提问于2012-10-20得票数 12
回答已采纳
1回答
我使用netty作为套接字客户端：
public void run() {
isRunning = true;
EventLoopGroup group = new NioEventLoopGroup(EventLoopsPerGetter);
Bootstrap b = new Bootstrap();
b.group(group).channel(NioSocketChannel.class)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
浏览 5提问于2016-01-22得票数 2
回答已采纳
Iv进行了一段时间的网络编程，最近将我的一个项目转换为netty。与我最初的程序不同的是，客户端在关闭前会冻结大约3-5秒，这足以让我每次都被迫终止它，因为我不想等待它。这对netty来说正常吗？我做错什么了吗？
主要方法：
public static void main(String[] args) throws Exception {
final SslContext sslCtx = SslContext.newClientContext(InsecureTrustManagerFactory.INSTANCE);
EventLoopGroup group = new
浏览 2提问于2015-03-17得票数 0
回答已采纳
1回答
出于测试目的，我想创建大量到服务器的客户端连接。我通过为每个连接创建线程来实现这一点，因此我只能在我的机器上创建3000个连接。下面是我的代码：
package com.stepnetwork.iot.apsclient.application;
import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.*;
import io.netty.channel.socket.SocketChannel;
浏览 2提问于2016-03-22得票数 1
在这段代码中，shutdownGracefully().syncUninterruptibly()从不返回。这是预期行为还是我误解了什么？使用netty 4.0.35进行了测试
public class ShutdownGracefullyDemo {
private ServerBootstrap bootstrap;
public static void main(String[] args) throws Exception {
new ShutdownGracefullyDemo().initialize();
}
private v
浏览 0提问于2016-04-11得票数 1
我在JAVA中使用Netty包实现了一个非常基本的EchoClient和EchoServer。我对Netty非常陌生。下面是我的客户端、clientHandler、服务器和serverHandler的代码。
我的客户
public class EchoClient {
private final String host;
private final int port;
public EchoClient(String host, int port) {
this.host = host;
this.port = port;
}
浏览 5提问于2017-05-22得票数 0
回答已采纳
如何在Netty中使用带有UDP协议的协议UDP有效载荷？你能给我一个自定义协议的例子吗？关于TCP协议，只有一个例子。
public void bind(int port)引发异常{
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, worke
浏览 2提问于2017-05-02得票数 1
我需要使用Netty创建一个服务器应用程序，它将允许在同一端口上有多个套接字连接。也就是说，我需要能够将多个ServerBootStrap对象绑定到同一个端口。使用Netty可以实现此目的吗？我的代码如下所示：
@Override
public void startServer() {
bossGroup = new NioEventLoopGroup(1);
workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, wor
浏览 8提问于2016-08-29得票数 0
目前，我不知道如何在多个地址/端口上使用netty侦听。我想要构建一个小小的HTTP，它提供一个特殊的应用程序。我需要在几个地址(如IPv4和IPv6)和端口(443 / 80)上运行它。
对于每个侦听器，我希望使用相同的处理程序。我的当前代码如下：
public void run() {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap boo
浏览 10提问于2015-06-20得票数 3
回答已采纳
我一直试图学习Netty并按照教程设置一个简单的服务器客户端连接，但是每当我运行这部分代码时：
public void start() throws Exception{
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(group)
.channel(NioSocketChannel.class)
.remoteAddress(new InetSock
浏览 2提问于2014-10-21得票数 1
回答已采纳
**chatclient.java**
package com.examplechat;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
impo
浏览 1提问于2018-03-08得票数 2
回答已采纳
我有一个使用Netty用Java设计的非常简单的服务器。我还使用Java包编写了一个简单的客户机。我可以将Netty与客户端连接起来，但是当消息发送到服务器时，我将得到以下异常：
My输出：
新客户端连接: sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43) at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) at sun.nio.ch.IOUtil.read(IOUtil.java:192) at sun.nio.ch.SocketChannelImpl.re
浏览 1提问于2017-05-27得票数 0
回答已采纳
1回答
我一直认为异步执行涉及高效的资源利用和线程安全，但今天我遇到了Netty的奇怪行为。
public class Example {
public static void main(String[] args) throws Exception {
EventLoopGroup group = new NioEventLoopGroup();
ServerBootstrap bootstrap = new ServerBootstrap();
try {
bootstrap.group(group)
浏览 0提问于2019-01-10得票数 1
回答已采纳
我正在尝试使用Netty在java中实现TCP服务器。我能够正确地处理长度< 1024的消息，但是当我收到消息超过1024时，我只能看到部分消息。
我做了一些研究，发现我应该实现重放解码器，但我无法理解如何实现解码方法。
我的消息使用JSON
Netty版本4.1.27
protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception
我的服务器设置
EventLoopGroup group;
浏览 1提问于2018-07-26得票数 0
回答已采纳
当我绑定"127.0.0.1“时，它毫无例外地工作，但是当我绑定"172.16.3.138”时，当它运行15秒后，会抛出一个异常：
java.net.SocketException:无法指定请求地址:/172.16.3.138:8888
我在用Netty-4.033在Mac上。
我的服务器代码：
EventLoopGroup masterGroup = null;
EventLoopGroup workGroup = null;
try {
masterGroup = new NioEventLoopGroup();
wo
浏览 1提问于2016-01-13得票数 0
2回答
是否可以将Netty (ServerBootstrap)的响应作为客户端发送到标准Java？
我正努力等待结果，但没有成功。
服务器：
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.group(bossGroup, workerGroup).channel(
浏览 2提问于2014-09-15得票数 1
回答已采纳
3回答
我正在使用Netty v4编写一个TCP服务器。服务器将处理来自客户端的多个连接，并将数据流到客户端。
我希望能够检测出客户端何时以缓慢的速度消耗数据。我基本上是想避免TCP缓冲区，以获得充分，仅仅因为客户端是缓慢的！
这基本上就是ZeroMQ所做的事情(称为“慢用户检测(自杀蜗牛模式)”)。如何使用Netty完成这一任务？
我的当前代码是(我将只显示服务器设置)：
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServer
浏览 5提问于2017-02-08得票数 1
回答已采纳
1回答
所以我最近用netty (5.0.0.Alpha2)做了一些工作，我非常喜欢它！但不幸的是，我无法发送/接收消息。奇怪的是，连接和断开连接就像是一种魔力。服务器接收客户端已连接/断开连接的消息，并添加/删除通道。只是消息不能正常工作。
我确实尝试了很多其他方法(例如，没有编码器)，但从来没有成功过。也许这里的某个人有什么想法？我真的很感激！
提前感谢！您可以在下面找到使用的所有源代码：
CoreClient.java
package me.creepsterlgc.coreclient;
import io.netty.bootstrap.Bootstrap;
import io.netty
浏览 0提问于2015-10-15得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
