javagolang服务端_googlegrpc框架的编译及夸语言调用(c++服务端,java客户端)

1. 如何获取grpc框架源码

源码可以去github获取&＃xff1a;https://github.com/grpc/grpc

2. 如何编译

2.1 环境

Golang编译工具&＃xff0c;源代码编译(非必须)

下载地址&＃xff1a;https://www.golangtc.com/download

Perl编译工具&＃xff0c;源代码编译(非必须)

下载地址&＃xff1a;http://www.perl.org/get.html

VS2015 源代码编译&＃xff0c;也就是工程构建后&＃xff0c;用vs2015打开解决方案&＃xff0c;然后进行编译

CMake&＃xff0c;用于工程配置&＃xff0c; 这个很重要&＃xff0c;用来构建工程的&＃xff0c;必须的。

下载地址&＃xff1a;https://cmake.org/download/

2.2  编译

2.2.1  由于下载grpc源码后&＃xff0c;一些模块源码是缺少的&＃xff0c;需要单独下载&＃xff0c;具体可以参考文件.gitmodules&＃xff0c; 截图如下&＃xff1a;

一般来说主要下载模块有&＃xff1a;zlib,protobuf, gflags, boringssl, benchmark,c-ares , 如下图&＃xff1a;

2.2.2  项目配置和生成vs2015项目

注意&＃xff1a;如果有错误产生&＃xff0c;需要看下具体原因&＃xff0c;逐个排除即可。

最终生成的vs2015解决方案及若干项目&＃xff0c;如下图&＃xff1a;

此后&＃xff1a;我们可以生成我们需要的项目模块目标文件即可。

3. 夸语言调用

grpc 可以跨语言调用&＃xff0c;例如&＃xff1a;c&＃43;&＃43;,java,go等等&＃xff0c;服务端的开发语言和客户端可有不一样&＃xff0c;但是需要定义好协议&＃xff0c;一般来说&＃xff0c;我们定义一个proto文件&＃xff0c;里面描述了大体的数据结构。

3.1 定义proto协议

说明&＃xff1a;本协议其实就是求2个数的和&＃xff0c;接口为Add

3.2 c&＃43;&＃43; 服务端

生成相关c&＃43;&＃43;文件&＃xff0c;截图如下&＃xff1a;

protoc --cpp_out&＃61;. calculator.proto

protoc.exe --grpc_out&＃61;. --plugin&＃61;protoc-gen-grpc&＃61;grpc_cpp_plugin.exe calculator.proto

需要拷贝生成的文件到服务端工程目录下&＃xff1a;

需要导入相关lib库&＃xff1a;

address_sorting.lib;cares.lib;crypto.lib;gpr.lib;grpc.lib;grpc&＃43;&＃43;.lib;libprotobufd.lib;ssl.lib;zlibd.lib;zlibstaticd.lib;Ws2_32.lib;upb.lib;

相关服务端代码&＃xff1a;

#include "stdafx.h"

#include "calculator.grpc.pb.h"

#include "grpc&＃43;&＃43;/grpc&＃43;&＃43;.h"

class CalcualtorService : public calc::Caltulator::Service

{

// 构造、析构

public:

// 接口实现

public:

virtual ::grpc::Status Add(::grpc::ServerContext* context,

const ::calc::Request* request, ::calc::Response* response) override

{

response->set_sum(request->a() &＃43; request->b());

return grpc::Status::OK;

}

};

int main()

{

std::string server_address("0.0.0.0:50051");

CalcualtorService service;

grpc::ServerBuilder builder;

builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());

builder.RegisterService(&service);

std::unique_ptr<:server> server(builder.BuildAndStart());

std::cout <<"Server listening on " <

server->Wait();

return 0;

}

3.3 java 客户端

3.1需要相关的jar包

3.2  利用工具根据proto文件生成java代码&＃xff1a;

3.3  代码如下&＃xff1a;

3.31. 定义CalculateService 类

package sample;

import io.grpc.ManagedChannel;

import io.grpc.ManagedChannelBuilder;

import java.util.concurrent.TimeUnit;

import io.grpc.StatusRuntimeException;

import io.grpc.netty.NegotiationType;

import io.grpc.netty.NettyChannelBuilder;

import java.util.logging.Level;

import java.util.logging.Logger;

public class CalculateService {

private ManagedChannel channel;

private calc.CaltulatorGrpc.CaltulatorBlockingStub blockingStub &＃61; null;

private CalculateService(ManagedChannel channel) {

this.channel &＃61; channel;

blockingStub &＃61; calc.CaltulatorGrpc.newBlockingStub(channel);

}

public CalculateService(String host, int port) {

//this(ManagedChannelBuilder.forAddress(host, port)

//      .usePlaintext()

//      .build());

channel &＃61; NettyChannelBuilder.forAddress(host, port).negotiationType(NegotiationType.PLAINTEXT).build();

}

public void shutdown() throws InterruptedException {

channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);

}

public int operate(int num1, int num2) {

calc.Calculator.Request request&＃61; calc.Calculator.Request.newBuilder().setA(num1).setB(num2).build();

calc.Calculator.Response response&＃61; blockingStub.add(request);

return (int) response.getSum();

}

}

3.3.2  调用代码如下&＃xff1a;

CalculateService service&＃61; new CalculateService("localhost", 50051);System.out.println(service.operate(100, 1));

结束语&＃xff1a; 如果需要相关代码及编译调试遇到问题&＃xff0c;可以联系我们&＃xff0c; 2736483347&＃64;qq.com

有疑问加站长微信联系(非本文作者)