Dubbo Golang快速开发Rpc服务

devtools/2024/11/25 10:14:31/

开发 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/devtools/136811.html

相关文章

【计算机网络】IP协议

一、IP协议的功能 提供将数据从A主机跨网络送到主机B的能力 (在复杂的网络环境中确定一个合适的路径) 二、IP协议格式 ​​​​​​​1.报头的含义 (1)一般字段 ① 4位版本:指定IP协议的版本,对于IPv4来说就是4 ② 4位首部长度…

定时/延时任务-Timer用法

文章目录 1. 概要2. 简述2.1 固定速率2.2 固定延时2.3 区别 3. Timer 的用法3.1 固定延时 - public void schedule(TimerTask task, long delay, long period)3.1.1 解释 3.2 固定延时 - public void schedule(TimerTask task, Date firstTime, long period)3.3 固定速率 - pub…

mfc100u.dll是什么?分享几种mfc100u.dll丢失的解决方法

mfc100u.dll 是一个动态链接库(DLL)文件,属于 Microsoft Foundation Classes (MFC) 库的一部分。MFC 是微软公司开发的一套用于快速开发 Windows 应用程序的 C 类库。mfc100u.dll 文件包含了 MFC 库中一些常用的函数和类的定义,这…

C++设计模式:建造者模式(Builder) 房屋建造案例

什么是建造者模式? 建造者模式是一种创建型设计模式,它用于一步步地构建一个复杂对象,同时将对象的构建过程与它的表示分离开。简单来说: 它将复杂对象的“建造步骤”分成多部分,让我们可以灵活地控制这些步骤。通过…

设计模式-创建型-建造者模式

1.概念 建造者设计模式(Builder Design Pattern)是一种创建型设计模式,它通过将一个复杂对象的构建过程与它的表示分离,使得同样的构建过程可以创建不同的表示。 2.作用 用于简化对复杂对象的创建 3.应用场景 当我们有一个非…

P1 练习卷(C++4道题)

1.纷繁世界 内存限制:256MB 时间限制:1s 问题描述 这是一个纷繁复杂的世界。 某一天清晨你起床很迟,没有吃上早饭。于是你骑着自行车去超市,但是你又发现商店的工作人员已经重新贴上了价格标签,零食价格都涨了50%。你…

Redis核心数据结构与高性能原理

一、Redis安装 下载地址:http://redis.io/download 安装步骤: # 安装gcc yum install gcc# 把下载好的redis-5.0.3.tar.gz放在/usr/local文件夹下,并解压 wget http://download.redis.io/releases/redis-5.0.3.tar.gz tar -zxvf redis-5.0.3…

深入理解 prompt提示词 原理及使用技巧

引言 在现代深度学习和人工智能领域,文本到图像生成模型(如 Stable Diffusion、DALL-E 等)已经取得了显著的进展。这些模型能够根据给定的文本提示词生成高质量的图像,极大地拓展了创意设计和艺术创作的可能性。然而,…