netty

1热度

1回答

中间我有一些数字，包括HTTP请求缓冲区的CompositeByteBuf，我想在HTTP请求行之后注入额外的HTTP报头字段。（我不想使用整个HTTP编码器/解码器的东西，因为我只是代理数据，不需要将它全部解析为HTTP）。我怎样才能做到这一点使用衍生缓冲区，从而避免复制CompositeByteBuf的内容。我使用slice和readSlice所做的每一次尝试都产生了indexoutofb

0热度

1回答

FullHttpRequest到ByteBuff

我想将我的FullHttpRequest对象转换为ByteBuf对象，以避免每次在流水线上写入内容时都使用编码。什么是最好的方式来做到这一点？

0热度

1回答

当我在ChannelHandlerContext上调用close（）时channelInactive（）没有被调用

我们一直在使用netty-handler 4.0.28.Final。我们有一个测试，我们将无效的xml写入测试通道。如下所示，ctx.close（）将被调用，channelInactive会触发。 @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable exc) { if (connectio

0热度

1回答

Netty HttpObjectAggregator与Http2

我正在用Netty 4.1构建一个Http2服务器（并且服务器只需要支持Http2客户端）。对于我最简单的请求处理，我希望在执行任何业务逻辑之前获得完整的Http2请求（即，FullHttpRequest）。我该如何用Http2做到这一点？ Netty的HttpObjectAggregator只能用于Http1。

0热度

1回答

确保只有一个TCP连接使用Netty4Http

我试图使用Netty4Http组件发送大量的HTTPS请求。下面是一个示例代码来测试： import java.util.HashMap; import java.util.Map; import java.util.concurrent.CompletableFuture; import org.apache.camel.CamelContext; import org.apache.

1热度

1回答

c＃客户端连接java netty服务器使用protobuf

服务器出现错误：协议消息标记的线路类型无效。有没有我的C＃代码需要序列化Person对象？配置Maven <dependencies> <dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.12.Final</version>

1热度

1回答

如何对Netty客户端进行编码以连接到Signalr集线器？

我正在尝试创建一个客户端以接收来自第三方信号中心的流式数据。目前，我们使用Netty框架来处理其他一些websocket流，所以如果我能够适应这一点以适应Signalr集线器，那将是一件好事。集线器公开订阅功能以及两个可调用函数。什么是一个Signalr枢纽，如果任何一个正常的Netty的WebSocket客户端和客户端的Netty之间的区别是什么？任何帮助，非常感谢。

-1热度

1回答

骆驼netty4消息1024截断..如何解决它？

我做了一个骆驼netty4服务器程序。客户端发送1119字节的消息，但我的解码器截断1024/95 这里是我的代码。 @ChannelHandler.Sharable public static class BytesDecoder extends MessageToMessageDecoder<ByteBuf> { @Override protected vo

0热度

1回答

在Netty 4.1中，关闭服务器上的通道后，管道中的处理程序何时被删除？

因此，我们正在生产服务器上从Netty 3.9迁移到Netty 4.1。在两个版本中，ChannelHandler在管道中的添加和删除似乎有所不同。特别是，在关闭服务器上的一个通道后，我记录了管道中某个时刻出现的ChannelHandler。在Netty 4.1中，管道有时显示很少或者没有处理程序，在Netty 3.9中，所有处理程序总是存在。所有这些在关闭通道参考后。这是预期的吗？ Netty（

0热度

1回答

如何使用littleproxy/netty缓存流量？

我想用littleproxy缓存静态文件。所以我使用uri的键和响应体的值创建了HashMap。这里的java代码： private static Map<String, FullHttpResponse> cache = new HashMap<>(); private static HttpFiltersSource getHttpFiltersSource() { return