Я хочу создать Reactor Flux из gRPC StreamObserver . Это необходимо сделать до тех пор, пока StreamObserver не реализует соответствующие интерфейсы изначально (см., например, эта проблема ). То, что я придумал, примерно похоже на следующее:...

@Override public StreamObserver<MdtDialoutArgs> mdtDialout(StreamObserver<MdtDialoutArgs> responseObserver) { return new StreamObserver<MdtDialoutArgs>() { @Override public void onError(Throwable t) {...

Я пытаюсь реализовать OAuth2 между моим сервером gRPC и клиентскими приложениями с помощью перехватчиков, выполнив следующие действия: клиентское приложение вызывает метод gRPC сервера серверное приложение отвечает статусом UNAUTHENTICATED и...

Я не смог запустить сервер gRPC (написанный на Java) на Raspberry Pi с включенной защитой SSL. Я получаю следующее сообщение: 2019-07-01 13:39:29,988 [main ] DEBUG OpenSsl Failed to load netty-tcnative;...

Я новичок в Spring webflux, а также в protobuf. Я читал некоторые вещи, и я нашел некоторое сходство между ними. Нравиться Spring webflux можно развернуть через netty, как и gRPC. Оба хорошо работают для потоковой передачи данных. Обе эти...

Вот мой трансформатор: public class DataEnricher implements Transformer < byte[], EnrichedData, KeyValue < byte[], EnrichedData >> { private ManagedChannel channel; private InfoClient infoclient; private LRUCacheCollector...

Я столкнулся с проблемой курицы и яйца. Случай: файл создается на удаленном клиенте. Клиент должен передать файл на сервер через asynccstub. Клиент также должен передавать метаданные через блокирующую заглушку для хранения в базе данных....

Я пытался заставить балансировку нагрузки GRPC работать в моем приложении Java, развернутом в кластере Kubernetes, но у меня не было особого успеха. Кажется, что по этому поводу не слишком много документации, но из примеров в Интернете я вижу, что...