先定义共享结构体，再分别实现UserService和OrderService的RPC通信。UserService监听8081提供用户查询，OrderService监听8082并调用UserService获取用户信息，客户端通过调用OrderService完成订单与用户数据聚合。
在Golang中实现多个服务间的RPC通信，可以通过标准库net/rpc轻松完成。下面是一个清晰的多服务间RPC通信示例，包含两个独立的服务（UserService和OrderService），它们通过RPC进行解耦通信。
1. 定义共享的数据结构与接口
为了支持跨服务调用，先定义共用的请求和响应结构体。这些结构可以放在一个独立的包中（如common），或直接复制到各服务中。
// common/types.go
package common
type User struct {
ID int
Name string
}
type Order struct {
ID int
UserID int
Product string
}
2. UserService 提供用户查询功能
UserService对外暴露一个RPC方法GetUser，根据ID返回用户信息。
// user_service/server.go
package main
import (
"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语言免费学习笔记（深入）”；
营销型企业网站源码响应式界面1.0.1
下载
这几年企业营销型网站成为PC端风靡一时的设计主流，主要特点就是首页长度比较长，首页展示的内容量非常大，通过对首页的大量渲染，突出企业优势、产品服务优势等众多信息，让用户在页面停留时间更久，对企业的映像更加深刻，从而达到营销的目的。但是对于大部分的营销型网站来说，一个最大的弱点就是在手机上的用户体验都比较差，而这又恰好是自适应网站所具备的优势，自适应网站能够自动检测访问者浏览设备的分辨率，从而根据访
// order_service/server.go
package main
import (
"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.go
package main
import (
"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 关联用户: AliceClient 日志： 获取订单: {ID:101 UserID:1 Product:Laptop}
基本上就这些。这种方式实现了服务间的低耦合通信，适合小型系统或学习用途。生产环境建议结合gRPC、服务注册发现等机制提升健壮性。不复杂但容易忽略细节，比如连接超时和错误处理。
