Reactor-Netty Как установить длину фрейма сокета - PullRequest
0 голосов
/ 04 мая 2019

Я реализовал клиент WebSocket, используя реактор-нетто, как показано в коде.

HttpClient.create()
        .websocket(65536)
        .uri(baseUri)
        .handle { inbound, _ -> inbound.receive().asString() }
        .doOnNext { log.info { it } }
        .subscribe()

в этом случае, когда клиент получает большое сообщение JSON (большое сообщение, но меньше 65536)

в doOnNext функция получает отдельную строку из исходного сообщения.

я видел лог-сообщение [ctor-http-nio-4] i.n.h.c.h.w.WebSocket08FrameDecoder : Decoding WebSocket Frame length=4082

как установить размер больше 4082 на WebSocket08FrameDecoder размер кадра?

...