如何解决无法在服务器端读取 requestResponse 调用的负载
考虑以下 TS 客户端代码片段:
this.rSocketClient.connect().subscribe({
onComplete: socket => {
const endpoint = ‚accesscode’;
socket.requestResponse({
data: clientId,//the clientId is a non-empty string
metadata: String.fromCharCode(endpoint.length) + endpoint
}).subscribe({
onComplete: () => console.log(’Done’),onError: error => {
console.log('Connection has been closed due to:: ' + error);
},});
},onError: error => console.error(error),onSubscribe: cancel => {}
});
我想知道我的服务器 accesscode
端点的签名应该是什么样子。事实上,我尝试了以下解决方案,但没有按预期锻炼。事实上,当我在 getAccessCode
中放置断点时,调用会被捕获但 clientId
无法解析:
@MessageMapping("accesscode")
public Mono<String> getAccessCode(@Payload String clientId) {
log.info("requested clientId:"+clientId);
//Server side processing to read the corresponding 'accesscode' from the DB
return Mono.just(DefaultPayload.create(accesscode));
}
任何帮助将不胜感激。
解决方法
您的客户端需要发送 spring-boot 做出决定的路由信息。见https://domenicosibilio.medium.com/rsocket-with-spring-boot-js-zero-to-hero-ef63128f973d
具体看设置客户端时的mime类型,以及应该匹配你的代码的@MessageMapping的路由。
// Create an instance of a client
client = new RSocketClient({
serializers: {
data: JsonSerializer,metadata: IdentitySerializer
},setup: {
// ms btw sending keepalive to server
keepAlive: 60000,// ms timeout if no keepalive response
lifetime: 180000,// format of `data`
dataMimeType: 'application/json',// format of `metadata`
metadataMimeType: 'message/x.rsocket.routing.v0',},transport: new RSocketWebSocketClient({
url: 'ws://localhost:8080/tweetsocket'
}),});
// Open the connection
client.connect().subscribe({
onComplete: socket => {
// socket provides the rsocket interactions fire/forget,request/response,// request/stream,etc as well as methods to close the socket.
socket.requestStream({
data: {
'author': document.getElementById("author-filter").value
},metadata: String.fromCharCode('tweets.by.author'.length) + 'tweets.by.author',}).subscribe({
onComplete: () => console.log('complete'),onError: error => {
console.log(error);
addErrorMessage("Connection has been closed due to ",error);
},onNext: payload => {
console.log(payload.data);
addMessage(payload.data);
},onSubscribe: subscription => {
subscription.request(2147483647);
},});
},onError: error => {
console.log(error);
addErrorMessage("Connection has been refused due to ",error);
},onSubscribe: cancel => {
/* call cancel() to abort */
}
});
,
Spring 中的 rsocket 就像 API 作为 Web Socket (https://rsocket.io/),它提供 API 类型(通过 TCP)供客户端应用程序使用。因此,端点是您调用以获取某些数据资源的某个 URI。所以,它是一个像这样的 URI:ws://localhost:8080/WebsocketTest/testserver 或者 yourtag://url:portnumber/resource 或者它甚至可以是localhost 如果你在本地测试。
理想情况下使用 clientId 调用端点。这取决于您的 rsocket 设计。另外,你想在这里做什么?您想通过 rsocket 提供什么服务?
您可以在此处找到有关该主题的专家:https://gitter.im/rsocket/rsocket-java
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。