grpc

    1熱度

    1回答

    我對(g)rpc有點新,而且我不太瞭解這個概念。我們在一個Kubernetes集羣中有一組NodeJS服務器,通過grpc相互通信。 rpc接口針對客戶端新貴上的每臺服務器進行設置。 我們最近發現,重新啓動服務器後,其客戶端失去與該服務器的連接。也就是說,在該服務器重新啓動之後,以前工作的rpc對服務器的調用不再起作用。直到我們以正確的順序重新啓動服務器,它纔會重新啓動。 我雖然是通過一個地址(主

    0熱度

    1回答

    io.grpc.StatusRuntimeException: CANCELLED at io.grpc.Status.asRuntimeException(Status.java:539) at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:439) at io.grpc.

    0熱度

    1回答

    我查看關於gRPC的不同教程並在Java中使用它,但是在教程中的protoc啓動和代碼後,獲得的代碼有很大不同。 例如,我看起來video from Ray Tsang和服務接口看起來像GreetingServiceGrpc.GreetingService,但是當Itry生成我自己的時候,我得到GreetingService.Interface。 此外,我生成的代碼中沒有'流'關鍵字的影響,所以我

    0熱度

    1回答

    我已經使用protoc 3.2編譯器編譯了我的Protoc文件。當我嘗試使用下面顯示的Maven依賴項時,POM文件給我錯誤,並且所有依賴關係都沒有解決。想知道什麼是正確版本的GRPC,所有我應該使用的是與protoc編譯器生成的Java代碼兼容3.2.0 我的POM文件看起來像: <dependencies> <!-- https://mvnrepository.com/artifact/io

    1熱度

    1回答

    我想測試一個React組件,組件的存儲正在做一些gRPC通信,因此需要grpc node_module。我的測試是通過鏈接導入grpc,因爲它導入了React組件,該組件導入了導入grpc的存儲。 這是好的,但automock失敗: Error: The specified module could not be found. \\?\C:\Dev\Projects\Electron\PAT\cl

    0熱度

    1回答

    我用grpc爲webcam-stream創建了一個微服務。流媒體工作正常,但流的取消僅在客戶端工作。 如果客戶端調用CancellableContext.cancel,則視頻流將停止,但服務器仍在使用該視頻流播放視頻。如果取消被調用,則服務器拋出Transport faild異常。 這個異常可以抓住停止在服務器端的流或其他操作嗎? ClientCall<KameraStreamRequest, K

    2熱度

    1回答

    在gRPC服務器的Python實現中,是否可以在請求之間維護一些持久的每線程狀態? (看起來像所有的例子使用concurrent.futures.ThreadPoolExecutor,但我還沒有找到什麼實際的服務器模型很多文件) 這將是一個不可忽視的設置成本,我想避免每RPC調用,但我不能依賴線程安全。例如。 DB連接,設置內存緩存等。

    2熱度

    1回答

    我想知道是否將數據從gRPC服務器推送到客戶端是個好主意。基本上我想在gRPC上使用pub/sub模式。 我的方式是我在服務器實現上返回一個響應流,我永遠不會關閉它。然後,客戶有一個永無止境的去閱讀這個流的例行程序。 下面是一個例子: service Service { rpc RegularChanges (Void) returns (stream Change) {} } 在

    0熱度

    1回答

    這是我第一天使用GRPC和我有幾個問題: 說我有產生時,看起來像這樣一個GRPC順序: Google::Protobuf::DescriptorPool.generated_pool.build do add_message "something.Order" do optional :uuid, :string, 1 repeated :shipments, :me

    0熱度

    1回答

    我正在使用grpc-java項目中的StreamObserver類來設置一些雙向流。 當我運行我的程序時,我向服務器發出了未確定數量的請求,並且我只想在完成所有請求後調用requestObserver上的onCompleted()。 目前,爲了解決這個問題,我使用變量「inFlight」來跟蹤已發出的請求,並且當響應返回時,我遞減「inFlight」。所以,這樣的事情。 // issuing re