GRPC 配置、使用、安裝文件 java-windows

2.新建maven專案，將.proto放入src/main/proto資料夾下面 3、編寫pom.xml檔案，引入外掛

<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>com.ytf.simple</groupId>
     <artifactId>protobuf</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>simple</name>
     <properties>
          <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
           <grpc.version>1.0.1</grpc.version>
     </properties>
     <dependencies>
           <dependency>
                <groupId>io.grpc</groupId>
                <artifactId>grpc-netty</artifactId>
                <version>1.0.1</version>
           </dependency>
           <dependency>
                <groupId>io.grpc</groupId>
                <artifactId>grpc-protobuf</artifactId>
                <version>1.0.1</version>
           </dependency>
           <dependency>
                <groupId>io.grpc</groupId>
                <artifactId>grpc-stub</artifactId>
                <version>1.0.1</version>
           </dependency>
           <dependency>
                <groupId>com.google.protobuf</groupId>
                <artifactId>protobuf-java</artifactId>
                <version>3.1.0</version>
           </dependency>
           <dependency>
                <groupId>io.grpc</groupId>
                <artifactId>grpc-core</artifactId>
                <version>${grpc.version}</version>
           </dependency>
           <dependency>
                <groupId>io.grpc</groupId>
                <artifactId>grpc-all</artifactId>
                <version>1.0.1</version>
           </dependency>
           <!-- <dependency> <groupId>io.grpc</groupId> <artifactId>grpc-stub</artifactId>
                <version>${grpc.version}</version> </dependency> <dependency> <groupId>com.orbitz.consul</groupId>
                <artifactId>consul-client</artifactId> <version>0.10.0</version> </dependency> -->
     </dependencies>
     <build>
           <finalName>com.ytf.rpc.demo</finalName>
           <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.1.0:exe:${os.detected.classifier}</protocArtifact>
                           <pluginId>grpc-java</pluginId>
                          <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.0.1:exe:${os.detected.classifier}</pluginArtifact>
                     </configuration>
                     <executions>
                           <execution>
                                <goals>
                                     <goal>compile</goal>
                                     <goal>compile-custom</goal>
                                </goals>
                           </execution>
                     </executions>
                </plugin>
                <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-compiler-plugin</artifactId>
                     <version>2.3.2</version>
                     <configuration>
                           <source>1.8</source>
                           <target>1.8</target>
                     </configuration>
                </plugin>
           </plugins>
     </build>
</project>

4、進入pom.xml的檔案目錄，開啟cmd視窗 (shift + 滑鼠右鍵 -->在此處開啟命令視窗)輸入 mvn compile 5、生成的java 以及grpc檔案目錄如下： projectPath\target\generated-sources\protobuf\java projectPath\Path\target\generated-sources\protobuf\grpc-java 6、將程式碼copy到專案src/main/java目錄下重新整理專案即可 二、利用exe手動命令生成java檔案 1.下載 protocol buffer 2/3

下載完成後，新增 window 環境變數(由於我本地有兩個版本，故我命名為protoc2/protoc3)新增完成後，進行驗證。如下圖：

如果出現於作者同樣的圖，說明安裝成功！

2.在編譯的 gRPC 的時候，protocol buffer 需要將 protoc-gen-grpc-java 作為外掛來生成程式碼，

文件介紹：http://www.grpc.io/docs/quickstart/java.html

下載地址：https://repo1.maven.org/maven2/io/grpc/protoc-gen-grpc-java/1.0.1/

下載完成後，同樣的新增到 winddos環境變數中。

3.編寫 .proto 檔案。命名為： grpc-helloworld.proto .檔案內容如下：

syntax = "proto3" 
;

option java_generic_services = true;
option java_multiple_files = true;
option java_package = "com.hservice.grpc.schema";
option java_outer_classname = "HelloWorldProto";

// The greeting service definition.
service Greeter {
  // Sends a greeting
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

// The request message containing the user's name.
message HelloRequest {
  string name = 1;
}

// The response message containing the greetings
message HelloReply {
  string message = 1;
}

首先生成Proto 檔案

再執行生成命令：( >>> protoc3 --plugin=protoc-gen-grpc-java=D:/sysEnv/protoc-gen-grpc-java.exe --grpc-java_out=java --proto_path=proto proto/g
rpc-helloworld.proto) 生成gRPC檔案

如果在這一步的時候，執行失敗，請注意路徑引數的配置。

4.生成後，會在com.hservice.grpc.schema 包下生存 GreeterGrpc.java 檔案。我的生成後java 程式碼如下：

三、利用gradle build 將proto生成java檔案 1、新建gradle3.0+++版本的gradle專案 2、編寫gradle.build檔案內容，如下： 3、進入gradle.build檔案所在目錄，，開啟cmd視窗 (shift + 滑鼠右鍵 -->在此處開啟命令視窗)輸入 gradle build 4、生成的檔案目錄如下： 然後複製過去就好 projectHome\build\generated\source\proto\main\java projectHome\build\generated\source\proto\main\grpc apply plugin: 'java' apply plugin: 'com.google.protobuf' buildscript { repositories { mavenCentral() } dependencies { // ASSUMES GRADLE 2.12 OR HIGHER. Use plugin version 0.7.5 with earlier // gradle versions classpath 'com.google.protobuf:protobuf-gradle-plugin:0.8.0' } } repositories { mavenLocal() mavenCentral() } // IMPORTANT: You probably want the non-SNAPSHOT version of gRPC. Make sure you // are looking at a tagged version of the example and not "master"! // Feel free to delete the comment at the next line. It is just for safely // updating the version in our release process. def grpcVersion = '1.0.1' // CURRENT_GRPC_VERSION dependencies { compile "io.grpc:grpc-netty:${grpcVersion}" compile "io.grpc:grpc-protobuf:${grpcVersion}" compile "io.grpc:grpc-stub:${grpcVersion}" testCompile "junit:junit:4.11" testCompile "org.mockito:mockito-core:1.9.5" } protobuf { protoc { artifact = 'com.google.protobuf:protoc:3.1.0' } plugins { grpc { artifact = "io.grpc:protoc-gen-grpc-java:${grpcVersion}" } } generateProtoTasks { all()*.plugins { grpc { // To generate deprecated interfaces and static bindService method, // turn the enable_deprecated option to true below: option 'enable_deprecated=false' } } } } // Inform IntelliJ projects about the generated code. apply plugin: 'idea' idea { module { // Not using generatedSourceDirs because of // https://discuss.gradle.org/t/support-for-intellij-2016/15294/8 sourceDirs += file("${projectDir}/build/generated/source/proto/main/java"); sourceDirs += file("${projectDir}/build/generated/source/proto/main/grpc"); } } // Provide convenience executables for trying out the examples. apply plugin: 'application' startScripts.enabled = false task routeGuideServer(type: CreateStartScripts) { mainClassName = 'io.grpc.examples.routeguide.RouteGuideServer' applicationName = 'route-guide-server' outputDir = new File(project.buildDir, 'tmp') classpath = jar.outputs.files + project.configurations.runtime } task routeGuideClient(type: CreateStartScripts) { mainClassName = 'io.grpc.examples.routeguide.RouteGuideClient' applicationName = 'route-guide-client' outputDir = new File(project.buildDir, 'tmp') classpath = jar.outputs.files + project.configurations.runtime } task helloWorldServer(type: CreateStartScripts) { mainClassName = 'io.grpc.examples.helloworld.HelloWorldServer' applicationName = 'hello-world-server' outputDir = new File(project.buildDir, 'tmp') classpath = jar.outputs.files + project.configurations.runtime } task helloWorldClient(type: CreateStartScripts) { mainClassName = 'io.grpc.examples.helloworld.HelloWorldClient' applicationName = 'hello-world-client' outputDir = new File(project.buildDir, 'tmp') classpath = jar.outputs.files + project.configurations.runtime } task compressingHelloWorldClient(type: CreateStartScripts) { mainClassName = 'io.grpc.examples.experimental.CompressingHelloWorldClient' applicationName = 'compressing-hello-world-client' outputDir = new File(project.buildDir, 'tmp') classpath = jar.outputs.files + project.configurations.runtime } applicationDistribution.into('bin') { from(routeGuideServer) from(routeGuideClient) from(helloWorldServer) from(helloWorldClient) from(compressingHelloWorldClient) fileMode = 0755 } 四、編寫service 和 client for java 首先你得有：*Grpc.java,*Proto.java,*Builder.java檔案 1、編寫service，流 ①、繼承GreeterGrpc.GreeterImplBase 定義一個靜態內部類重寫你剛才定義的介面，然後你還的有個start(),stop(),blockUntilShutdown()方法來操作服務端的開始停止，完整程式碼如下： package com.ibm.crl.demo; import java.io.IOException; import io.grpc.Server; import io.grpc.ServerBuilder; import io.grpc.stub.StreamObserver; public class DemoServer { private Server server; /* The port on which the server should run */ private int port = 50051; private void start() throws IOException { server = ServerBuilder.forPort(port).addService(new DemoGrpcImpl()).build().start(); System.out.println("server start " + port); Runtime.getRuntime().addShutdownHook(new Thread() { @Override public void run() { // Use stderr here since the logger may have been reset by its JVM shutdown hook. System.err.println("*** shutting down gRPC server since JVM is shutting down"); DemoServer.this.stop(); System.err.println("*** server shut down"); } }); } private void stop() { if (server != null) { server.shutdown(); } } /** * Await termination on the main thread since the grpc library uses daemon threads. */ private void blockUntilShutdown() throws InterruptedException { if (server != null) { server.awaitTermination(); } } /** * Main launches the server from the command line. */ public static void main(String[] args) throws IOException, InterruptedException { final DemoServer server = new DemoServer(); server.start(); server.blockUntilShutdown(); } static class DemoGrpcImpl extends GreeterGrpc.GreeterImplBase { @Override public StreamObserver<HelloRequest> sayHello(StreamObserver<HelloReply> responseObserver) { return new StreamObserver<HelloRequest>() { private int count = 0; public void onNext(HelloRequest req) { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } count++; HelloReply reply = HelloReply.newBuilder().setMessage("demo " + req.getName()).build(); responseObserver.onNext(reply); System.out.println("resquest:" + req.getName() + System.currentTimeMillis()); } public void onError(Throwable t) { System.err.println(System.currentTimeMillis() + " : " + count + "server demo error:" + t.getMessage()); responseObserver.onError(t); } public void onCompleted() { System.out.println("task finish close session ! someone has died!" + System.currentTimeMillis() + " times:" + count); responseObserver.onCompleted(); } }; } } } // end 2、編寫client，流 主要是初始化channel和GreeterStub程式碼如下： package com.ibm.crl.demo; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; import

GRPC 配置、使用、安裝文件 java-windows

GRPC 配置、使用、安裝文件 java-windows

GRPC 配置、使用、安裝文件 java-windows-eclipse

Java項目生成可執行jar包、exe文件以及在Windows下的安裝文件

二、Redis命令行和配置文件redis.windows.conf

Head first java chapter 17 包、jar存檔文件和部署

九、將cs文件快速的轉換成可執行文件和響應文件(配置編譯開關的文件)

SpringBoot系列四：SpringBoot開發（改變環境屬性、讀取資源文件、Bean 配置、模版渲染、profile 配置）

Java 007 面向物件（構造方法、static關鍵字、JDK幫助文件、Math類）

Java 合併、拆分PDF文件

CDH完全安裝文件（含Spark2、）

AKKA文件(java版)—角色的引用、路徑和地址

Google、IBM和Lyft開源的微服務管理框架Istio安裝文件

Lesson_for_java_day23--java的網路程式設計練習(登入介面、上傳文件、上傳圖片、通過網路文字轉換)

Java 加密、解密PDF文件

Linux中怎麼檢視命令的幫助文件、怎麼檢視系統配置檔案的幫助文件？

Java中抽象類、介面、包的文件練習

apache poi操作office文件----java線上預覽txt、word、ppt、execel，pdf程式碼

Java 新增、讀取、刪除PPT文件屬性

Java 新增、讀取、刪除Excel文件屬性

關於Ubuntu中passwd、shadow、group等文件

GRPC 配置、使用、安裝文件 java-windows

相關推薦