Dubbo Golang快速开发Rpc服务

server/2024/11/25 20:37:29/

开发 RPC Server & RPC Client

基于 Dubbo 定义的 Triple 协议,你可以轻松编写浏览器、gRPC 兼容的 RPC 服务,并让这些服务同时运行在 HTTP/1 和 HTTP/2 上。Dubbo Go SDK 支持使用 IDL 或编程语言特有的方式定义服务,并提供一套轻量的 API 来发布或调用这些服务。

本示例演示了基于 Triple 协议的 RPC 通信模式,示例使用 Protocol Buffer 定义 RPC 服务,并演示了代码生成、服务发布和服务访问等过程。

前置条件

因为使用 Protocol Buffer 的原因,我们首先需要安装相关的代码生成工具,这包括 protocprotoc-gen-goprotoc-gen-go-triple

  1. 安装 protoc

    查看 Protocol Buffer Compiler 安装指南

  2. 安装 protoc 插件

    接下来,我们安装插件 protoc-gen-goprotoc-gen-go-triple

    go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
    go install dubbo.apache.org/dubbo-go/v3/cmd/protoc-gen-go-triple@v3.0.1
    

    确保 protoc-gen-goprotoc-gen-go-triple 在你的 PATH 中。这可以通过 which protoc-gen-go 验证,如果该命令不能正常工作的话,请执行以下命令:

    [ -n "$(go env GOBIN)" ] && export PATH="$(go env GOBIN):${PATH}"
    [ -n "$(go env GOPATH)" ] && export PATH="$(go env GOPATH)/bin:${PATH}"
    

快速运行示例

下载示例源码

我们在 apache/dubbo-go-samples 仓库维护了一系列 dubbo-go 使用示例,用来帮助用户快速学习 dubbo-go 使用方式。

你可以 下载示例zip包并解压,或者克隆仓库:

$ git clone --depth 1 https://github.com/apache/dubbo-go-samples

切换到快速开始示例目录:

$ cd dubbo-go-samples/helloworld

运行 server

在 go-server/cmd 目录:

运行以下命令,启动 server:

$ go run server.go

使用 cURL 验证 server 已经正常启动:

$ curl \--header "Content-Type: application/json" \--data '{"name": "Dubbo"}' \http://localhost:20000/greet.GreetService/GreetGreeting: Hello world

运行 client

打开一个新的 terminal,运行以下命令,在 go-client/cmd 目录运行以下命令,启动 client

$ go run client.goGreeting: Hello world

以上就是一个完整的 dubbo-go RPC 通信服务开发过程。

源码讲解

接下来,我们将对 dubbo-go-samples/helloworld 示例进行源码层面的讲解。

定义服务

示例使用 Protocol Buffer (IDL) 来定义 Dubbo 服务。

syntax = "proto3";package greet;
option go_package = "github.com/apache/dubbo-go-samples/helloworld/proto;greet";message GreetRequest {string name = 1;
}message GreetResponse {string greeting = 1;
}service GreetService {rpc Greet(GreetRequest) returns (GreetResponse) {}
}

这个文件声明了一个叫做 GreetService 的服务,为这个服务定义了 Greet 方法以及它的请求参数 GreetRequest 和返回值 GreetResponse。

生成代码

在运行 server 或者 client 之前,我们需要使用 protoc-gen-goprotoc-gen-go-triple 生成相关的代码

protoc --go_out=. --go_opt=paths=source_relative \--go-triple_out=. --go-triple_opt=paths=source_relative \./greet.proto

运行以上命令后,在目标目录中看到以下生成的文件:

 proto├── greet.pb.go├── greet.proto└── greet.triple.go

在 proto/greet/v1 包下有两部分内容:

  • greet.pb.go 是由谷歌标准的 protoc-gen-go生成,它包含 GreetRequestGreetResponse 结构体和响应的编解码规则。
  • greet.triple.go 是由 Dubbo 自定义的插件protoc-gen-go-triple成,其中关键的信息包括生成的接口 GreetService、构造器等。

实现服务

接下来我们就需要添加业务逻辑了,实现 greet.GreetService 接口即可。

type GreetTripleServer struct {
}func (srv *GreetTripleServer) Greet(ctx context.Context, req *greet.GreetRequest) (*greet.GreetResponse, error) {resp := &greet.GreetResponse{Greeting: req.Name}return resp, nil
}

启动 Server

创建一个新的 Server,把我们上一步中实现的 GreeterServer注册给它,接下来就可以直接初始化和启动 Server 了,它将在指定的端口接收请求。

func main() {srv, err := server.NewServer(server.WithServerProtocol(protocol.WithPort(20000),protocol.WithTriple(),),)if err != nil {panic(err)}if err := greet.RegisterGreetServiceHandler(srv, &GreetTripleServer{}); err != nil {panic(err)}if err := srv.Serve(); err != nil {logger.Error(err)}
}

访问服务

最简单方式是使用 HTTP/1.1 POST 请求访问服务,参数则作以标准 JSON 格式作为 HTTP 负载传递。如下是使用 cURL 命令的访问示例:

curl \--header "Content-Type: application/json" \--data '{"name": "Dubbo"}' \http://localhost:20000/greet.GreetService/Greet

也可以使用 Dubbo client 请求服务,我们首先需要从生成代码即 greet 包中获取服务代理,为它指定 server 地址并初始化,之后就可以发起 RPC 调用了。

func main() {cli, err := client.NewClient(client.WithClientURL("127.0.0.1:20000"),)if err != nil {panic(err)}svc, err := greet.NewGreetService(cli)if err != nil {panic(err)}resp, err := svc.Greet(context.Background(), &greet.GreetRequest{Name: "hello world"})if err != nil {logger.Error(err)}logger.Infof("Greet response: %s", resp.Greeting)
}

以上即是 dubbo-go rpc 的基本工作原理!

 


http://www.ppmy.cn/server/144888.html

相关文章

Selenium 使用指南:从基础到反爬虫的实践

掌握Selenium 文章目录 掌握Selenium复杂动态网页解决方案Selenium简介Selenium chromedriver 安装打开自动化浏览器初始化机器人访问url——browser.get(url)全屏打开网页——browser.maximize_window()关闭窗口——browser.close()指定selenium参数需要的库网页元素定位获取…

oracle的静态注册和动态注册

oracle的静态注册和动态注册 静态注册: 静态注册 : 指将实例的相关信息手动告知 listener 侦 听 器 , 可以使用netmgr,netca,oem 以及直接 vi listener.ora 文件来实现静态注册,在动态注册不稳定时使用,特点是:稳定&…

ssm基于bs的企业合同管理系统

摘要 企业合同管理系统是一种旨在帮助企业高效管理各类合同的软件工具。该系统能够实现合同的电子化存储、快速检索和版本控制,简化审批流程。通过这一系统,企业能够确保合同执行的合规性,降低法律风险,同时提升工作效率和管理水…

URL在线编码解码- 加菲工具

URL在线编码解码 打开网站 加菲工具 选择“URL编码解码” 输入需要编码/解码的内容,点击“编码”/“解码”按钮 编码: 解码: 复制已经编码/解码后的内容。

postman 调用 下载接口(download)使用默认名称(response.txt 或随机名称)

官网地址:https://www.postman.com 介绍 Postman 是一款流行的 API 开发和测试工具,用于发送 HTTP 请求、测试接口、调试服务器响应以及进行 API 文档管理。它支持多种请求类型(如 GET、POST、PUT、DELETE 等),并且功能…

力扣题解3248 矩阵中的蛇(简单)

Problem: 3248. 矩阵中的蛇 文章目录 题目重述关键词提取解题思路分析算法思维模式代码分析时间复杂度分析空间复杂度分析 题目重述 给定一个大小为 ( n x n ) 的矩阵 grid,其中每个单元格的标识由公式 grid[i][j] (i * n) j 计算得出。蛇从矩阵的起始位置&#…

Java项目实战II基于微信小程序的南宁周边乡村游平台(开发文档+数据库+源码)

目录 一、前言 二、技术介绍 三、系统实现 四、文档参考 五、核心代码 六、源码获取 全栈码农以及毕业设计实战开发,CSDN平台Java领域新星创作者,专注于大学生项目实战开发、讲解和毕业答疑辅导。获取源码联系方式请查看文末 一、前言 随着城市化…

初识ArkUI

ArkUI简介: ArkUI(方舟UI框架)为应用的UI开发提供了完整的基础设施,包括简洁的UI语法、丰富的UI功能(组件、布局、动画以及交互事件),以及实时界面预览工具等,可以支持开发者进行可视化界面开发…