все! У меня возникла идея использовать реализацию генерации кода протобаффа gRPC в качестве API уровня данных, чтобы использовать его вместо POJO в протоколе RSocket. Вот реализация: syntax = "proto3"; import...

Я получаю сообщение об ошибке 0000 Error {000}: [00000003] Invalid mime type "binary": does not contain '/' var client = new RSocketClient(new WebSocketTransport("ws://127.0.0.1:7000/quotes"), new RSocketOptions() {...

Как мы можем использовать @AuthenticationPrincipal с методом RSocket @AuthenticationPrincipal Mono token public Mono<String> uppercase(String s, @AuthenticationPrincipal Mono<JwtAuthenticationToken> token) { //Token is...

Я понимаю, что соединение RSocket двунаправленное. Как долго клиент может быть подключен к серверу через RSocket, прежде чем соединение будет разорвано? И если соединение действительно разрывается, как оно восстанавливается, если сервер хочет...

У меня есть несколько микросервисов, которые должны работать поверх фреймворка WebFlux. У каждого сервера есть собственный API с Mono или Flux. Мы используем MongoDB, который поддерживается Spring (Spring Data MongoDb Reactive). Проблема...

Я написал небольшую демонстрацию сообщения RSocket Проблема в том, что я не могу получить доступ к конечной точке Rsocket , я получаю следующее исключение от сервера: На стороне клиента: конфигурация: @Bean RSocket rSocket() { return...

Как настроить метаданные маршрутизации (в полезной нагрузке с использованием только RSocket-Java, когда сервер использует Spring Boot Rsocket. Flux<Payload> s = connection.flatMapMany(requester ->...

У меня есть клиент, которому нужно получить исключение от сервера клиент: rSocketRequester .route("v1.data") .data(data) .sendAndAwait() сервер: return Mono.error(RuntimeException("test excep")) В...

поэтому я начал играть с rsocket и spring boot 2.2, чтобы посмотреть, смогу ли я использовать его в своих проектах, но у меня возникли некоторые проблемы. Обычно при обмене сообщениями Spring я определяю метод слушателя следующим образом:...

Есть ли разница в трафике ввода-вывода, когда мы используем поддержку RSocket Spring WebFlux (поверх WebSockets) для передачи значений с помощью Kotlin Coroutines Flow и Reactor Flux? @MessageMapping("stream") suspend fun send():...

Я хочу создать канал rsocket, где данные, отправленные с сервера, могут быть либо реакцией на запрос клиента, либо push. Для этого я использую слияние потоков. Это ссылочные данные: обновление может быть запрошено клиентом, и сервер также может...

Может кто-нибудь подскажет или даст готовый пример CRUD с использованием WebFlux, RScoket и Spring (или SpringBoot) ? Я изучил документацию RSocket , WebFlux , также написал свои простые примеры, но я хотел бы увидеть настоящее приложение CRUD...