当前位置: 首页 > 工具软件 > cwsharp-go > 使用案例 >

Go Web---RPC

蒋典
2023-12-01


用 rpc 实现远程过程调用

Go 程序之间可以使用 net/rpc 包实现相互通信,这是另一种客户端-服务器应用场景。它提供了一种方便的途径,通过网络连接调用远程函数。当然,仅当程序运行在不同机器上时,这项技术才实用。rpc 包建立在 gob 包之上,实现了自动编码/解码传输的跨网络方法调用。

服务器端需要注册一个对象实例,与其类型名一起,使之成为一项可见的服务:它允许远程客户端跨越网络或其他 I/O 连接访问此对象已导出的方法。总之就是在网络上暴露类型的方法。

rpc 包使用了 http 和 tcp 协议,以及用于数据传输的 gob 包。服务器端可以注册多个不同类型的对象(服务),但同一类型的多个对象会产生错误。

小结:

  • Golang 提供RPC标准包,支持开发 RPC 服务端和客户端,采用 gob 编码。
  • 支持三种请求方式:HTTP、TCP 和 JSONRPC
  • Golang RPC 函数必须特定的格式写法才能被远程调用,格式如下:
func (t *T) MethodName(argType T1, replyType *T2) error

T1 和 T2 必须能被 encoding/gob 包编码和解码


实例演示

服务端:

  • 新增rpc服务 func (p *HelloService) Hello(request string, reply *string) error{}
  • 注册rpc服务 rpc.Register(HelloService)
  • 开启服务监听 net.Listen(“tcp”, “:5200”)
package main

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

type HelloService struct{}

func (p *HelloService) Hello(request string, reply *string) error {
	*reply = "hello: " + request
	fmt.Println("hello方法被调用,返回给客户端的结果为: ", *reply)
	return nil
}

func main() {
	rpc.RegisterName("HelloService", new(HelloService))

	listener, err := net.Listen("tcp", ":5200")

	if err != nil {
		log.Fatal(err)
	}

	conn, err := listener.Accept()

	if err != nil {
		log.Fatal(err)
	}

	rpc.ServeConn(conn)
}


客户端:

  • 连接rpc服务器 rpc.Dail(“tcp”, “localhost:5200”)
  • 调用rpc服务 client.Call(“HelloService.Hello”, “chloe”, &reply)
package main

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

func main() {
	client, err := rpc.Dial("tcp", "localhost:5200")

	if err != nil {
		log.Fatal(err)
	}

	var reply string

	err = client.Call("HelloService.Hello", "chloe", &reply)

	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("远程调用,响应结果为: " + reply)
}

更多go rpc细节可以参考此文


 类似资料: