1

每个人。

问题 1

我尝试使用 Rsocket。Rsocket服务器如何向客户端发送消息？与 websocket 一样，服务器可以向一个客户端或所有客户端发送消息。我找不到办法。也许我可以使用频道？但我不知道该怎么办。

问题2

我像这样使用频道：

  @MessageMapping("channel")
  fun channel(settings: Flux<Duration>) =
      settings
          .doOnNext { setting: Duration -> println("Frequency setting is ${setting.seconds} second(s).") }
          .switchMap { setting: Duration ->
            Flux.interval(setting).map { index: Long -> Message("Server", "Channel", index) }
          }
          .log()

在 js 中，我这样做：

const {
  RSocketClient
} = require('rsocket-core');
const RSocketTcpClient = require('rsocket-tcp-client').default;
const {Flowable} = require('rsocket-flowable')

const tcpClient = new RSocketTcpClient((host, port))

const client = new RSocketClient({
  setup: {
    keepAlive,
    lifetime,
    dataMimeType: "application/json",
    metadataMimeType: 'message/x.rsocket.routing.v0'
  },
  transport: tcpClient,
});

const flowablePayload = new Flowable(subscriber => {
  subscriber.onSubscribe({
    cancel: () => {},
    request: n => {
      for (let index = 0; index < n; index++) {
        const message = {
          message: "requestChannel from JavaScript! #" + index
        };
        subscriber.onNext(message);
      }
      subscriber.onComplete();
    }
  });
});    

client.connect().subscribe({
  onComplete: socket => {
    console.log('onComplete')
    socket.requestChannel({
      data: flowablePayload,
      metadata: String.fromCharCode('channel'.length) + 'channel'
    }).subscribe({
      onComplete: res => console.log(res),
      onError: err => console.error(err)，
      onSubscribe: cancel => console.log('success')
    });
  },
  onError: error => {
    console.log("got error");
    console.error(error);
  },
  onSubscribe: cancel => {
    console.log("subscribe!");
  }
})

输出：

subscribe!
onComplete
success

但是我无法获取MessageMapping频道信息并且channel方法未执行。

我该怎么办？</p>

谢谢！！！

4

1 回答 1

0

问题1：如果您想知道如何向某个客户端发送消息，请参阅这个 StackOverflow 问题Send message only to certain client using websockets with Rsocket and Spring Webflux

问题 2：我从未尝试过使用这些渠道，但我不确定您是否真的需要它。例如，我会在一个在线游戏中使用该通道，其中用户不断按下键，服务器必须响应它们。

于 2020-04-27T06:12:51.417 回答