        <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>

添加插件(注意：如果wagon-provider-api無(wú)法自動(dòng)引入，可以現(xiàn)在依賴中引入，以便于依賴的下載，然后在刪除依賴坐標(biāo)即可)

<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>
                    <!--默認(rèn)值-->
                    <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>

2.2 添加proto依賴文件

添加目錄src/main/proto，并將目錄設(shè)置為Source Root,然后在目錄src/main/proto下添加文件hello.proto，內(nèi)容如下

syntax = "proto3"; //指定proto版本
package com.server;
// 生成的Java代碼的包名
option java_package = "com.grpc.server";
// 請(qǐng)求參數(shù)
message HelloReq{
    string name = 1;
}
// 返回參數(shù)
message HelloResp{
    string ret = 1;
}
// rpc service
service HelloService{
	// service中需要進(jìn)行調(diào)用的具體方法
    rpc hello(HelloReq) returns (HelloResp){}
}

2.3 通過(guò)protobuf生成Java代碼

插件導(dǎo)入成功后，點(diǎn)擊下圖選中的protobuf:compile和protbuf:compile-custom 依次生成對(duì)應(yīng)的Java代碼（也就是接口依賴代碼）

3. server端接口具體實(shí)現(xiàn)

service代碼如下

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();
    }
}

4 client端接口具體實(shí)現(xiàn)

client端測(cè)試調(diào)用代碼如下

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("牛哈哈");
    }
}

以上就是maven grpc整合springboot demo的詳細(xì)內(nèi)容，更多關(guān)于maven grpc整合springboot 的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: