netty相关内容

Netty HTTPProxyHandler 总是发送一个 CONNECT

HTTPProxyHandler 总是发送 CONNECT 请求是对的吗?这不是只适用于你想要做隧道的时候吗? 解决方案 HTTPProxyHandler 不知道你是只想对 http 数据进行隧道传输,还是想在连接的瞬间发起 http 请求,因此,它猜测在这两种情况下都适用的选项,因为标准补充 HTTP 代理支持 CONNECT 和旧的 http 代理方法调用.如果您需要使用 GET 和其 ..
发布时间:2021-06-07 19:24:41 其他开发

在 Netty 客户端处理来自服务器的响应

我正在使用 Netty 编写 JavaFX 应用程序来实现自定义协议.没有会话状态,但我想将服务器响应与特定的出站请求相关联(并将结果返回到正确的 JavaFX Task.)到目前为止我还没有能够这样做客户端代码,因为 responseFuture 是一个 ChannelFuture. future = tcpBoostrap.connect(address, 3333).sync();最终通道 ..
发布时间:2021-06-07 19:24:38 Java开发

如果Netty channel isWritable return false,数据会排到哪里

从 Netty api,它显示如果 isWritable 返回 false,请求将排队.我能知道请求在哪里排队吗?在什么情况下,队列可能已满并导致 OOM 问题? 以下是isWritable()的文档 当且仅当 I/O 线程将立即执行请求的写操作时返回真.此方法返回 false 时发出的任何写入请求都会排队,直到 I/O 线程准备好处理排队的写入请求. https://netty ..
发布时间:2021-06-07 19:24:31 Java开发

Netty 4:将 ByteBuf 写为 HTTP 块

Netty 4.1.2.Final 这是我的管道: pipeline.addLast(new HttpServerCodec());pipeline.addLast(new HttpObjectAggregator(65536));pipeline.addLast(new ChunkedWriteHandler());pipeline.addLast(new HttpInboundHand ..
发布时间:2021-06-07 19:24:27 其他开发

泄漏: ByteBuf.release() 没有被调用 - 我们如何解决这个问题?

我们有一个基于 netty 的网络流量密集型 Java 应用程序/服务器. 附注:我主要支持这个应用程序,我没有构建它所以我不完全了解它. 我们有时会收到如下所示的错误. 以前我们曾经在服务器启动 3-4 天后收到此错误.现在我注意到即使在重新启动服务器/应用程序 10-15 分钟后我们也会收到此错误. 我不明白这怎么可能.这个错误是否令人担忧,我们该如何解决?我记得过去对 ..
发布时间:2021-06-07 19:24:20 Java开发

netty.io 客户端不发送请求正文

我有以下简单的代码.它一直工作到三月,但现在突然间我发现它不起作用了到达服务器端的请求没有任何正文......从客户端代码我可以看到,即使是简单的文本也不会......我在我的应用程序中使用 netty.io -all 4.0.10 jar,我的客户端代码如下: 请帮忙 public class HttpClient {私有最终 URI uri;私有最终字符串ip;私有最终 int 端口; ..
发布时间:2021-06-07 19:24:13 其他开发

Netty 4.0 多端口不同协议每个端口

我想 netty 是我所知道的最好的 Java 网络框架,在阅读并尝试了一些示例后,我有疑问: 1.使用 netty 4.0 为不同协议的多端口创建网络服务器的最佳方法是什么? 每个服务器创建: EventLoopGroup bossGroup = new NioEventLoopGroup();//(1) EventLoopGroup workerGroup = new ..
发布时间:2021-06-07 19:24:10 其他开发

Netty 可以自动处理请求的排队吗?

在 Apache PLC4X 项目 (https://plc4x.apache.org) 中,我们正在为使用 Netty 的工业 PLC.这里通常将各种协议分层.有时一层要求我们将一条消息拆分为底层的多条消息.现在我们面临一个大问题:一个协议协商每个连接的最大数量的未确认消息.所以我们不能发送超过这个最大值的消息,否则接收者只会发送一个错误响应. 现在我们不需要在 encode 方法中将东西 ..
发布时间:2021-06-07 19:24:08 其他开发

CompositeByteBuf 的 readableBytes 返回 0

以下代码有什么问题?它总是为 readableBytes 打印 0,即使 CompositeByteBuf 中有明确的数据. private void CompositeTest() {ByteBuf buf1 = Unpooled.buffer(1024);buf1.writeBytes("hello".getBytes(StandardCharsets.UTF_8));ByteBuf bu ..
发布时间:2021-06-07 19:24:02 其他开发

Netty:ClientBootstrap 连接重试

我需要连接到一个服务器,我知道它会监听一个端口.尽管可能需要一些时间才能投入使用.是否可以让 ClientBootstrap 尝试连接给定的尝试次数或直到达到超时? 目前,如果连接被拒绝,我会收到一个异常,但它应该尝试在后台连接,例如通过尊重“connectTimeoutMillis"引导选项. 解决方案 你需要手动完成,但这并不难.. 你可以这样做: final Clien ..
发布时间:2021-06-07 19:23:57 Java开发

动态改变 netty 管道

我正在使用 netty 4.0.25Final 编写一个 netty HTTP 服务器.我需要根据 HTTP GET 请求中的一些参数在管道中添加各种处理程序. pipeline.addLast(new HttpRequestDecoder(4096, 8192, 8192, false),新的 HttpResponseEncoder(),新的 HttpObjectAggregator(1048 ..
发布时间:2021-06-07 19:23:51 其他开发

使用 TLS 1.2 将客户端连接到 TCP 服务器

我正在尝试将设备连接到 .Net (4.5.2) 服务器,但没有成功.这是设备打开的 TCP 连接,使用 TLS 1.2. 在服务器端,我有一个 TCP 服务器的标准 .Net 实现:SslStream 包裹在 DotNetty 我无法更改设备上的任何内容 任何 .Net 客户端都可以使用安全的 TLS 连接成功连接到我的服务器.尝试使用 CURL 时它也能正常工作,所以我得出结论我 ..
发布时间:2021-06-07 19:23:45 C#/.NET

为什么在 Netty 中引入了原生 epoll 支持?

我相信 Java 的 NIO 库会在 Linux 机器上使用 epoll.在 Linux 机器上使用 Epoll 代替 NIO 有哪些优点. 解决方案 Netty 的 epoll 传输使用 epoll 边缘触发,而 java 的 nio 库使用级别触发.除此之外,epoll 传输公开了 java 的 nio 不存在的配置选项,如 TCP_CORK、SO_REUSEPORT 等. ..
发布时间:2021-06-07 19:23:36 其他开发

在netty中重用bytebuf

我有一个 Netty 的 http 服务.对于一组请求,http 正文中只有“{}"有相同的回复.我有一个想法,以避免为每个这样的请求等创建新的缓冲区,所以我刚刚使用了: private static final ByteBuf EMPTY_REPLY = Unpooled.copiedBuffer("{}", CharsetUtil.UTF_8); 在我的 SimpleChannelInbo ..
发布时间:2021-06-07 19:23:33 其他开发

AMQ214013:无法解码数据包:java.lang.IllegalArgumentException:AMQ119032:无效类型:1

我在 widlfly 上的 activeMQ 工作正常,而且从星期一开始我这周开始出现这个异常并且非常频繁. 起初我进入堆栈跟踪并通过代码 grep 查看代码,该代码抛出此异常,在我看来,问题可能与消息的大小有关.我停止了在队列中输入消息的过程.并打开了我的野蝇.队列中没有数据,但我仍然收到此异常. 我从数据目录中删除了 activeMQ 数据目录和 tx-object-store.我 ..
发布时间:2021-06-07 19:23:30 其他开发