netty相关内容

为什么Netty http2服务器始终对streamId使用奇数

我正在使用Netty设置简单的http/2服务器.我正在使用此例如http://服务器. 要测试此服务器,我使用的是netty示例我向服务器发送请求的客户端代码: 完整代码: http://netty.io /5.0/xref/io/netty/example/http2/client/package-summary.html HttpResponseHandler resp ..
发布时间:2020-05-17 03:10:18 其他开发

净值channelActive与channelRead0

我正在使用netty 4.0.33来构建SSL/TLS客户端/服务器.对于每个连接,我想记录一条消息,表明2个对等方之间TLS连接成功. 该代码段应该放在哪里? channelActive或channelRead0?我对channelActive和channelRead0的用途有点困惑.看起来在服务器端,我们根本不需要channelActive.是真的吗? 解决方案 如果您想在握手成功后做 ..
发布时间:2020-05-17 03:10:10 其他开发

如何从netty中的HTTP服务器请求处理程序正确调用HTTP客户端?

我正在使用netty 3.3.1开发自定义HTTP服务器. 我需要实现类似这样的东西 HTTP Server收到请求 HTTP Server对其进行解析并作为其他计算机的客户端调用HTTP请求 HTTP Server等待(2)中发送的请求的响应 HTTP服务器根据(3)中收到的内容发送对(1)的请求的响应 这意味着客户端请求(2)必须表现为同步. 我写的内容基于 Ht ..
发布时间:2020-05-17 03:10:00 其他开发

如何配置Netty 4 HTTP/2客户端以获取单个框架

我正在编写一个基于Netty的HTTP/2服务,该服务执行“服务器发送的事件"(SSE),并且我需要编写一个HTTP/2测试客户端类以用于集成测试,但是我很难工作了解如何设置客户端管道,以便可以从服务器获取单个事件. 我首先尝试使用HTTP/1.1↔HTTP/2适配器类(InboundHttp2ToHttpAdapter + HttpToHttp2ConnectionHandler),但是使 ..
发布时间:2020-05-17 03:09:52 Java开发

如何限制Netty用于客户端连接的线程

有没有一种方法可以限制netty用于客户端连接的线程数(Netty是连接到远程服务器的客户端).我正在使用1个NioEventLoopGroup,它被传递到每个Bootstrap中.每个引导程序都获得相同的ChannelInitializer引用(我曾经为每个引导程序创建不同的初始化程序,但似乎可以很好地共享相同的引用).我已从Java应用程序连接到许多充当服务器的硬件设备. 我注意到,目前 ..
发布时间:2020-05-17 03:09:48 Java开发

当缓冲区大小小于帧大小时,LengthFieldBasedFrameDecoder无法正确解析

我正在使用基于帧的解码器对Netty管道进行单元测试.如果我使用的缓冲区大小小于最大帧的大小,则看起来帧是不正确的.我正在测试包含两个消息的文件.长度字段是第二个作品,包括整个消息的长度,包括长度字段和它之前的作品. new LengthFieldBasedFrameDecoder(65536, 4, 4, -8, 0) 我正在读取具有各种块大小的文件.第一条消息的大小为348个字节, ..
发布时间:2020-05-17 03:09:40 Java开发

意外的消息类型:HttpClientCodec管道上的DefaultHttpRequest

频道上的第二个.write导致异常 "io.netty.handler.codec.CodecException:java.lang.IllegalStateException:意外消息类型:DefaultHttpRequest". 抓挠我的脑袋应该做些不同的事情,因为管道上只有HttpClientCodec.通过从 Github 克隆并运行main(运行客户端和服务器端)来重现错误. ..
发布时间:2020-05-17 03:09:29 其他开发

Netty 4. ByteToMessageCodec之后的并行处理

如果将NioEventLoopGroup用作workerGroup,则通过跟随NioEventLoop中的处理程序,以连续(单线程)的方式处理ByteToMessageDecoder处理程序(用于单个连接)之后的消息. 是否可以使它们由ByteToMessageDecoder处理程序之后的其他“工人"处理? 解决方案 是的,只需将带有特殊EventExecutorGroup的Chan ..
发布时间:2020-05-17 03:09:25 其他开发

Jboss Netty-如何使用3个工作线程处理2个连接

仅举一个简单的例子,我想只使用netty中的2个工作线程来处理3个同时的TCP客户端连接,我该怎么做? 问题 一种) 使用下面的代码,我的第三个连接没有从服务器获取任何数据-该连接只是位于那里.注意-我的工人遗嘱执行人和工人人数是2. 因此,如果我有2个工作线程和3个连接,那么这2个线程是否应该为这3个连接提供服务? B) 另一个问题是-Netty是否使用java.util.concu ..
发布时间:2020-05-17 03:09:21 Java开发

限制每个IP在Netty上的连接数

我一直在寻找一种使用NetFilter的IPFilter类来限制Netty上每个IP连接的方法.但是,没有JavaDoc解释可以做到这种限制. 我发现的唯一方法是使用两年前在jboss上发布的'ConnectionPerIPLimitUpStreamHandler',但是Norman Maurer表示不再需要该功能,因为该功能已添加到IPFilter类中. 因此,在简历中,我需要说明如 ..
发布时间:2020-05-17 03:09:17 Java开发

在负载下观察到Netty 3.2.7和3.3.1的ClosedChannelException异常

未加载我的Netty服务器时,一切正常. 但是在负载下它开始失败. 目前,我正在使用所有默认设置(尚未设置任何选项).请建议我是否需要设置任何选项来处理2k +并发连接(可能在加载期间频繁关闭和打开) 这里是netty 3.2.7的堆栈跟踪.我已升级到netty 3.3.1,但仍然失败. 2012-09-19 16:17:54,864新的I/O服务器工作人员#1-11调试 org.jb ..
发布时间:2020-05-17 03:09:15 Java开发

播放框架[2.5.0 Java]-导致netty-event-loop线程阻塞,导致超时

我们刚刚从Play框架2.4.3升级到2.5.0(java).但是,升级后,我们的测试会在几分钟后开始超时.在升级之前,它们运行了一个小时而没有错误. 似乎某些线程被阻塞,系统只是停止响应. 我正在使用Yourkit java profiler在我的计算机上本地运行较小版本的负载测试.最初,有16个netty-event-loop线程启动.大约一分钟后,我可以看到它们已开始阻止: ..
发布时间:2020-05-17 03:09:11 Java开发

如何通过Jetty而不是Netty使用Spring WebClient?

根据文档,可以将Spring Reactive WebClient与其他服务器(如Netty)一起使用: WebClient通过HTTP客户端库提供了更高级别的API.经过 默认情况下,它使用Reactor Netty,但是可以用其他插件插入 ClientHttpConnector. 但是,我无法找到一种方法来做到这一点.如果我像这样简单地将依赖从Netty更改为Jetty: c ..
发布时间:2020-05-17 03:09:04 其他开发

如何使用netty通过HTTP流式传输响应

我正在使用Netty 3.6.6,我想将较大的响应发送回给呼叫者.我无法将响应主体复制到ChannelBuffer中,因为在某些情况下,响应主体会很大. 我要将服务器从CXF迁移到Netty,以前,我只能使用CXF提供的OutputStream写入数据. 我最初试图只发送不带内容的响应,然后继续在一系列8k缓冲区中将数据写入Channel.这失败了,因为客户似乎得到了原始答复,没有看到 ..
发布时间:2020-05-17 03:09:00 其他开发

使用netty高速发送消息时获得OOM异常

我用netty编写了一个客户端,以便以高速率发送消息. 通过jConsole,我看到“老一代"正在增加,最后它抛出了 java.lang.OutOfMemoryError:超出了GC开销限制. 是否有一些方法或配置可以避免这种异常 以下是我的测试代码: import io.netty.bootstrap.Bootstrap; import io.netty.channel.C ..
发布时间:2020-05-17 03:08:58 Java开发

网络连接限制

我正在开发使用Netty 3.6.5的应用程序服务器.我想首先了解选项积压的全部含义.另外,为什么没有关于serverbootstrap选项的文档来帮助我们的开发人员. 我的另一个问题是,如何最好地限制与服务器的并发连接数以提高性能. 谢谢. 解决方案 要限制与服务器的并发连接数(在UNIX系统上),可以在运行应用程序之前在文件描述符上设置ulimit,并且在所有应用程序上都可 ..
发布时间:2020-05-17 03:08:54 Java开发