我有一個Tcp數據提供程序，它使用管道定界符發出數據，該定界符需要轉換為JSON，然后存儲在NoSQL數據存儲區中。

我已使用RSocket中的TcpClientTransport協議連接到提供程序，以便以requestStream方式成功連接客戶端，以便僅接收數據包，直到發送最后一個數據包為止。

public class RSocketSample {

public static void main(String[] args) {

final int port = 8282;

final String host = "localhost";

RSocket socket = RSocketFactory.connect()

.frameDecoder(PayloadDecoder.ZERO_COPY)

.transport(TcpClientTransport.create(host, port))

.start()

.block();

System.out.printf("Tcp Client initialized, connecting to port %d%n", port);

socket.requestStream(DefaultPayload.create("request-stream-message"))

.map(Payload::getData)

.map(ByteBuffer::asReadOnlyBuffer)

.doOnNext(System.out::println)

//.take(10)

.doFinally(signalType -> socket.dispose())

//.then()

// Block until all the bytes are received

.blockLast();

}

}

我希望它連接到提供程序，將自定義格式轉換為JSON。 我已經嘗試打印出接收到的數據，但是沒有看到任何顯示。 任何幫助都感激不盡！！！

總結

以上是生活随笔為你收集整理的java的tcp实时接收json格式报文_tcp - 如何使用带有rsocket Java的TcpClientTransport将自定义数据格式转换为JSON - 堆栈内存溢出...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。