maven grpc整合springboot demo

< dependency >

     < groupId >net.devh</ groupId >

     < artifactId >grpc-spring-boot-starter</ artifactId >

     < version >2.12.0.RELEASE</ version >

</ dependency >

< dependency >

     <!-- Java 9+ compatibility -->

     < groupId >javax.annotation</ groupId >

     < artifactId >javax.annotation-api</ artifactId >

</ dependency >

< plugin >

                 <!--                    protobuf生成插件-->

                 < groupId >org.xolstice.maven.plugins</ groupId >

                 < artifactId >protobuf-maven-plugin</ artifactId >

                 < version >0.6.1</ version >

                 < configuration >

                     < protocArtifact >com.google.protobuf:protoc:3.17.3:exe:${os.detected.classifier}

                     </ protocArtifact >

                     < pluginId >grpc-java</ pluginId >

                     < pluginArtifact >io.grpc:protoc-gen-grpc-java:1.39.0:exe:${os.detected.classifier}

                     </ pluginArtifact >

                     <!--默认值-->

                     < protoSourceRoot >${project.basedir}/src/main/proto</ protoSourceRoot >

                     < outputDirectory >${project.basedir}/src/main/java</ outputDirectory >

                     < clearOutputDirectory >false</ clearOutputDirectory >

                 </ configuration >

                 < executions >

                     < execution >

                         < goals >

                             < goal >compile</ goal >

                             < goal >compile-custom</ goal >

                         </ goals >

                     </ execution >

                 </ executions >

             </ plugin >

syntax = "proto3" ; //指定proto版本

package com.server;

// 生成的Java代码的包名

option java_package = "com.grpc.server" ;

// 请求参数

message HelloReq{

     string name = 1 ;

}

// 返回参数

message HelloResp{

     string ret = 1 ;

}

// rpc service

service HelloService{

     // service中需要进行调用的具体方法

     rpc hello(HelloReq) returns (HelloResp){}

}

import io.grpc.stub.StreamObserver;

import net.devh.boot.grpc.server.service.GrpcService;

@GrpcService

public class HelloService extends HelloServiceGrpc.HelloServiceImplBase {

     @Override

     public void hello(Hello.HelloReq request, StreamObserver<Hello.HelloResp> responseObserver) {

         Hello.HelloResp resp = Hello.HelloResp.newBuilder().setRet( "你好-->" +request.getName()).build();

         responseObserver.onNext(resp);

         responseObserver.onCompleted();

     }

}

import org.junit.jupiter.api.Test;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest

public class GrpcTest {

     @Autowired

     private HelloSerivce helloSerivce;

     @Test

     public void test1() throws   Exception{

         helloSerivce.haha( "牛哈哈" );

     }

}