无法在服务器端读取 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