Описание тега grpc-java

Версия Java общей структуры RPC (удаленного вызова процедур) через HTTP/2.
0 ответов

Как перехватить и переслать вызов GRPC в зависимости от содержания сообщения

Я хочу быть в состоянии переслать RPC вызовите другую реализацию, основанную на содержании сообщения. Я исследовал GRPC interceptors но у веб-сайта нет хорошего объяснения этому. Я не могу найти хорошую документацию по этому вопросу мой proto файл в…
22 окт '18 в 11:48
2 ответа

Передача файлов с использованием gRPC

Каков стандартный способ использования gRPC и буфера протокола для передачи файла или изображений из одного процесса в другой? Размер файла составляет от 1 до 6 МБ. В основном я хочу знать, как реализовать пары кода отправитель / получатель для pyth…
07 сен '17 в 21:16
1 ответ

Как создать запись в объекте Context в начале запроса и получить его в конце запроса?

(отказ от ответственности: я балуюсь grpc) У меня есть объект, который я хотел бы связать с каждым запросом, initializeв начале запроса и closeПосле того, как запрос сделан. В настоящее время я достигаю этого, используя два ServerInterceptorsпервый …
02 авг '18 в 21:55
1 ответ

gRPC UNAVAILABLE EOF Ошибка при ожидании данных

Я пытаюсь создать Java-версию Jtimon Github На Github вы можете увидеть прото-сообщение для определения сервиса И мой код Java выглядит следующим образом package jti.collector; public class JTICollector { private static final Logger log = LoggerFact…
28 ноя '17 в 21:13
0 ответов

Не получается имя метода или класса в нативном Java из прото

Я создал файл прото syntax = "proto3"; package example; message HelloRequest { string name = 1; } message HelloResponse { string greeting = 1; } // 4. service, unary request/response service GreetingService { rpc GetGreetingMethod(HelloRequest) retu…
08 июн '18 в 06:38
2 ответа

Ошибка подключения io.netty.handler.codec.http2.Http2Exception: предисловие клиента HTTP/2 отсутствует или повреждено. Шестнадцатеричный дамп для полученных байтов:

Работа над двунаправленной потоковой передачей Grpc, когда я пытаюсь запустить grpc, получаю ошибку ниже Connection Error io.netty.handler.codec.http2.Http2Exception: HTTP/2 client preface string missing or corrupt. Hex dump for received bytes: at i…
08 авг '17 в 14:39
2 ответа

Пример загрузки Java-файла gRPC

Я ищу способ реализации функции загрузки файлов с помощью gRPC, но я не могу найти в документации, как это делается. Каков оптимальный способ сделать это? Я хотел иметь сервер gRPC, который содержит файлы, и клиент gRPC для запроса чего-либо из gRPC…
16 мар '18 в 03:08
0 ответов

Запуск google pub/sub под Java 7 получает ALPN ClassNotFoundException

Я пытаюсь запустить небольшую тестовую программу, используя Google Cloud Pub/Sub (версии от 0.32.0 до 0.39.0) под Java 7. Код Google Cloud предположительно совместим с Java 7, но я обнаружил, что получаю Следующее исключение при запуске с 7. Java 8 …
1 ответ

Работа с gRPC - выберите между фреймворками, такими как Spring или Dropwizard

Мы с нетерпением ожидаем внедрения серверной системы с чистым gRPC-сервером с БД Mongo в качестве нашего хранилища данных. Обычно я всегда использую Spring или Dropwizard в качестве своего java-фреймворка, но так как в них нет особой ценности для gR…
05 ноя '18 в 13:06
1 ответ

Импортировать файл в gRPC Java-проект

Я пытаюсь внедрить состояние отчета с помощью gRPC для модуля "Умный дом" в Google Actions. Но я не могу выполнить все операции импорта для моего файла *.proto (как сказано в официальной документации): https://developers.google.com/actions/smarthome…
22 июн '18 в 08:14
2 ответа

Проблема bindableService с grpc-Java

Я пытаюсь использовать grpc-java v1.1.2 (раздел build.gradle ниже), но когда я пытаюсь запустить толстый jar для примера приложения, возникает исключение, указанное ниже. Я не вижу проблем при компиляции приложения. Части build.gradle: apply plugin:…
01 мар '17 в 19:39
1 ответ

Пружинная загрузка + GRPC Http2Exception

Я пытаюсь настроить сервер GRPC с весенней загрузкой. Мой VIP указывает на сервер через порт 8443. Я пытаюсь подключиться к серверу GRPC в моем vip от моего локального клиента GRPC. Есть ли что-то, чего мне не хватает при следовании подходу GRPC с п…
29 май '17 в 17:34
1 ответ

Как я могу получить аннотации для вызова метода rpc в grpc-java

Мне нужно проверить запрос перед вызовом разных методов rpc с разными валидаторами. Поэтому я реализовал валидаторы, такие как class BarRequestValidator { public FooServiceError validate(BarRequest request) { if (request.bar.length > 12) { return…
11 дек '16 в 18:18
1 ответ

"Мостовой" поток реактора от gRPC StreamObserver

Я хочу создать Reactor Flux из gRPC StreamObserver. Это необходимо сделать до тех пор, пока StreamObserver не реализует соответствующие интерфейсы изначально (см., Например, эту проблему). То, что я придумал, примерно так: final StreamObserver<Pr…
23 окт '17 в 08:33
2 ответа

Столкновение с NoSuchMethodError для метода io.netty.util.AttributeKey.valueOf() с grpc и protobuf Пример Hello world

После запуска тестов GreetingServerTest.java я получаю ниже приведенные ошибки. Я использую библиотеки grpc 1.1.0-SNAPSHOT и пытаюсь реализовать базовый пример grpc Helloword, приведенный в git repo. Кто-нибудь может предложить, какие библиотеки мне…
12 сен '16 в 12:18
1 ответ

Ошибка SSL с GRPC Java

Версия JDK: 1.8u77 версия proto3.0.3 Я попытался включить SSL в текущее приложение. Пожалуйста, найдите ниже подходы, которые мы попробовали. 1) OpenSSL Статический подход Мы добавили io.netty.tcnative-boringssl-static, io.netty.handler и пакеты в c…
05 авг '17 в 04:20
2 ответа

Как передать traceIds в Hystrix Observables?

У меня есть несколько служб, некоторые из которых используют HystrixObservableCommand Hystrix для вызова других служб, а другие используют HystrixCommand. Как передать traceIds из вызывающей службы в Observables в HystrixObservableCommand, а также п…
14 ноя '17 в 19:05
2 ответа

Протокольный буферный поток, проверяющий gRPC на миллион сообщений

Я тестирую gRPC со списком миллионов элементов и отправляю этот миллион элементов потоком. У меня есть этот код на клиенте: на моем тестовом хосте: "Localhost", ipPort = 7777 ManagedChannel comunicationChanel = ManagedChannelBuilder.forAddress(host,…
24 янв '18 в 10:08
1 ответ

gRPC-java - компиляция файла.proto

Я скомпилировал свой файл.proto, используя компилятор protobuf, и получил набор файлов Java. Я получил файл proto.java и файл.java для каждого элемента в файле.proto, включая тип сообщения и каждый вызов rpc, например publicKeyRequest.java и Quote.j…
31 июл '17 в 12:27
1 ответ

gRPC gradle:generateProto завершается ошибкой с каталогом, не найденным при импорте других прототипов

Я пытаюсь скомпилировать некоторые определения protobuf как задачу gradle, но получаю следующую ошибку без генерации исходного кода: * What went wrong: Execution failed for task ':generateProto'. > protoc: stdout: . stderr: /Users/ash/IdeaProject…
28 июн '17 в 16:55