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