go-zero(七) RPC服务和ETCD使用

go zero RPC和ETCD

在现实的开发中，微服务通常是分布式的，每个服务运行在独立的历程中，乃至大概在差别的服务器上。RPC答应这些服务以透明的方式相互调用方法，就像在当地调用一样，从而简化了服务间的通讯。
RPC使调用者不须要关注服务的实现细节，只需知道接口，更方便协作编程 ，多数RPC框架可以大概根据服务界说主动天生客户端代码，淘汰了人为错误并加速了开发过程。
RPC可以比传统的HTTP/REST更快地举行数据互换，这在须要高性能和低耽误的微服务体系中尤为告急
一、API和RPC

1.API 和 RPC 的关系

API和RPC是两种差别的服务交互模式，分别用于处理处罚HTTP哀求和服务间的远程调用。

  

• API（应用步伐编程接口）:
  
     
  
  • API通常用于袒露微服务的HTTP接口，答应客户端（如前端应用）通过HTTP哀求与微服务举行交互。   
    
  • API重要处理处罚用户哀求，举行输入验证、路由、HTTP状态码处理处罚等。   
    
     
  
• RPC（远程过程调用）:
  
     
  
  • RPC用于微服务之间的直接调用，通常通过协议（如gRPC）举行通讯。   
    
  • RPC更得当于内部服务之间的高效交互，特殊是在须要低耽误和高吞吐量的场景中。   
    
    
  

2.API 文件与 Proto 文件的约定

在项目开发中，API界说和RPC界说应保持肯定的约定，以确保服务的同等性和可维护性：

  

• 接口界说同等性：
  
     
  
  • API层和RPC层应只管保持同等的接口，比如在API层界说的哀求和相应布局体，RPC层也应使用类似或相似的布局体。这有助于低落服务侵入和明白本钱。   
    
     
  
• 数据布局的映射：
  
     
  
  • 当API哀求到达时，通常须要将HTTP哀求参数映射到RPC调用的参数。此时，可以界说一个公共的哀求和相应数据布局，以淘汰重复界说和维护本钱。   
    
     
  
• 错误处理处罚同等性：
  
     
  
  • 在API和RPC之间应保持类似的错误处理处罚逻辑，以便在发生错误时可以大概提供同等的错误相应。   
    
    
  

3.示例约定

  

• **API 文件（.api）**示例：
  1. # 文件: user.api
  2. service user-api {
  3.      
  4.      
  5.     @server(
  6.         rest: {
  7.      
  8.      
  9.             path: /users,
  10.             method: POST
  11.         }
  12.     )
  13.     register(req RegisterRequest) returns (RegisterResponse);
  15.     @server(
  16.         rest: {
  17.      
  18.      
  19.             path: /users/{
  20.      
  21.      id},
  22.             method: GET
  23.         }
  24.     )
  25.     getUser(id int64) returns (GetUserResponse);
  26. }
  28. message RegisterRequest {
  29.      
  30.      
  31.     string name = 1;
  32.     int32 age = 2;
  33. }
  35. message RegisterResponse {
  36.      
  37.      
  38.     int64 id = 1;
  39. }
  41. message GetUserResponse {
  42.      
  43.      
  44.     string name = 1;
  45.     int32 age = 2;
  46. }

  复制代码
  
  

3. **Proto 文件（.proto）**示例：
4.   ```protobuf
5.   syntax = "proto3";
7.   package user;
9.   service UserService {
10.    
11.    
12.       rpc Register(RegisterRequest) returns (RegisterResponse);
13.       rpc GetUser(GetUserRequest) returns (GetUserResponse);
14.   }
16.   message RegisterRequest {
17.    
18.    
19.       string name = 1;
20.       int32 age = 2;
21.   }
23.   message RegisterResponse {
24.    
25.    
26.       int64 id = 1;
27.   }
29.   message GetUserRequest {
30.    
31.    
32.       int64 id = 1;  // 请求者根据ID获取用户信息
33.   }
35.   message GetUserResponse {
36.    
37.    
38.       string name = 1;
39.       int32 age = 2;
40.   }

复制代码

下面我将通过一个简朴的示例，分析怎样使用go zero框架和 Protocol Buffers 界说 RPC 服务。
二、天生 RPC代码

在这个教程中，我们根据user.api文件，来编写一个user.proto 文件，创建一个用户管理的 RPC 服务.
1.回顾user.api

go zero的 API 文件通常界说 HTTP 接口，包罗哀求和相应的格式。它重要用于 RESTful API 的界说。
我们先来回顾下之前的user.api文件

1. type (
2.         RegisterRequest {
3.    
4.    
5.                 Username string `json:"username" validate:"required"` // 注册请求，用户名
6.                 Password string `json:"password" validate:"required"` // 注册请求，密码
7.         }
8.         RegisterResponse {
9.    
10.    
11.                 Message string `json:"message"` // 响应消息
12.         }
13. )
15. type (
16.         LoginRequest {
17.    
18.    
19.                 Username string `json:"username" validate:"required"` // 登录请求，用户名
20.                 Password string `json:"password" validate:"required"` // 登录请求，密码
21.         }
22.         LoginResponse {
23.    
24.    
25.                 Token string `json:"token"` // 登录响应，JWT token
26.         }
27. )
29. @server (
30.         group:  user // 代表当前 service 代码块下的路由生成代码时都会被放到 user 目录下
31.         prefix: /v1 //定义路由前缀为 "/v1"
32. )
33. // 微服务名称为 user-ap，生成的代码目录和配置文件将和 user 值相关
34. service user-api {
35.    
36.    
37.         //用户注册
38.         @handler RegisterHandler
39.         //提交post请求   RegisterRequest为请求体  RegisterResponse为响应体
40.         post /register (RegisterRequest) returns (RegisterResponse)
42.         //用户登录
43.         @handler LoginHandler
44.         post /login (LoginRequest) returns (LoginResponse)
45. }
47. //因为我们想要通过jwt来传递数据，所以我们不需求请求信息
48. type (
49.         GetInfoResponse {
50.    
51.    
52.                 Username string `json:"username" `
53.                 Password string `json:"password" `
54.         }
55. )
57. //更新数据我们就简单修改下密码
58. type (
59.         UpdataRequest {
60.    
61.    
62.                 Password string `json:"password" ` // 更新请求，新的密码
63.         }
64.         UpdataResponse {
65.    
66.    
67.                 Message string `json:"message"` // 更新响应消息
68.         }
69. )
71. @server (
72.         group:  user
73.         prefix: /v1
74.         jwt:    Auth //开启jwt
75. )
76. service user-api {
77.    
78.    
79.         @handler GetInfoHandler
80.         // 不需要请求信息
81.         post /getinfo returns (GetInfoResponse)
83.         @handler UpdataHandler
84.         post /updata (UpdataRequest) returns (UpdataResponse)
85. }

复制代码

2. 创建user.proto 文件

Proto 文件，用于界说 gRPC 服务和消息格式。它重要用于远程过程调用（RPC），使用 Protocol Buffers 举行数据序列化。
根据user.api文件创建user.proto文件:

1. syntax = "proto3";  //声明使用 Protocol Buffers 的版本为 3
3. //proto 包名
4. package pb;
5. //生成 golang 代码后的包名
6. option go_package ="./pb";  //必须要有“./” 这样的路径
7. //指定生成的 Go 代码的包名为 pb，在同一目录下创建一个名为 pb 的包
9. //定义用户消息结构
10. message Users {
11.    
12.    
13.   int64

复制代码