一、环境

jdk8+maven+IDEA

二、我的理解+官方文档

1、官方文档:https://codelabs.developers.google.com/codelabs/cloud-grpc-java/index.html#2

2、我的理解：grpc是利用.proto文件用相应的语言编译生成相应的代码，这样就能实现不同语言平台之间的调用。最神奇的是仿佛客户端和服务器端调用的是相同的函数，在相同函数里面实现通信，相当的容易理解。

三、我的github+代码

1、github链接：https://github.com/cysisu/grpc-java.git

2、代码如下：

（1）pop.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>com.grpc.cube</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>io.grpc</groupId><artifactId>grpc-netty</artifactId><version>1.7.0</version></dependency><dependency><groupId>io.grpc</groupId><artifactId>grpc-protobuf</artifactId><version>1.7.0</version></dependency><dependency><groupId>io.grpc</groupId><artifactId>grpc-stub</artifactId><version>1.7.0</version></dependency></dependencies><build><extensions><extension><groupId>kr.motd.maven</groupId><artifactId>os-maven-plugin</artifactId><version>1.5.0.Final</version></extension></extensions><plugins><plugin><groupId>org.xolstice.maven.plugins</groupId><artifactId>protobuf-maven-plugin</artifactId><version>0.5.0</version><configuration><protocArtifact>com.google.protobuf:protoc:3.4.0:exe:${os.detected.classifier}</protocArtifact><pluginId>grpc-java</pluginId><pluginArtifact>io.grpc:protoc-gen-grpc-java:1.7.0:exe:${os.detected.classifier}</pluginArtifact></configuration><executions><execution><goals><goal>compile</goal><goal>compile-custom</goal></goals></execution></executions></plugin></plugins></build></project>

(2) 客户端：

package com.example.grpc;import io.grpc.*;public class Client
{public static void main( String[] args ) throws Exception{// Channel is the abstraction to connect to a service endpoint// Let's use plaintext communication because we don't have certsfinal ManagedChannel channel = ManagedChannelBuilder.forTarget("localhost:8080").usePlaintext(true).build();// It is up to the client to determine whether to block the call// Here we create a blocking stub, but an async stub,// or an async stub with Future are always possible.GreetingServiceGrpc.GreetingServiceBlockingStub stub = GreetingServiceGrpc.newBlockingStub(channel);GreetingServiceOuterClass.HelloRequest request =GreetingServiceOuterClass.HelloRequest.newBuilder().setName("Ray").build();// Finally, make the call using the stubGreetingServiceOuterClass.HelloResponse response =stub.greeting(request);System.out.println(response);// A Channel should be shutdown before stopping the process.channel.shutdownNow();}
}

（3）服务器端调用的函数：

package com.example.grpc;import io.grpc.stub.StreamObserver;public class GreetingServiceImpl extends GreetingServiceGrpc.GreetingServiceImplBase {public void greeting(GreetingServiceOuterClass.HelloRequest request,StreamObserver<GreetingServiceOuterClass.HelloResponse> responseObserver) {// HelloRequest has toString auto-generated.System.out.println(request);// You must use a builder to construct a new Protobuffer objectGreetingServiceOuterClass.HelloResponse response = GreetingServiceOuterClass.HelloResponse.newBuilder().setGreeting("Hello there, " + request.getName()).build();// Use responseObserver to send a single response backresponseObserver.onNext(response);// When you are done, you must call onCompleted.responseObserver.onCompleted();}
}

（5）服务器端：

package com.example.grpc;
import io.grpc.*;public class App
{public static void main( String[] args ) throws Exception{// Create a new server to listen on port 8080Server server = ServerBuilder.forPort(8080).addService(new GreetingServiceImpl()).build();// Start the serverserver.start();// Server threads are running in the background.System.out.println("Server started");// Don't exit the main thread. Wait until server is terminated.server.awaitTermination();}
}

（6）proto文件：

syntax = "proto3";
package com.example.grpc;// Request payload
message HelloRequest {// Each message attribute is strongly typed.// You also must assign a "tag" number.// Each tag number is unique within the message.string name = 1;// This defines a strongly typed list of Stringrepeated string hobbies = 2;// There are many more basics types, like Enum, Map// See https://developers.google.com/protocol-buffers/docs/proto3// for more information.
}message HelloResponse {string greeting = 1;
}// Defining a Service, a Service can have multiple RPC operations
service GreetingService {// Define a RPC operationrpc greeting(HelloRequest) returns (HelloResponse);
}

GRPC java实现demo相关推荐

Java类Demo中存在_Java中的数据类型转换
先来看一个题: Java类Demo中存在方法func0.func1.func2.func3和func4,请问该方法中,哪些是不合法的定义?( ) public class Demo{ float fu ...
海康威视（HIKVISION） JAVA SDK Demo成功运行
海康威视(HIKVISION) JAVA SDK Demo成功运行引子下载说明代码编译添加文件问题排查总结引子调海康的JAVA SDK花费时间较长,所以记录下,为其他小伙伴填填坑, ...
java用虹软人脸识别SDK实现人脸识别，运行ArcSoft的Java版本Demo出错，未检出人脸
java.lang.UnsatisfiedLinkError: Can't load library: d:\face_libs\libarcsoft_ java用虹软人脸识别SDK实现人脸识别网上 ...
java用虹软人脸识别SDK实现人脸识别，运行ArcSoft的Java版本Demo出错，未检出人脸（已解决）
java用虹软人脸识别SDK实现人脸识别,运行ArcSoft的Java版本Demo出错,未检出人脸问题已解决!!! 原因: 虹软人脸识别SDK版本问题! 下载的java版本的demo的SDK是arcs ...
微信公众号Java接入demo
微信公众号Java接入demo 前不久买了一台服务,本来是用来当梯子用的,后来买了一个域名搭了一个博客网站,后来不怎么在上面写博客一直闲着,最近申请了一个微信公众号就想着弄点什么玩玩.周末没事就鼓捣了 ...
Java类Demo中存在方法func1、func2、func3和func4，请问该方法中，哪些是不合法的定义？( )
Java类Demo中存在方法func1.func2.func3和func4,请问该方法中,哪些是不合法的定义?( ) public class Demo{float func1(){int i=1;r ...
grpc java 泛型_gRPC中Any类型的使用(Java和NodeJs端)
工作中要把原来Java服务端基于SpringMVC的服务改为使用gRPC直接调用.由于原Service的返回值为动态的Map类型,key值不确定,且value的类型不唯一,因此使用了protobuf ...
grpc java 基础教程
1 RPC 框架原理 RPC 框架的目标就是让远程服务调用更加简单.透明,RPC 框架负责屏蔽底层的传输方式(TCP 或者 UDP).序列化方式(XML/Json/ 二进制)和通信细节.服务调用者可以 ...
java junit 运行_appium+java+junit demo运行
对java熟悉一些,所以想用java把appium给做起来.今天用myeclipse给环境和Demo弄了一下,网上没有一篇全套资料的. 各块环境的搭建: 1.安装appium客户端,省略下载和安装步骤 ...

GRPC java实现demo

一、环境

jdk8+maven+IDEA

二、我的理解+官方文档

三、我的github+代码

GRPC java实现demo相关推荐

最新文章

热门文章

GRPC java实现demo

一、环境

jdk8+maven+IDEA

二、 我的理解+官方文档

三、我的github+代码

GRPC java实现demo相关推荐

最新文章

热门文章

二、我的理解+官方文档