grpc-srpingboot集成

待我称王封你为后i 2022-10-07 14:55 150阅读 0赞

1，依赖  
<dependency>  
            <groupId>net.devh</groupId>  
            <artifactId>grpc-server-spring-boot-starter</artifactId>  
            <version>2.10.1.RELEASE</version>  
        </dependency>  
        <dependency>  
            <groupId>net.devh</groupId>  
            <artifactId>grpc-client-spring-boot-starter</artifactId>  
            <version>2.10.1.RELEASE</version>  
        </dependency>  
2，配置  
服务端  
grpc:  
  server:  
    port: 6566  
      
客户端---自动到注册中心的metadata获取服务端的grpc端口  
grpc:  
  client:  
    GLOBAL:  
      negotiation-type: plaintext  
      enable-keep-alive: true  
      keep-alive-without-calls: true              
management:  
  server:  
    port: 6567---此端口和服务端通信无关  
  endpoints:  
    enabled-by-default: true  
    web:  
      exposure:  
        include: "\*"

pom--需要生成代码的项目  
<build>  
        <extensions>  
            <extension>  
                <groupId>kr.motd.maven</groupId>  
                <artifactId>os-maven-plugin</artifactId>  
                <version>1.6.2</version>  
            </extension>  
        </extensions>  
        <plugins>  
            <plugin>  
                <groupId>org.xolstice.maven.plugins</groupId>  
                <artifactId>protobuf-maven-plugin</artifactId>  
                <version>0.6.1</version>  
                <configuration>  
                    <protocArtifact>com.google.protobuf:protoc:3.12.0:exe:$\{os.detected.classifier\}</protocArtifact>  
                    <pluginId>grpc-java</pluginId>  
                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.34.1:exe:$\{os.detected.classifier\}</pluginArtifact>  
                      
                    <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>

<plugin>  
                <groupId>org.codehaus.mojo</groupId>  
                <artifactId>build-helper-maven-plugin</artifactId>  
                <version>3.0.0</version>  
                <executions>  
                      
                    <execution>  
                        <id>add-source</id>  
                        <phase>generate-sources</phase>  
                        <goals>  
                            <goal>add-source</goal>  
                        </goals>  
                        <configuration>  
                            <sources>  
                                <source>$\{project.basedir\}/src/main/gen</source>  
                                <source>$\{project.basedir\}/src/main/java</source>  
                            </sources>  
                        </configuration>  
                    </execution>  
                </executions>  
            </plugin>

</plugins>  
    </build>

代码：  
服务端：  
package com.hualala.aleenjava.grpc.service.impl;

import com.hualala.aleenjava.grpc.beanmapper.UserMapper;  
import com.hualala.aleenjava.grpc.config.Status;  
import com.hualala.aleenjava.grpc.model.TblUser;  
import com.hualala.aleenjava.grpc.service.ITblUserService;  
import com.hualala.aleenjava.grpc.user.UserReply;  
import com.hualala.aleenjava.grpc.user.UserRequest;  
import com.hualala.aleenjava.grpc.user.UserServiceGrpc;  
import io.grpc.stub.StreamObserver;  
import lombok.extern.slf4j.Slf4j;  
import net.devh.boot.grpc.server.service.GrpcService;  
import org.springframework.beans.factory.annotation.Autowired;

@Slf4j  
@GrpcService---注册到注册中心（把grpc端口当做注册中心中metadata中的字段）  
public class UserServiceGrpcImpl extends UserServiceGrpc.UserServiceImplBase \{

@Autowired  
    private ITblUserService iTblUserService;

@Override  
    public void queryUser(UserRequest request, StreamObserver<UserReply> responseObserver) \{  
        log.info("request id \{\}", request.getId());  
        UserReply.Builder userReply =  UserReply.newBuilder();  
        TblUser tblUser = iTblUserService.getById(request.getId());  
        userReply.setCode(Status.SUCCESS.code).setMsg(Status.SUCCESS.message).setSuccess(true);  
        userReply.setData(UserReply.Data.newBuilder().setUserPb(UserMapper.INSTANCE.convertToProtobuf(tblUser)));  
        responseObserver.onNext(userReply.build());  
        responseObserver.onCompleted();  
    \}  
\}

客户端：  
package com.hualala.aleenjava.grpc.controller;  
import com.hualala.aleenjava.grpc.user.UserReply;  
import com.hualala.aleenjava.grpc.user.UserRequest;  
import com.hualala.aleenjava.grpc.user.UserServiceGrpc;  
import lombok.extern.slf4j.Slf4j;  
import net.devh.boot.grpc.client.inject.GrpcClient;  
import org.springframework.web.bind.annotation.PathVariable;  
import org.springframework.web.bind.annotation.RequestMapping;  
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.ExecutionException;

/\*\*  
 \* <p>  
 \*  前端控制器  
 \* </p>  
 \*  
 \* @author aleenjava  
 \* @since 2021-04-10  
 \*/  
@RestController  
@RequestMapping("/user")  
@Slf4j  
public class UserController \{  
    @GrpcClient("grpc-greet-service")---从注册中心获取  
    UserServiceGrpc.UserServiceFutureStub futureStub;

@RequestMapping(value="/queryUser/\{id\}")  
    public UserReply queryUser(@PathVariable Integer id)  \{  
        UserReply userReply = null;  
        try \{  
            userReply = futureStub.queryUser(UserRequest.newBuilder().setId(id).build()).get();  
            return userReply;  
        \} catch (InterruptedException e) \{

\} catch (ExecutionException e) \{

\}  
        return userReply;  
    \}

注册中心就是项目本来的注册中心用法

json格式转化器：

Type definition error: \[simple type, class com.google.protobuf.UnknownFieldSet\]; nested exception is com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Direct self-reference leading to cycle (through reference chain: com.ecarx.collect.tile.ConsistenceResponse\["unknownFields"\]->com.google.protobuf.UnknownFieldSet\["defaultInstanceForType"\])  
由于http的Converter无法解析proto的格式（json《---》proto对象），需要增加proto 的解析器

http解析器和proto解析器按顺顺遍历谁，可以解析用谁，仅从contnettype看http可以解析proto,但是具体过程会失败，  
proto先解析的话，他内部实现非常精确，只解析proto,不是的话自然其他解析

package com.t.collect.config;

import com.google.common.collect.Lists;  
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Configuration;  
import org.springframework.http.MediaType;  
import org.springframework.http.converter.protobuf.ProtobufHttpMessageConverter;

@Configuration  
public class MessageConverter \{

@Bean  
    public HttpMessageConverters protobufHttpMessageConverter() \{  
        ProtobufHttpMessageConverter protobufHttpMessageConverter = new ProtobufHttpMessageConverter();  
        protobufHttpMessageConverter.setSupportedMediaTypes(Lists.newArrayList(MediaType.APPLICATION\_JSON,MediaType.parseMediaType(MediaType.TEXT\_PLAIN\_VALUE + ";charset=ISO-8859-1")));  
        return new HttpMessageConverters(protobufHttpMessageConverter);  
    \}