saturnism / grpc-by-example-java Goto Github PK

View Code? Open in Web Editor NEW

869.0 51.0 340.0 341 KB

A collection of useful/essential gRPC Java Examples

License: Apache License 2.0

Java 94.70% HTML 2.27% Dockerfile 0.62% Kotlin 2.40%

grpc java grpc-java examples kubernetes containers docker jpa rxjava rxjava2

grpc-by-example-java's Introduction

gRPC Java Examples

This is a collection of Java gRPC examples.

This is not official Google product.

YouTube video

grpc-by-example-java's People

Contributors

Stargazers

Watchers

Forkers

boywsk yidongnan zxcnmv roseflunder paulvi dong77 sekift alanma yamau6809 windperson lkokhreidze kameshsampath marceluxvk smathangi amirtoole spadaki teranga liangguo85 jeffreymu yangyong2014 loneknightpy mevrescu sinxsoft fork-world clockworm wesleydias lazycathome davidraleigh sangdan zhuxukai hanhongyuan sgaraba amitbansal26 truongdo ywww glpenghui misaniy stephenking1101 gerardo8 claudiouzelac vivekkothari cvigo zhoujunhui239 blax11 sreddybr3 sjl421 gustavoleitao vineetu dshylov euno7 cakper maisi koga-fbs junneyang ninovz lizhitao0923 veramasu akashalgo lokeshmadan raymondzhaoy direkshan-digital adasniff achal126 shuza ofadeyi yqq836438958 minhsonmta nilportugues fengxinziio balia4u leonj1 tranbavinhson balajivenki feihu618 egerszegilaszlo nelbrecht iegrsy hoaronal sundongxu siddharthk blacktree javaqube clifford-beta mucyomiller faresyusuf flozano akodali18 jemmyzhang helianthuslulu zhou6ang zhanjunmap 3quanfeng kanthgithub benluteijn 24675574 mario-pinderi kvsravindrareddy alexaugustobr gjavolce liangyali

grpc-by-example-java's Issues

Does not build

[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 49.149 s
[INFO] Finished at: 2019-06-19T15:46:05+07:00
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-dependency-plugin:2.8:copy-dependencies (default) on project simple-grpc-client: Artifact has not been packaged yet. When used on reactor artifact, copy should be executed after packaging: see MDEP-187. -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]

Please update this code to build in java 12

There are many problems.

no com.example.grpc.GreetingServiceGrpc

hi,
how can i import this package, i did not find it anywhere.

Reactive-gRPC 0.10.0-RC1

Hello. We've released Reactive-gRPC 0.10.0-RC1. Would you be willing to try it out and report any findings?

https://github.com/salesforce/reactive-grpc/releases/tag/v0.10.0-RC1

grpc-example-Client-side Load Balancing w/ Kubernetes API Service Discovery

I followed the steps:
$ kubectl apply -f kubernetes/client-side-lb-api/echo-server.yaml
$ kubectl apply -f kubernetes/client-side-lb-api/echo-client.yaml
$ kubectl get pods -l run=echo-client
with this step:
$ kubectl logs -f echo-client...
I found java error

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Nov 28, 2019 2:07:04 PM io.grpc.internal.ManagedChannelImpl$NameResolverListenerImpl onError
WARNING: [io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNKNOWN, description=null, cause=io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred.
at io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:61)
at io.fabric8.kubernetes.client.KubernetesClientException.launderThrowable(KubernetesClientException.java:52)
at io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:195)
at com.example.grpc.client.KubernetesNameResolver.refresh(KubernetesNameResolver.java:79)
at com.example.grpc.client.KubernetesNameResolver.start(KubernetesNameResolver.java:63)
at io.grpc.internal.ManagedChannelImpl.exitIdleMode(ManagedChannelImpl.java:311)
at io.grpc.internal.ManagedChannelImpl$4$1.run(ManagedChannelImpl.java:357)
at io.grpc.internal.ChannelExecutor.drain(ChannelExecutor.java:87)
at io.grpc.internal.ManagedChannelImpl$4.get(ManagedChannelImpl.java:359)
at io.grpc.internal.ClientCallImpl.start(ClientCallImpl.java:218)
at io.grpc.stub.ClientCalls.startCall(ClientCalls.java:276)
at io.grpc.stub.ClientCalls.asyncUnaryRequestCall(ClientCalls.java:252)
at io.grpc.stub.ClientCalls.futureUnaryCall(ClientCalls.java:186)
at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:132)
at com.example.grpc.EchoServiceGrpc$EchoServiceBlockingStub.echo(EchoServiceGrpc.java:138)
at com.example.grpc.client.ClientSideLoadBalancedEchoClient.lambda$main$0(ClientSideLoadBalancedEchoClient.java:63)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.net.UnknownHostException: kubernetes.default.svc: Temporary failure in name resolution
at java.net.Inet4AddressImpl.lookupAllHostAddr(Native Method)
at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:928)
at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323)
at java.net.InetAddress.getAllByName0(InetAddress.java:1276)
at java.net.InetAddress.getAllByName(InetAddress.java:1192)
at java.net.InetAddress.getAllByName(InetAddress.java:1126)
at okhttp3.Dns$1.lookup(Dns.java:39)
at okhttp3.internal.connection.RouteSelector.resetNextInetSocketAddress(RouteSelector.java:172)
at okhttp3.internal.connection.RouteSelector.nextProxy(RouteSelector.java:138)
at okhttp3.internal.connection.RouteSelector.next(RouteSelector.java:80)
at okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:178)
at okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:129)
at okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:98)
at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)
at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:109)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)
at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)
at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:124)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)
at io.fabric8.kubernetes.client.utils.HttpClientUtils$3.intercept(HttpClientUtils.java:97)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:92)
at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:67)
at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:170)
at okhttp3.RealCall.execute(RealCall.java:60)
at io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:235)
at io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:230)
at io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:226)
at io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleGet(BaseOperation.java:708)
at io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:188)
... 17 more
}

$ kubectl version
Client Version: version.Info{Major:"1", Minor:"16", GitVersion:"v1.16.3", GitCommit:"b3cbbae08ec52a7fc73d334838e18d17e8512749", GitTreeState:"clean", BuildDate:"2019-11-13T11:23:11Z", GoVersion:"go1.12.12", Compiler:"gc", Platform:"linux/amd64"}
Server Version: version.Info{Major:"1", Minor:"16", GitVersion:"v1.16.3", GitCommit:"b3cbbae08ec52a7fc73d334838e18d17e8512749", GitTreeState:"clean", BuildDate:"2019-11-13T11:13:49Z", GoVersion:"go1.12.12", Compiler:"gc", Platform:"linux/amd64"}

Is it common/good practice to reference server in client?

In multiple projects, the client pom.xml uses

        <dependency>
            <groupId>${project.groupId}</groupId>
            <artifactId>*-grpc-server</artifactId>
            <version>${project.version}</version>
        </dependency>

I know this way the client can reuse the generated grpc classes.
But beside this way, are there any better ways, for example, server and client both reference same proto file, and use plugin to generated their own classes?

basic authentication example

can u please create some example about authenticate the request with diffrente methods like Basic, OAuth2 and ...?

Client retry example

Hello, thank you for this GitHub repo, it is extremely useful! It would be great if you could add an example of client-side retries. Using the standard mechanism, or by writing a new ClientInterceptor.

How do I execute the examples?

Attempting to execute both the client and server of the error handling example. I packaged the parent app, and successfully executed it with mvn exec:java -Dexec.mainClass="com.example.grpc.server.ErrorGrpcServer" . However, I cannot package the client app by running mvn package in the directory error-handling-example/error-handling-client due to the error

[ERROR] Failed to execute goal on project error-handling-client: Could not resolve dependencies for project com.example.errors:error-handling-client:jar:1.0-SNAPSHOT: Failed to collect dependencies at com.example.errors:error-server:jar:1.0-SNAPSHOT:

I also tried to execute mvn package at parent project root, i.e. error-handling-example/, but it didn't help.

“NoSuchMethodErrors” due to multiple versions of com.google.protobuf:protobuf-java:jar

Hi, there are multiple versions of com.google.protobuf:protobuf-java in grpc-by-example-java-master\springboot-example-lognet. As shown in the following dependency tree, according to Maven's “nearest wins” strategy, only com.google.protobuf:protobuf-java:3.6.1 can be loaded, com.google.protobuf:protobuf-java:3.5.1 and com.google.protobuf:protobuf-java:3.7.1 will be shadowed.

As com.google.protobuf:protobuf-java:3.7.1 has not been loaded during the building process, several methods are missing. However, the missing methods:
1. com.google.protobuf.GeneratedMessageV3: com.google.protobuf.Internal$LongList mutableCopy(com.google.protobuf.Internal$LongList)