RSocket 错误 0x201 (APPLICATION_ERROR): readerIndex(1) + length(102) 超过 writerIndex(8): UnpooledSlicedByteBu

Question

 setInterval(() => {
        let that = this;
        this.socket && this.socket.requestResponse({
            data: '' + (++index),
            metadata: 'org.mvnsearch.account.AccountService.findById',
        }).subscribe({
            onComplete(payload) {
                let account = JSON.parse(payload.data);
                that.setState({
                    nick: account.nick
                })
            },
            onError: (e) => {
                console.log('onError', e)
            }
        });
    }, 2000)

正在尝试使用 reactjs 连接到 spring rsocket。在下面显示的 javascript 代码中订阅之前出现错误。

**this.socket.requestResponse({
                data: '' + (++index),
                metadata: 'org.mvnsearch.account.AccountService.findById',
            })**

如何解决上述问题？

Answer 1

如果您在后端使用 rsocket 路由，它是长度前缀。参见 https://github.com/rsocket/rsocket-demo/blob/master/src/main/js/app.js#L22-L36

  // Create an instance of a client
  const client = new RSocketClient({
    setup: {
      keepAlive: 60000,
      lifetime: 180000,
      dataMimeType: 'application/json',
      metadataMimeType: 'message/x.rsocket.routing.v0',
    },
    transport: new RSocketWebSocketClient({url: url}),
  });

  const stream = Flowable.just({
    data: '{"join": {"name": "Web"}}',
    metadata: String.fromCharCode('chat/web'.length) + 'chat/web',
  });

路由规范允许多条路由，因此不幸的是单个路由的编码因此变得复杂。 https://github.com/rsocket/rsocket/blob/master/Extensions/Routing.md

RSocket 错误 0x201 (APPLICATION_ERROR): readerIndex(1) + length(102) 超过 writerIndex(8): UnpooledSlicedByteBu

RSocket error 0x201 (APPLICATION_ERROR): readerIndex(1) + length(102) exceeds writerIndex(8): UnpooledSlicedByteBu

spring

websocket

reactjs

rsocket