第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機(jī)立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

如何用 JavaScript 編寫 RSocket 客戶端

如何用 JavaScript 編寫 RSocket 客戶端

慕田峪9158850 2021-10-21 13:52:14
我嘗試在 Java 中實現(xiàn) RSocket 服務(wù)器,在 JavaScript 中實現(xiàn)客戶端,但我無法在后端調(diào)用任何方法。Java服務(wù)器public final class RawServer {    public static void main(String[] args) {        RSocketFactory.receive()                .acceptor((setup, sendingSocket) -> Mono.just(new DefaultSimpleService()))                .transport(WebsocketServerTransport.create("localhost", 8801))                .start()                .block()                .onClose()                .block();    }    private static final class DefaultSimpleService extends AbstractRSocket {        private ObjectMapper jsonMapper = new ObjectMapper();        @Override        public Flux<Payload> requestStream(Payload payload) {            return Mono.just(payload.getDataUtf8())                    .map(json -> {                        try {                            return jsonMapper.readValue(json, Message.class);                        } catch (IOException e) {                            e.printStackTrace();                            return null;                        }                    })                    .doOnNext(msg -> System.out.println("got message " + msg.message))                    .flatMapMany(msg -> Flux.range(0, 5)                            .map(count -> msg.message + " #" + count))                    .map(message -> DefaultPayload.create(message));        }    }}public class Message {    public final String message;    @JsonCreator    public Message(@JsonProperty("message") String message) {        this.message = message;    }}JavaScript 客戶端    import { RSocketClient, JsonSerializers } from "rsocket-core";    import RSocketWebSocketClient from "rsocket-websocket-client";    const transport = new RSocketWebSocketClient({        url: "ws://localhost:8801"      });好像建立了 WebSocket 連接,但沒有消息推送到服務(wù)器。我怎樣才能做到這一點?我還用 Java 實現(xiàn)了客戶端,它工作正常。我找到的 JavaScript 示例是https://github.com/rsocket/rsocket-js/blob/master/docs/01-client-configuration.md,但我無法使其工作。
查看完整描述

1 回答

  • 1 回答
  • 0 關(guān)注
  • 295 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號