java的tcp实时接收json格式报文_tcp - 如何使用带有rsocket Java的TcpClientTransport将自定义数据格式转换为JSON

我有一个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 - 堆栈内存溢出...相关推荐

html显示json数据中某一条的数据,php - 给定一个具有json格式数据的API，我该如何在HTML表中显示数据？ - 堆栈内存溢出...
到目前为止,我有以下PHP cURL代码: $curl = curl_init(); curl_setopt_array($curl, array( CURLOPT_URL => "h ...
java 奖xls转成csv_java - 在Java中将.csv转换为.xls - 堆栈内存溢出
有没有人知道在java中将csv文件转换为xls或xlsx文件的快速,干净的方法? 我有一些东西来管理已经存在的csv文件,我需要其他程序的额外兼容性. 除包名之外的示例代码总是很受欢迎. 非常感谢, ...
java preparedstatement 关闭_java - 如果基础连接已关闭，为什么isClosed（）方法对PreparedStatements不返回true？ - 堆栈内存溢出...
就像标题所说的那样,我想知道为什么准备好的语句.isClosed()方法在关闭基础流(使用JDBC)后将返回false. public void someTest() throws SQLExcept ...
java程序包r不存在_java - 从命令行使用Gradle构建时，“程序包R不存在”错误 - 堆栈内存溢出...
我正在尝试从命令行使用Gradle构建一个Android项目,但是当我想要更改目录结构时发现了一个问题. 目前是这样的: . └── main ├── AndroidManifest.xml ├── ...
flyingsaucer转换多个html,java - 使用FlyingSaucer将包含阿拉伯字符的HTML页面转换为PDF - 堆栈内存溢出...
我想使用FlyingSaucer将包含阿拉伯字符的HTML页面转换为PDF文件,但生成的PDF不包含组合字符并向后打印输出. HTML: جميع الحقوق Java摘录: String inpu ...
java自动生成项目编号_java - Apache POI，在同一文档中创建项目符号点和编号列表 - 堆栈内存溢出...
我试图用apache poi创建一个既包含圆点又包含编号列表的文档. 我想得到这样的结果. 名单: 清单1项目0 清单1项目1 清单1项目2 列表后的段落. 清单2: 清单2项目0 清单2项目1 清单 ...
源服务器未能找到目标资源的表示或者不愿,java - 源服务器没有找到目标资源的当前表示，或者不愿意透露一个存在。关于部署到 tomcat - 堆栈内存溢出...
===============>>#1 票数:12 我已经使用 Spring 和 Eclipse IDE 构建了一个应用程序. 当我从 Eclipse IDE 启动项目时,一切都很好,但是 ...
关于通过webclient和JSON格式报文与服务器之间通讯的解决方法和遇到的难题
关于通过webclient和JSON格式报文与服务器之间通讯的解决方法和遇到的难题参考文章: (1)关于通过webclient和JSON格式报文与服务器之间通讯的解决方法和遇到的难题 (2)http ...
JAVA Socket实现实时接收TCP消息，让你的服务端通信更高效！
本文主要介绍如何利用socket实现实时接收服务端发送的TCP消息. 目录一.需要掌握二.程序源码三.运行演示一.需要掌握网络调试助手下载:https://www.aliyundrive.c ...

java的tcp实时接收json格式报文_tcp - 如何使用带有rsocket Java的TcpClientTransport将自定义数据格式转换为JSON - 堆栈内存溢出...

java的tcp实时接收json格式报文_tcp - 如何使用带有rsocket Java的TcpClientTransport将自定义数据格式转换为JSON - 堆栈内存溢出...相关推荐

最新文章

热门文章