netty

    0熱度

    1回答

    在我調用ChannelWriter.wite()方法發送消息之後,它返回給我一個ChannelFuture。如果另一端的接收端已禁用epoll_wait讀取,我認爲套接字寫入應該是部分完成的,因爲應該寫入零字節。我想過使用返回的ChannelFuture,但isSuccess()返回true。 如何知道ChannelWriter.write()是僅部分完成還是寫入零字節?

    2熱度

    1回答

    我正在爲一個能夠傳輸文件和結構化消息的協議寫一個netty管道。文件傳輸是通過一個結構化的消息(握手)開始的,然後是一個代表該文件的字節流。 傳入文件的確切消息流看起來像這樣(服務器是我的網狀實現,客戶其他軟件): +---------+ +---------+ | Client | | Server | +---------+

    1熱度

    1回答

    我正在使用Netty來設置一個簡單的http/2服務器。我使用this作爲http/2服務器的例子。 要測試此服務器,我使用netty示例client。在那裏,我將請求發送到服務器 我的客戶端代碼: 完整代碼:http://netty.io/5.0/xref/io/netty/example/http2/client/package-summary.html HttpResponseHandler

    0熱度

    1回答

    我用grpc爲webcam-stream創建了一個微服務。流媒體工作正常,但流的取消僅在客戶端工作。 如果客戶端調用CancellableContext.cancel,則視頻流將停止,但服務器仍在使用該視頻流播放視頻。如果取消被調用,則服務器拋出Transport faild異常。 這個異常可以抓住停止在服務器端的流或其他操作嗎? ClientCall<KameraStreamRequest, K

    2熱度

    1回答

    我正在使用基於幀的解碼器測試netty管道。如果我使用比最大幀小的緩衝區大小,它看起來像框架是不正確的。我正在測試包含兩條消息的文件。長度字段是第二件作品,包括整個消息的長度,包括長度字段和之前的作品。 new LengthFieldBasedFrameDecoder(65536, 4, 4, -8, 0) 我正在讀取具有各種塊大小的文件。第一條消息的大小是348字節,第二條是456字節。如果

    0熱度

    1回答

    我使用ChannelInboundHandlerAdapter類和writeAndFlush來自channelRead()的每條消息; public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ByteBuf msgBuffer = (ByteBuf)msg; Binary

    0熱度

    1回答

    在類EpollDatagramChannelConfig,有4個方法是這樣的: @Override public EpollDatagramChannelConfig setTimeToLive(int ttl) { throw new UnsupportedOperationException("Multicast not supported"); } 它們是: setLoop

    0熱度

    1回答

    產生的原因:了java.lang.RuntimeException: java.io.NotSerializableException: io.netty.channel。 DefaultChannelHandlerContext在 org.apache.storm.serialization.SerializableSerializer.write(SerializableSerializer.

    2熱度

    1回答

    我需要驗證一些用戶請求,所以我試圖使用LittleProxy。這個想法是讓它對用戶透明(iptables> littleproxy>原始服務器)。 所以我使用iptables重定向流量LittleProxy(即監聽127.0.0.1:3127)如下: iptables -t nat -A OUTPUT -p tcp -o eth0 --dport 80 -j DNAT --to 127.0.0.1

    0熱度

    1回答

    我已經構建了一個WebSocket客戶端,以保持向echo服務器發送相同的消息並計算接收到的字節數。斷絕返回類似消息: WebSocketData [接收的消息] 但是,當我檢查由LoggingHandler打印日誌,所接收的消息由回聲服務器棒一起發送。所以當我在LoggingHandler之前放置一個BytesCountingHandler時,單個消息的計數結果比平常大。 我想問:我做錯了嗎?