Golang 实现RPC

示例1

服务端

package main

import (
	"log"
	"net/http"
	"net/rpc"
)

//    例题:golang实现RPC程序,实现求矩形面积和周长

type Params struct {
	Width, Height int
}

type Rect struct{}

// RPC服务端方法,求矩形面积
//函数的第一个参数是接收参数,第二个参数是返回给客户端的参数,必须是指针类型,函数还必须有一个返回值error
func (r *Rect) Area(p Params, ret *int) error {
	*ret = p.Height * p.Width
	return nil
}

// 周长
func (r *Rect) Perimeter(p Params, ret *int) error {
	*ret = (p.Height + p.Width) * 2
	return nil
}

// 主函数
func main() {
	// 1.注册服务
	rect := new(Rect)
	// 注册一个rect的服务
	rpc.Register(rect)
	// 2.服务处理绑定到http协议上
	rpc.HandleHTTP()
	// 3.监听服务
	err := http.ListenAndServe(":8000", nil)
	if err != nil {
		log.Panicln(err)
	}
}

客户端

package main

import (
	"fmt"
	"log"
	"net/rpc"
)

// 传的参数
type Params struct {
	Width, Height int
}

// 主函数
func main() {
	// 1.连接远程rpc服务
	conn, err := rpc.DialHTTP("tcp", ":8000")
	if err != nil {
		log.Fatal(err)
	}
	// 2.调用方法
	// 面积
	ret := 0
	err2 := conn.Call("Rect.Area", Params{50, 100}, &ret)
	if err2 != nil {
		log.Fatal(err2)
	}
	fmt.Println("面积:", ret)
	// 周长
	err3 := conn.Call("Rect.Perimeter", Params{50, 100}, &ret)
	if err3 != nil {
		log.Fatal(err3)
	}
	fmt.Println("周长:", ret)
}

上一篇:NFS:Network File System(网络文件系统)


下一篇:分布式 - 公司使用什么RPC框架,聊聊你理解的RPC原理