This example demonstrates how you can use Camel-gRPC Starter component. The example is composed of a standalone gRPC server and a Camel Spring-boot gRPC route acting as client. We will run this example on Minikube (0.21.0)
You can build the server under the directory hello-camel-grpc-server with:
$ mvn clean install
and then run the server with
$ mvn -Pkubernetes-install fabric8:deploy
then check your pod status with
$ kubectl get pods
NAME READY STATUS RESTARTS AGE
camel-example-hello-grpc-server-kubernetes-2604940788-g47hr 1/1 Running 0 13sand get the logs
$ kubectl logs camel-example-hello-grpc-server-kubernetes-2604940788-g47hr
You should see the following output:
Aug 30, 2017 7:31:11 AM org.apache.camel.examples.grpc.HelloCamelServer start
INFO: Server started. I'm listening on 8080You can build the client example under the directory hello-camel-grpc-client with:
$ mvn clean install
and then run the server with
$ mvn -Pkubernetes-install fabric8:deploy
then check your pod status with
$ kubectl get pods
NAME READY STATUS RESTARTS AGE
camel-example-hello-grpc-client-kubernetes-1594657646-ptrkn 1/1 Running 0 15s
camel-example-hello-grpc-server-kubernetes-2604940788-g47hr 1/1 Running 0 7mand get the logs
$ kubectl logs camel-example-hello-grpc-client-kubernetes-1594657646-ptrkn
And you should see this output in the console.
2017-08-30 07:38:50.753:INFO:ifasjipjsoejs.Server:jetty-8.y.z-SNAPSHOT
2017-08-30 07:38:50.787:INFO:ifasjipjsoejs.AbstractConnector:Started SelectChannelConnector@0.0.0.0:9779
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v1.5.6.RELEASE)
2017-08-30 07:38:51.742 INFO 1 --- [ main] o.a.c.e.springboot.grpc.Application : Starting Application v2.20.0-SNAPSHOT on camel-example-hello-grpc-client-kubernetes-1594657646-ptrkn with PID 1 (/deployments/camel-example-hello-grpc-client-kubernetes-2.20.0-SNAPSHOT.jar started by root in /deployments)
2017-08-30 07:38:51.744 INFO 1 --- [ main] o.a.c.e.springboot.grpc.Application : No active profile set, falling back to default profiles: default
2017-08-30 07:38:51.899 INFO 1 --- [ main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@5faeada1: startup date [Wed Aug 30 07:38:51 GMT 2017]; root of context hierarchy
2017-08-30 07:38:53.236 INFO 1 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.apache.camel.spring.boot.CamelAutoConfiguration' of type [org.apache.camel.spring.boot.CamelAutoConfiguration$$EnhancerBySpringCGLIB$$bd99dea4] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2017-08-30 07:38:54.109 INFO 1 --- [ main] o.a.c.i.converter.DefaultTypeConverter : Type converters loaded (core: 192, classpath: 1)
2017-08-30 07:38:54.906 INFO 1 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Registering beans for JMX exposure on startup
2017-08-30 07:38:54.976 INFO 1 --- [ main] o.a.camel.spring.boot.RoutesCollector : Loading additional Camel XML routes from: classpath:camel/*.xml
2017-08-30 07:38:54.977 INFO 1 --- [ main] o.a.camel.spring.boot.RoutesCollector : Loading additional Camel XML rests from: classpath:camel-rest/*.xml
2017-08-30 07:38:54.977 INFO 1 --- [ main] o.a.camel.spring.boot.RoutesCollector : Starting CamelMainRunController to ensure the main thread keeps running
2017-08-30 07:38:54.980 INFO 1 --- [inRunController] o.a.camel.spring.SpringCamelContext : Apache Camel 2.20.0-SNAPSHOT (CamelContext: gRPC) is starting
2017-08-30 07:38:54.983 INFO 1 --- [inRunController] o.a.c.m.ManagedManagementStrategy : JMX is enabled
2017-08-30 07:38:55.005 INFO 1 --- [ main] o.a.c.e.springboot.grpc.Application : Started Application in 3.745 seconds (JVM running for 4.657)
2017-08-30 07:38:55.308 INFO 1 --- [inRunController] o.a.camel.spring.SpringCamelContext : StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
2017-08-30 07:38:55.387 INFO 1 --- [inRunController] o.a.camel.component.grpc.GrpcProducer : Creating channel to the remote gRPC server grpc-server:80
2017-08-30 07:38:55.544 INFO 1 --- [inRunController] o.a.camel.spring.SpringCamelContext : Route: route1 started and consuming from: timer://foo?period=10000&repeatCount=5
2017-08-30 07:38:55.545 INFO 1 --- [inRunController] o.a.camel.spring.SpringCamelContext : Total 1 routes, of which 1 are started
2017-08-30 07:38:55.546 INFO 1 --- [inRunController] o.a.camel.spring.SpringCamelContext : Apache Camel 2.20.0-SNAPSHOT (CamelContext: gRPC) started in 0.565 seconds
2017-08-30 07:38:57.443 INFO 1 --- [2 - timer://foo] route1 : Received message: "Hello Camel"
2017-08-30 07:39:06.556 INFO 1 --- [2 - timer://foo] route1 : Received message: "Hello Camel"
2017-08-30 07:39:16.551 INFO 1 --- [2 - timer://foo] route1 : Received message: "Hello Camel"
2017-08-30 07:39:26.551 INFO 1 --- [2 - timer://foo] route1 : Received message: "Hello Camel"
2017-08-30 07:39:36.551 INFO 1 --- [2 - timer://foo] route1 : Received message: "Hello Camel"Undeploy server and client
$ cd hello-camel-grpc-client-kubernetes
$ mvn -Pkubernetes-install fabric8:undeploy
$ cd ../hello-camel-grpc-server-kubernetes
$ mvn -Pkubernetes-install fabric8:undeployMake sure no pod is running
$ kubectl get pods
No resources found.If you hit any problem using Camel or have some feedback, then please let us know.
We also love contributors, so get involved :-)
The Camel riders!