Go入门实战:分布式编程
package main
import (
"fmt"
"net/rpc"
)
type Args struct {
A, B int
}
type Quotient struct {
Quo, Rem int
}
func main() {
// 连接到RPC服务器
serverAddress := "127.0.0.1:1234"
client, err := rpc.DialHTTP("tcp", serverAddress)
if err != nil {
fmt.Println("连接失败:", err)
return
}
// 调用远程过程调用
args := &Args{10, 3}
var reply Quotient
err = client.Call("Divide.Divide", args, &reply)
if err != nil {
fmt.Println("调用失败:", err)
} else {
fmt.Printf("调用成功: %d/%d = %d ... %d\n", args.A, args.B, reply.Quo, reply.Rem)
}
}
这段代码演示了如何使用Go语言进行RPC(远程过程调用)客户端的编写。首先,我们尝试连接到RPC服务器,然后调用服务端公开的方法“Divide.Divide”。我们定义了参数和返回值的结构体,并通过RPC调用服务端的计算除法操作。如果调用成功,我们会打印出结果,如果失败,我们会打印出错误信息。这是一个简单的RPC客户端实现,展示了如何在Go语言中使用RPC进行分布式编程。
评论已关闭