Dubbo Golang快速开发Rpc服务

news/2024/11/28 14:29:10/

开发 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/news/1550638.html

相关文章

23种设计模式-生成器(Builder)设计模式

文章目录 一.什么是生成器设计模式?二.生成器模式的特点三.生成器模式的结构四.生成器模式的优缺点五.生成器模式的 C 实现六.生成器模式的 Java 实现七.代码解析八. 总结 类图: 生成器设计模式类图 一.什么是生成器设计模式? 生成器模式&am…

外卖点餐系统小程序

目录 开发前准备 项目展示项目分析项目初始化封装网络请求 任务1 商家首页 任务分析焦点图切换中间区域单击跳转到菜单列表底部商品展示 任务2 菜单列表 任务分析折扣信息区设计菜单列表布局请求数据实现菜单栏联动单品列表功能 任务3 购物车 任务分析设计底部购物车区域添加商…

如何用通义灵码快速绘制流程图?

使用通义灵码快速绘制流程图?新功能体验 不想读前人“骨灰级”代码,不想当“牛马”程序员,想像看图片一样快速读复杂代码和架构? 通义灵码已经支持代码逻辑可视化,可以把你的每段代码画成流程图。像个脑图工具一样帮你…

深度学习 | 什么是知识图谱

来源 2012年5月17日,Google 正式提出了知识图谱(Knowledge Graph)的概念,其初衷是为了优化搜索引擎返回的结果,增强用户搜索质量及体验。 实际上,知识图谱并不是一个全新的概念,早在 2006 年就有文献提出了语义网(Sema…

Hbase 部署

HBase是一个分布式的、面向列的开源数据库,它是Apache Hadoop项目的子项目。为了成功部署HBase,可以按照以下步骤进行: 主机部署 一、准备环节 设备基本要求: Hadoop和ZooKeeper:HBase集群需要依赖Hadoop和Zookeepe…

Linux介绍与安装指南:从入门到精通

1. Linux简介 1.1 什么是Linux? Linux是一种基于Unix的操作系统,由Linus Torvalds于1991年首次发布。Linux的核心(Kernel)是开源的,允许任何人自由使用、修改和分发。Linux操作系统通常包括Linux内核、GNU工具集、图…

【H2O2|全栈】JS进阶知识(十一)axios入门

目录 前言 开篇语 准备工作 获取 介绍 使用 结束语 前言 开篇语 本系列博客主要分享JavaScript的进阶语法知识,本期主要对axios进行基本的了解。 与基础部分的语法相比,ES6的语法进行了一些更加严谨的约束和优化,因此,在…

网络基础 - 地址篇

一、IP 地址 IP 协议有两个版本,IPv4 和 IPv6IP 地址(IPv4 地址)是一个 4 字节,32 位的正整数,通常使用 “点分十进制” 的字符串进行表示,例如 192.168.0.1,用点分割的每一个数字表示一个字节,范围是 0 ~…