第GoLang與Java各自生成grpc代碼流程介紹目錄1.背景2.go生成grpc代碼2.1安裝2.2安裝對(duì)應(yīng)插件3.java生成grpc代碼3.1idea安裝protobuf插件3.2創(chuàng)建maven項(xiàng)目3.3生成grpc代碼

1.背景

由于公司的日志系統(tǒng)使用的是plumelog，最近生產(chǎn)環(huán)境老是報(bào)jedis連接池不夠，導(dǎo)致丟失日志，而且服務(wù)老是重啟，懷疑跟日志系統(tǒng)有關(guān)，于是自己改造plumelog，使用gogrpc生成server端，使用javagrpc生成客戶端，將日志以grpc服務(wù)形式傳遞到server端。

2.go生成grpc代碼

2.1安裝

protc：/protocolbuffers/protobuf/releases

選擇自己所需版本，解壓后將protoc.exe拷貝至go環(huán)境的bin目錄下

2.2安裝對(duì)應(yīng)插件

goinstall/protobuf/cmd/protoc-gen-go@v1.28

goinstall/grpc/cmd/protoc-gen-go-grpc@v1.2

將生成的插件拷貝至go環(huán)境的bin目錄下

編寫(xiě).proto文件：

syntax="proto3";

//指定等會(huì)文件生成出來(lái)的package

packageserver;

optiongo_package="plumelog/rpc;server";

//定義requestmodel

messagePlumelogRequest{

stringmessage=1;//1代表順序

//定義responsemodel

messagePlumelogResponse{

stringmessage=1;//1代表順序

//定義服務(wù)主體

servicePlumelogService{

//定義方法

rpcGetPlumelog(PlumelogRequest)returns(PlumelogResponse);

}

項(xiàng)目結(jié)構(gòu)圖：

在終端cd到proto目錄下，執(zhí)行如下命令生成grpc代碼：

protoc--go_out=plugins=grpc:.to

server端：

main.go：

import(

"/grpc"

"log"

"net"

"plumelog/rpc"

"plumelog/server"

funcmain(){

//1.new一個(gè)grpc的server

rpcServer:=grpc.NewServer()

//2.將剛剛我們新建的ProdService注冊(cè)進(jìn)去

rpc.RegisterPlumelogServiceServer(rpcServer,new(server.RpcServer))

//3.新建一個(gè)listener，以tcp方式監(jiān)聽(tīng)8899端口

listener,err:=net.Listen("tcp",":8899")

iferr!=nil{

log.Fatal("服務(wù)監(jiān)聽(tīng)端口失敗",err)

//4.運(yùn)行rpcServer，傳入listener

_=rpcServer.Serve(listener)

}

server.go

packageserver

import(

"context"

"plumelog/rpc"

typeRpcServerstruct{

varpushProducer*plumelog.Producer

func(*RpcServer)GetProductStock(ctxcontext.Context,req*rpc.PlumelogRequest)(*rpc.PlumelogResponse,error){

fmt.Println(req.Message)

returnrpc.PlumelogResponse{Message:req.Message},nil

}

3.java生成grpc代碼

3.1idea安裝protobuf插件

3.2創(chuàng)建maven項(xiàng)目

pom.xml:

xmlversion="1.0"encoding="UTF-8"

projectxmlns="/POM/4.0.0"xmlns:xsi="/2001/XMLSchema-instance"

xsi:schemaLocation="/POM/4.0.0/xsd/maven-4.0.0.xsd"

parent

groupIdcom.plumelog/groupId

artifactIdplumelog/artifactId

version3.5/version

/parent

modelVersion4.0.0/modelVersion

artifactIdplumelog-logback/artifactId

nameplumelog-logback/name

packagingjar/packaging

dependencies

dependency

groupIdch.qos.logback/groupId

artifactIdlogback-core/artifactId

version1.2.3/version

/dependency

dependency

groupIdch.qos.logback/groupId

artifactIdlogback-classic/artifactId

version1.2.3/version

/dependency

dependency

groupIdcom.plumelog/groupId

artifactIdplumelog-core/artifactId

version${project.parent.version}/version

/dependency

dependency

groupIdtobuf/groupId

artifactIdprotobuf-java/artifactId

version3.5.1/version

/dependency

!--/artifact/tobuf/protobuf-java-util--

dependency

groupIdtobuf/groupId

artifactIdprotobuf-java-util/artifactId

version3.5.1/version

/dependency

!--/artifact/io.grpc/grpc-all--

dependency

groupIdio.grpc/groupId

artifactIdgrpc-all/artifactId

version1.12.0/version

/dependency

dependency

groupIdjavax.annotation/groupId

artifactIdjavax.annotation-api/artifactId

version1.3.2/version

scopecompile/scope

/dependency

dependency

groupIdjavax.annotation/groupId

artifactIdjavax.annotation-api/artifactId

version1.3.2/version

scopecompile/scope

/dependency

dependency

groupIdjavax.annotation/groupId

artifactIdjavax.annotation-api/artifactId

version1.3.2/version

scopecompile/scope

/dependency

/dependencies

build

plugins

!--依賴包插件--

plugin

groupIdorg.apache.maven.plugins/groupId

artifactIdmaven-dependency-plugin/artifactId

executions

execution

idcopy-dependencies/id

phasepackage/phase

goals

goalcopy-dependencies/goal

/goals

configuration

outputDirectory${project.build.directory}/lib/outputDirectory

!--是否不包含間接依賴--

excludeTransitivefalse/excludeTransitive

!--忽略版本--

stripVersionfalse/stripVersion

/configuration

/execution

/executions

/plugin

plugin

groupIdorg.xolstice.maven.plugins/groupId

artifactIdprotobuf-maven-plugin/artifactId

version0.5.0/version

configuration

protocArtifact

tobuf:protoc:3.1.0:exe:${os.detected.classifier}

/protocArtifact

pluginIdgrpc-java/pluginId

pluginArtifact

io.grpc:protoc-gen-grpc-java:1.11.0:exe:${os.detected.classifier}

/pluginArtifact

/configuration

!--executions--

!--execution--

!--goals--

!--goalcompile/goal--

!--goalcompile-custom/goal--

!--/goals--

!--/execution--

!--/executions--

/plugin

/plugins

extensions

extension

groupIdkr.motd.maven/groupId

artifactIdos-maven-plugin/artifactId

version1.6.2/version

/extension

/extensions

/build

/project

maven插件：

3.3生成grpc代碼

//這個(gè)就是protobuf的中間文件

//指定的當(dāng)前proto語(yǔ)法的版本，有2和3

syntax="proto3";

//指定等會(huì)文件生成出來(lái)的package

packageserver;

optionjava_package="com.plumelog.logback.rpc";

optionjava_multiple_files=false;

optionjava_outer_classname="RpcClient";

//定義requestmodel

messagePlumelogRequest{

stringmessage=1;//1代表順序

//定義responsemodel

messagePlumelogResponse{

stringmessage=1;//1代表順序

//定義服務(wù)主體

servicePlumelogService{

//定義方法

rpcGetPlumelog(PlumelogRequest)returns(PlumelogResponse);

}

ps：指定的package要與go那邊的proto指定的package一致，否則啟動(dòng)報(bào)找不到rpc服務(wù)

雙擊maven插件的protobuf:complie生成rpc代碼，雙擊maven插件的protobuf:custom生成grpc代碼

調(diào)用：

privateStringrpcHost="";

privateintrpcPort=8899;

ManagedChannelchannel=ManagedChannelBuilder.forAddress(rpcHost,rpcPort).usePlaintext().build();

@Override

protectedvoidappend(ILoggingEventevent){

if(event!=null){

send(event);

protectedvoidsend(ILoggingEventevent){

finalBaseLogMessagelogMessage=LogMessageUtil.getLogMessage(appName,env,event);

if(logMessageinstanceofRunLogMessage){