Java RSocket客户端与Spring RSocket通道连接
我有简单的Spring启动RSocket服务
@MessageMapping("msend")
public Flux<String> msend(String message) {
log.info("msend channel publish " + message);
return Flux.just(message, " "+System.currentTimeMillis());
}
连接2个Spring服务很容易，但我的客户端应用程序没有Spring，我的客户端应该在RSocket java中
我很难理解如何将（路由，如Spring RocketRequest ester）消息发送到该特定通道。
客户端代码应为：
Mono<RSocket> rsocket = RSocketConnector.create()
.metadataMimeType(WellKnownMimeType.MESSAGE_RSOCKET_COMPOSITE_METADATA.getString())
.connect(TcpClientTransport.create(2050));
///real path "http://gateway:2022/producer/toProducerRsocket", 2050)
///toProducerRsocket redirect to producer/rsocket
有可能订阅Spring频道吗？
共有1个答案
这对于定义元数据类型看起来是正确的。但是您需要为请求流设置它。通道在这里听起来不正确，因为您只有一个输入值消息。
https://stackoverflow.com/a/62776146/1542667
CompositeByteBuf metadata = ByteBufAllocator.DEFAULT.compositeBuffer();
RoutingMetadata routingMetadata = TaggingMetadataCodec.createRoutingMetadata(ByteBufAllocator.DEFAULT, List.of("/route"));
CompositeMetadataCodec.encodeAndAddMetadata(metadata,
ByteBufAllocator.DEFAULT,
WellKnownMimeType.MESSAGE_RSOCKET_ROUTING,
routingMetadata.getContent());
-
谁能让我知道如何传递这个参数，使用java。 根据我的理解，不是证书的一部分。
-
我用的是Netty 3.9 我有一个客户场景，我必须按照这个顺序进行操作 连接 发送1条消息 接收1消息 断开连接 由于连接和断开连接是一项成本高昂的操作，我希望尽可能多地重用Netty级别的对象。 所以我做以下事情 上面的代码生成了java.nio.channels。ClosedChannel异常，可能是因为套接字已关闭。但是Netty中没有api，我可以使用它断开与服务器的连接，并且仍然保留套
-
问题内容： 我在生产中看到很多连接重置，可能有多种原因，但我想确保代码中没有连接泄漏。我在代码中使用Jersey客户端 最初，我以以下方式实例化客户端Client this.client = Client.create（），我们将其更改为ApacheHttpClient.create（）。我没有在响应上调用close（），但是我假设ApacheHttpClient将在内部执行该操作，因为HttpC
-
我有一个这样描述的任务： 实现调用按钮： 当点击通话图标时，first Twilio会拨打电话号码#1（管理员） 这时我想出了如何通过浏览器拨打电话号码（比如管理员可以在浏览器中拨打提供商的电话）。 但是我找不到任何信息，如何通过Twilio相应地连接人们的任务。有什么方法可以实现这个解决方案吗？
-
在Netty中创建客户端连接时，我有一个问题。 这里，为什么我们没有一个bind方法，将通道绑定到发起客户端连接的端口（在客户端）？我们唯一需要提供的就是给出服务器地址和端口如下： 这是在客户端还是服务器端创建了一个新的通道？此通道绑定在客户端的哪个端口？ 我们在执行服务器端引导时进行绑定，如下所示 我很困惑，不明白客户端从哪个端口向服务器发送数据，使用的是什么通道？
-
我正在Druid服务器上处理数据的获取和查询。但是，当我查询时，我只使用以下命令行： 有谁能告诉我如何利用Java客户端和ApacheHttpClient将该查询发送到Druid服务器以获得响应。非常感谢。