当前位置：首页 > news >正文

eRPC消息协议完全指南：从rawproto到HTTP兼容协议

news 2026/6/2 19:17:17

eRPC消息协议完全指南：从rawproto到HTTP兼容协议

【免费下载链接】erpcAn efficient, extensible and easy-to-use RPC framework.项目地址: https://gitcode.com/gh_mirrors/er/erpc

eRPC是一个高效、可扩展且易用的RPC框架，提供了多种消息协议支持，从原始二进制协议到HTTP兼容协议，满足不同场景的通信需求。本文将详细介绍eRPC支持的各类消息协议，帮助开发者快速选择和使用适合的协议进行通信。

eRPC协议架构概览

eRPC的协议系统采用模块化设计，允许开发者根据需求灵活选择和扩展协议。框架核心通过插件化机制支持多种协议实现，包括原始二进制协议、JSON协议、Protobuf协议、Thrift协议以及HTTP兼容协议等。

图1：eRPC框架架构图，展示了协议层在整体架构中的位置

eRPC的协议模块主要位于proto/目录下，包含以下子模块：

proto/rawproto/：原始二进制协议实现
proto/jsonproto/：JSON协议实现
proto/pbproto/：Protobuf协议实现
proto/thriftproto/：Thrift协议实现
proto/httproto/：HTTP兼容协议实现

核心协议类型及应用场景

1. rawproto：高性能原始二进制协议

rawproto是eRPC中最基础的协议，采用二进制编码格式，具有极高的性能和极低的开销。适用于对性能要求严格、数据传输量大的内部服务通信场景。

rawproto协议的实现位于proto/rawproto/rawproto.go，其核心特点是：

固定长度的消息头
无额外数据格式开销
支持双向流传输
适合二进制数据传输

2. JSON协议：简单易用的文本协议

jsonproto提供了基于JSON的消息编码方式，便于调试和跨语言交互。适用于开发环境、简单API服务以及需要人类可读性的场景。

图2：eRPC数据消息结构示意图，展示了协议封装格式

JSON协议的实现位于proto/jsonproto/jsonproto.go，使用时只需在创建Peer时指定协议类型：

peer := erpc.NewPeer(erpc.PeerConfig{ DefaultProtoFunc: jsonproto.NewJSONProtoFunc, })

3. Protobuf协议：高效结构化数据传输

pbproto基于Google的Protobuf实现，提供强类型、高效的结构化数据传输。适用于需要严格数据格式定义和跨语言通信的场景。

Protobuf协议的定义文件位于proto/pbproto/pb/payload.proto，使用前需要通过protobuf编译器生成对应的Go代码。eRPC提供了便捷的代码生成脚本，可在examples/bench/msg/gen.sh中找到参考。

4. Thrift协议：多语言服务通信

thriftproto实现了Apache Thrift协议，支持多种编程语言间的高效通信。适用于已有Thrift服务或需要与其他语言服务交互的场景。

Thrift协议的实现位于proto/thriftproto/目录下，包含二进制协议和结构化协议两种实现方式。

5. HTTP兼容协议：Web服务集成

httproto提供了HTTP兼容的协议实现，允许eRPC服务与Web服务无缝集成。适用于需要通过HTTP协议暴露服务的场景。

HTTP协议的实现位于proto/httproto/httproto.go，支持标准HTTP方法和状态码，可直接与浏览器和HTTP客户端通信。

协议选择指南

选择合适的协议需要考虑以下因素：

性能要求：高性能场景优先选择rawproto或pbproto
跨语言需求：多语言环境优先选择pbproto或thriftproto
调试便利性：开发阶段可使用jsonproto或httproto
数据结构复杂度：复杂数据结构优先选择pbproto或thriftproto
网络环境：不稳定网络环境可考虑httproto（基于HTTP重试机制）

协议扩展与自定义

eRPC支持自定义协议扩展，只需实现proto.Proto接口并注册即可。自定义协议的实现可以参考proto/目录下的现有协议实现。

协议注册示例：

// 注册自定义协议 erpc.RegisterProto("myproto", func() proto.Proto { return NewMyProto() }) // 使用自定义协议 peer := erpc.NewPeer(erpc.PeerConfig{ DefaultProtoFunc: erpc.GetProtoFunc("myproto"), })

协议性能对比

不同协议在性能上存在差异，以下是eRPC官方提供的协议性能测试结果：

图3：eRPC协议性能对比图，展示了不同协议在消息传输中的性能表现

从测试结果可以看出，rawproto和pbproto在吞吐量和延迟方面表现最佳，适合高性能场景；jsonproto和httproto虽然性能稍低，但提供了更好的可读性和兼容性。

快速开始：使用eRPC协议

安装eRPC

go get github.com/erpc/erpc

简单示例：使用JSON协议

服务端代码：

package main import ( "github.com/erpc/erpc" "github.com/erpc/erpc/proto/jsonproto" ) func main() { peer := erpc.NewPeer(erpc.PeerConfig{ DefaultProtoFunc: jsonproto.NewJSONProtoFunc, }) peer.RouteCall(new(Hello)) peer.ListenAndServe("0.0.0.0:9090") } type Hello struct { erpc.CallCtx } func (h *Hello) Say(args string) (string, *erpc.Status) { return "Hello " + args, nil }

客户端代码：

package main import ( "fmt" "github.com/erpc/erpc" "github.com/erpc/erpc/proto/jsonproto" ) func main() { peer := erpc.NewPeer(erpc.PeerConfig{ DefaultProtoFunc: jsonproto.NewJSONProtoFunc, }) sess, err := peer.Dial("127.0.0.1:9090") if err != nil { panic(err) } var reply string err = sess.Call("/Hello/Say", "World", &reply).Status().Err() if err != nil { panic(err) } fmt.Println(reply) // 输出: Hello World }