今天就跟大家聊聊有關(guān)net與rpc包怎么在golang中使用,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
golang的rpc支持三個(gè)級(jí)別的RPC:TCP、HTTP、JSONRPC。但Go的RPC包是獨(dú)一無(wú)二的RPC,它和傳統(tǒng)的RPC系統(tǒng)不同,它只支持Go開發(fā)的服務(wù)器與客戶端之間的交互,因?yàn)樵趦?nèi)部,它們采用了Gob來編碼。
Go RPC的函數(shù)只有符合下面的條件才能被遠(yuǎn)程訪問,不然會(huì)被忽略,詳細(xì)的要求如下:
函數(shù)必須是導(dǎo)出的(首字母大寫)
必須有兩個(gè)導(dǎo)出類型的參數(shù),
第一個(gè)參數(shù)是接收的參數(shù),第二個(gè)參數(shù)是返回給客- 戶端的參數(shù),第二個(gè)參數(shù)必須是指針類型的
函數(shù)還要有一個(gè)返回值error
舉個(gè)例子,正確的RPC函數(shù)格式如下:
func (t *T) MethodName(argType T1, replyType *T2) error
T、T1和T2類型必須能被encoding/gob包編解碼。
示例
舉一個(gè)http的例子。
下面是http服務(wù)器端的代碼:
package main import ( "errors" "net" "net/rpc" "log" "net/http" ) type Args struct { A, B int } type Quotient struct { Quo, Rem int } type Arith int func (t *Arith) Multiply(args *Args, reply *int) error { *reply = args.A * args.B return nil } func (t *Arith) Divide(args *Args, quo *Quotient) error { if args.B == 0 { return errors.New("divide by zero") } quo.Quo = args.A / args.B quo.Rem = args.A % args.B return nil } func main() { arith := new(Arith) rpc.Register(arith) rpc.HandleHTTP() l, e := net.Listen("tcp", ":1234") if e != nil { log.Fatal("listen error:", e) } http.Serve(l, nil) }
簡(jiǎn)單分析一下上面的例子,先實(shí)例化了一個(gè)Arith對(duì)象arith,然后給arith注冊(cè)了rpc服務(wù),然后把rpc掛載到http服務(wù)上面,當(dāng)http服務(wù)打開的時(shí)候我們就可以通過rpc客戶端來調(diào)用arith中符合rpc標(biāo)準(zhǔn)的的方法了。
請(qǐng)看客戶端的代碼:
package main import ( "net/rpc" "log" "fmt" ) type Args struct { A, B int } type Quotient struct { Quo, Rem int } func main() { client, err := rpc.DialHTTP("tcp", "127.0.0.1:1234") if err != nil { log.Fatal("dialing:", err) } // Synchronous call args := &Args{7,8} var reply int err = client.Call("Arith.Multiply", args, &reply) if err != nil { log.Fatal("arith error:", err) } fmt.Printf("Arith: %d*%d=%d\n", args.A, args.B, reply) // Asynchronous call quotient := new(Quotient) divCall := client.Go("Arith.Divide", args, quotient, nil) replyCall := <-divCall.Done // will be equal to divCall if replyCall.Error != nil { log.Fatal("arith error:", replyCall.Error) } fmt.Printf("Arith: %d/%d=%d...%d", args.A, args.B, quotient.Quo, quotient.Rem) // check errors, print, etc. }
簡(jiǎn)單說明下,先用rpc的DialHTTP方法連接服務(wù)器端,調(diào)用服務(wù)器端的函數(shù)就要使用Call方法了,Call方法的參數(shù)和返回值已經(jīng)很清晰的表述出rpc整體的調(diào)用邏輯了。
我們把服務(wù)器端跑起來,再把客戶端跑起來,這時(shí)候客戶端會(huì)輸出:
Arith: 7*8=56 Arith: 7/8=0...7
看完上述內(nèi)容,你們對(duì)net與rpc包怎么在golang中使用有進(jìn)一步的了解嗎?如果還想了解更多知識(shí)或者相關(guān)內(nèi)容,請(qǐng)關(guān)注億速云行業(yè)資訊頻道,感謝大家的支持。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。