Go gRPC教程-简单RPC（二）
<h3 id="前言">前言</h3><p>gRPC主要有4种请求和响应模式，分别是<code>简单模式(Simple RPC)</code>、<code>服务端流式（Server-side streaming RPC）</code>、<code>客户端流式（Client-side streaming RPC）</code>、和<code>双向流式（Bidirectional streaming RPC）</code>。</p>
<ul>
<li>
<p><code>简单模式(Simple RPC)</code>：客户端发起请求并等待服务端响应。</p>
</li>
<li>
<p><code>服务端流式（Server-side streaming RPC）</code>：客户端发送请求到服务器，拿到一个流去读取返回的消息序列。 客户端读取返回的流，直到里面没有任何消息。</p>
</li>
<li>
<p><code>客户端流式（Client-side streaming RPC）</code>：与服务端数据流模式相反，这次是客户端源源不断的向服务端发送数据流，而在发送结束后，由服务端返回一个响应。</p>
</li>
<li>
<p><code>双向流式（Bidirectional streaming RPC）</code>：双方使用读写流去发送一个消息序列，两个流独立操作，双方可以同时发送和同时接收。</p>
</li>
</ul>
<p>本篇文章先介绍简单模式。</p>
<h3 id="新建proto文件">新建proto文件</h3>
<p>主要是定义我们服务的方法以及数据格式，我们使用上一篇的simple.proto文件。</p>
<p>1.定义发送消息的信息</p>
<pre><code class="language-protobuf">message SimpleRequest{
// 定义发送的参数，采用驼峰命名方式，小写加下划线，如：student_name
string data = 1;//发送数据
}
</code></pre>
<p>2.定义响应信息</p>
<pre><code class="language-protobuf">message SimpleResponse{
// 定义接收的参数
// 参数类型 参数名 标识号(不可重复)
int32 code = 1;//状态码
string value = 2;//接收值
}
</code></pre>
<p>3.定义服务方法Route</p>
<pre><code class="language-protobuf">// 定义我们的服务（可定义多个服务,每个服务可定义多个接口）
service Simple{
rpc Route (SimpleRequest) returns (SimpleResponse){};
}
</code></pre>
<p>4.编译proto文件</p>
<p>我这里使用上一篇介绍的VSCode-proto3插件，保存后自动编译。</p>
<blockquote>
<p>指令编译方法，进入simple.proto文件所在目录，运行：<br>
<code>protoc --go_out=plugins=grpc:./ ./simple.proto</code></p>
</blockquote>
<h3 id="创建server端">创建Server端</h3>
<p>1.定义我们的服务，并实现Route方法</p>
<pre><code class="language-go">import (
"context"
"log"
"net"
"google.golang.org/grpc"
pb "go-grpc-example/proto"
)
// SimpleService 定义我们的服务
type SimpleService struct{}
// Route 实现Route方法
func (s *SimpleService) Route(ctx context.Context, req *pb.SimpleRequest) (*pb.SimpleResponse, error) {
res := pb.SimpleResponse{
Code:200,
Value: "hello " + req.Data,
}
return &res, nil
}
</code></pre>
<p>该方法需要传入RPC的上下文context.Context，它的作用结束<code>超时</code>或<code>取消</code>的请求。更具体的说请参考该文章</p>
<p>2.启动gRPC服务器</p>
<pre><code class="language-go">const (
// Address 监听地址
Address string = ":8000"
// Network 网络通信协议
Network string = "tcp"
)
func main() {
// 监听本地端口
listener, err := net.Listen(Network, Address)
if err != nil {
log.Fatalf("net.Listen err: %v", err)
}
log.Println(Address + " net.Listing...")
// 新建gRPC服务器实例
grpcServer := grpc.NewServer()
// 在gRPC服务器注册我们的服务
pb.RegisterSimpleServer(grpcServer, &SimpleService{})
//用服务器 Serve() 方法以及我们的端口信息区实现阻塞等待，直到进程被杀死或者 Stop() 被调用
err = grpcServer.Serve(listener)
if err != nil {
log.Fatalf("grpcServer.Serve err: %v", err)
}
}
</code></pre>
<p>里面每个方法的作用都有注释，这里就不解析了。<br>
运行服务端</p>
<pre><code class="language-powershell">go run server.go
:8000 net.Listing...
</code></pre>
<h3 id="创建client端">创建Client端</h3>
<pre><code class="language-go">import (
"context"
"log"
"google.golang.org/grpc"
pb "go-grpc-example/proto"
)
const (
// Address 连接地址
Address string = ":8000"
)
func main() {
// 连接服务器
conn, err := grpc.Dial(Address, grpc.WithInsecure())
if err != nil {
log.Fatalf("net.Connect err: %v", err)
}
defer conn.Close()
// 建立gRPC连接
grpcClient := pb.NewSimpleClient(conn)
// 创建发送结构体
req := pb.SimpleRequest{
Data: "grpc",
}
// 调用我们的服务(Route方法)
// 同时传入了一个 context.Context ，在有需要时可以让我们改变RPC的行为，比如超时/取消一个正在运行的RPC
res, err := grpcClient.Route(context.Background(), &req)
if err != nil {
log.Fatalf("Call Route err: %v", err)
}
// 打印返回值
log.Println(res)
}
</code></pre>
<p>运行客户端</p>
<pre><code class="language-powershell">go run client.go
code:200 value:"hello grpc"
</code></pre>
<p>成功调用Server端的Route方法并获取返回的数据。</p>
<h3 id="总结">总结</h3>
<p>本篇介绍了简单RPC模式，客户端发起请求并等待服务端响应。下篇将介绍<code>服务端流式RPC</code>.</p>
<p>教程源码地址：https://github.com/Bingjian-Zhu/go-grpc-example<br>
参考：gRPC官方文档中文版</p>
</div>
<div id="MySignature" role="contentinfo">
看完之后若觉得对自己有帮助，恳请点赞或评论。这是对我最大的鼓励！<br><br>
来源：https://www.cnblogs.com/FireworksEasyCool/p/12674120.html
頁:
[1]