先定义共享结构体，再分别实现UserService和OrderService的RPC通信。UserService监听8081提供用户查询，OrderService监听8082并调用UserService获取用户信息，客户端通过调用OrderService完成订单与用户数据聚合。
在Golang中实现多个服务间的RPC通信，可以通过标准库net/rpc轻松完成。下面是一个清晰的多服务间RPC通信示例，包含两个独立的服务（UserService和OrderService），它们通过RPC进行解耦通信。
1. 定义共享的数据结构与接口
为了支持跨服务调用，先定义共用的请求和响应结构体。这些结构可以放在一个独立的包中（如common），或直接复制到各服务中。
// common/types.gopackage commontype User struct { ID int Name string}type Order struct { ID int UserID int Product string}
2. UserService 提供用户查询功能
UserService对外暴露一个RPC方法GetUser，根据ID返回用户信息。
// user_service/server.gopackage mainimport ( "common" "log" "net" "net/rpc")type UserService struct{}func (s *UserService) GetUser(uid int, user *common.User) error { // 模拟数据库查找 userData := map[int]common.User{ 1: {ID: 1, Name: "Alice"}, 2: {ID: 2, Name: "Bob"}, } *user = userData[uid] return nil}func main() { rpc.Register(new(UserService)) listener, err := net.Listen("tcp", ":8081") if err != nil { log.Fatal("Listen error:", err) } defer listener.Close() log.Println("UserService 启动在 :8081") for { conn, _ := listener.Accept() go rpc.ServeConn(conn) }}
3. OrderService 调用 UserService 获取用户信息
OrderService在返回订单详情时，需要通过RPC向UserService查询关联的用户信息。
立即学习“go语言免费学习笔记（深入）”；
// order_service/server.gopackage mainimport ( "common" "log" "net" "net/rpc")type OrderService struct{}func (s *OrderService) GetOrder(oid int, reply *common.Order) error { // 模拟订单数据 orderData := map[int]common.Order{ 101: {ID: 101, UserID: 1, Product: "Laptop"}, 102: {ID: 102, UserID: 2, Product: "Phone"}, } *reply = orderData[oid] // 调用 UserService 获取用户信息 client, err := rpc.Dial("tcp", "127.0.0.1:8081") if err != nil { log.Printf("无法连接 UserService: %v", err) return nil } defer client.Close() var user common.User err = client.Call("UserService.GetUser", reply.UserID, &user) if err != nil { log.Printf("调用 GetUser 失败: %v", err) } else { log.Printf("订单 %d 关联用户: %s", reply.ID, user.Name) } return nil}func main() { rpc.Register(new(OrderService)) listener, err := net.Listen("tcp", ":8082") if err != nil { log.Fatal("Listen error:", err) } defer listener.Close() log.Println("OrderService 启动在 :8082") for { conn, _ := listener.Accept() go rpc.ServeConn(conn) }}
4. 客户端调用 OrderService
客户端只需访问OrderService，它会自动联动UserService完成数据聚合。
// client/main.gopackage mainimport ( "common" "log" "net/rpc")func main() { client, err := rpc.Dial("tcp", "127.0.0.1:8082") if err != nil { log.Fatal("Dial error:", err) } defer client.Close() var order common.Order err = client.Call("OrderService.GetOrder", 101, &order) if err != nil { log.Fatal("Call error:", err) } log.Printf("获取订单: %+v", order)}
运行顺序：
先启动user_service（监听8081）再启动order_service（监听8082）最后运行client发起请求
输出示例：
OrderService 日志： 订单 101 关联用户: Alice
Client 日志： 获取订单: {ID:101 UserID:1 Product:Laptop}
基本上就这些。这种方式实现了服务间的低耦合通信，适合小型系统或学习用途。生产环境建议结合gRPC、服务注册发现等机制提升健壮性。不复杂但容易忽略细节，比如连接超时和错误处理。
以上就是Golang RPC多服务间通信示例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1410906.html
微信扫一扫 
支付宝扫一扫 
