基本概念

RPC（Remote Procedure Call）遠(yuǎn)程過(guò)程調(diào)用，簡(jiǎn)單的理解是一個(gè)節(jié)點(diǎn)請(qǐng)求另一個(gè)節(jié)點(diǎn)提供的服務(wù)，該協(xié)議允許運(yùn)行于一臺(tái)計(jì)算機(jī)的程序調(diào)用另一臺(tái)計(jì)算機(jī)的子程序，而程序員無(wú)需額外地為這個(gè)交互作用編程，RPC最直接的作用就是微服務(wù)。

RPC通信過(guò)程

RPC的通信過(guò)程網(wǎng)上介紹很多，這里就不在單獨(dú)介紹了，具體過(guò)程如下：
1.Client以本地調(diào)用的方式發(fā)起調(diào)用；
2.Client stub收到調(diào)用后負(fù)責(zé)將被調(diào)用的方法名、參數(shù)等打包編碼成特定格式成網(wǎng)絡(luò)傳輸?shù)南Ⅲw；
3.Client stub將消息體通過(guò)網(wǎng)絡(luò)發(fā)送給服務(wù)端；
4.Server stub收到通過(guò)網(wǎng)絡(luò)接收到消息后按照相應(yīng)格式進(jìn)行拆包解碼，獲取方法名和參數(shù)；
5.Server stub根據(jù)方法名和參數(shù)進(jìn)行本地調(diào)用；
6.被調(diào)用者（Server）本地調(diào)用執(zhí)行后將結(jié)果返回給Server stub；
7.Server stub將返回值打包編碼成消息；
8.通過(guò)網(wǎng)絡(luò)發(fā)送給Client；
9.Client stub收到消息后，進(jìn)行拆包解碼，返回給Client；
10.Client得到本次RPC調(diào)用的最終結(jié)果.

RPC 具體實(shí)現(xiàn)

server端

package main
import (
	"net"
	"net/http"
	"net/rpc"
	"strings"
)
type EchoUtil struct {
}
func (echo *EchoUtil) CountString(str string, rsp *int) error {
	*rsp = strings.Count(str, "s")
	return nil
}
func main() {
	echoUtil := new(EchoUtil)
	/*將服務(wù)對(duì)象進(jìn)行注冊(cè)*/
	err := rpc.Register(echoUtil)
	if err != nil {
		err.Error()
	}
	rpc.HandleHTTP()
   
   /* 固定端口進(jìn)行監(jiān)聽(tīng)*/
	listen, err := net.Listen("tcp", ":9999")
	if err != nil {
		panic(err.Error())
	}
	http.Serve(listen, nil)
}

客戶端

package main
import (
	"fmt"
	"net/rpc"
)
func main() {
	cli, err := rpc.DialHTTP("tcp", "localhost:9999")
	if err != nil {
		panic(err.Error())
	}
	var resp *int
	/*采用同步調(diào)用的方式*/
	err = cli.Call("EchoUtil.CountString", "this is test", &resp)
	if err != nil {
		panic(err.Error())
	}
	fmt.Println(*resp)
}