golang實(shí)現(xiàn)簡(jiǎn)單rpc調(diào)用過程解析

更新時(shí)間：2022年05月06日 11:22:35 作者：神技圈子

這篇文章主要介紹了golang實(shí)現(xiàn)簡(jiǎn)單rpc調(diào)用,包括RPC具體實(shí)現(xiàn)結(jié)合實(shí)例代碼給大家講解的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

基本概念

RPC（Remote Procedure Call）遠(yuǎn)程過程調(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ī)的子程序，而程序員無需額外地為這個(gè)交互作用編程，RPC最直接的作用就是微服務(wù)。

RPC通信過程

RPC的通信過程網(wǎng)上介紹很多，這里就不在單獨(dú)介紹了，具體過程如下：
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將消息體通過網(wǎng)絡(luò)發(fā)送給服務(wù)端；
4.Server stub收到通過網(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.通過網(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)聽*/
	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)
}

到此這篇關(guān)于golang實(shí)現(xiàn)簡(jiǎn)單rpc調(diào)用的文章就介紹到這了,更多相關(guān)golang rpc調(diào)用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: