其他分享
首页 > 其他分享> > net/rpc

net/rpc

作者:互联网

在网上找grpc学习资料的时候,发先go语言自带一个rpc框架,不过只支持go语言,赶紧过来看看。

net/rpc

这里简要记了,详细的内容在go源码的注释里面。

注意事项:

服务端

package main

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

type Server struct {
}

//请求
type Req struct {
	NumOne int
	NumTwo int
}

//返回
type Res struct {
	Num int
}

func (s *Server) Add(req Req, res *Res) error {
	res.Num = req.NumOne + req.NumTwo
	return nil
}

func main() {
	rpc.Register(new(Server))
	rpc.HandleHTTP()
	l, err := net.Listen("tcp", ":8888")
	if err != nil {
		fmt.Println(err.Error())
	}
	http.Serve(l, nil)
}

我们将server注册起来,然后跑在8888端口上。server有一个函数Add,就是将入参的两个值加到一起赋给出参。

客户端

package main

import (
	"fmt"
	"net/rpc"
)

type Req struct {
	NumOne int
	NumTwo int
}

type Res struct {
	Num int
}

func main() {
	req := Req{NumOne: 1, NumTwo: 2}
	var res Res
	client, err := rpc.DialHTTP("tcp", "localhost:8888")
	if err != nil {
		fmt.Println(err.Error())
	}
	client.Call("Server.Add", req, &res)
	fmt.Println(res)
}

客户端调用服务端的这个函数,结果如下:

image-20220706153255121

使用Call()方法是同步方式的调用,使用Go方法可以是实现异步调用

修改服务端为:

func (s *Server) Add(req Req, res *Res) error {
	time.Sleep(5 * time.Second)
	res.Num = req.NumOne + req.NumTwo
	return nil
}

我们让add函数等5秒再返回

客户端修改为这样:

func main() {
	req := Req{NumOne: 1, NumTwo: 2}
	var res Res
	client, err := rpc.DialHTTP("tcp", "localhost:8888")
	if err != nil {
		fmt.Println(err.Error())
	}
	ca := client.Go("Server.Add",req,&res,nil)
	for {
		select {
		case <-ca.Done:
			fmt.Println(res)
			return
		default:
			time.Sleep(time.Second)
			fmt.Println("哈哈啊哈")
		}
	}
}

然后结果是

image-20220706160937737

标签:err,nil,res,req,rpc,net
来源: https://www.cnblogs.com/yumingkuan/p/16451317.html