Go語言net包RPC遠(yuǎn)程調(diào)用三種方式http與json-rpc及tcp
發(fā)布日期：2022-02-01 08:23 | 文章來源：腳本之家
rpc有多種調(diào)用方式，http、json-rpc、tcp
一、服務(wù)端
在代碼中，啟動(dòng)了三個(gè)服務(wù)
package main
import (
"log"
"net"
"net/http"
"net/rpc"
"net/rpc/jsonrpc"
"sync"
)
//go對(duì)RPC的支持，支持三個(gè)級(jí)別：TCP、HTTP、JSONRPC
//go的RPC只支持GO開發(fā)的服務(wù)器與客戶端之間的交互，因?yàn)椴捎昧薵ob編碼
//注意字段必須是導(dǎo)出
type Params struct {
Width, Height int
}
type Rect struct{}
//函數(shù)必須是導(dǎo)出的
//必須有兩個(gè)導(dǎo)出類型參數(shù)
//第一個(gè)參數(shù)是接收參數(shù)
//第二個(gè)參數(shù)是返回給客戶端參數(shù)，必須是指針類型
//函數(shù)還要有一個(gè)返回值error
func (r *Rect) Area(p Params, ret *int) error {
*ret = p.Width * p.Height
return nil
}
func (r *Rect) Perimeter(p Params, ret *int) error {
*ret = (p.Width + p.Height) * 2
return nil
}
func main() {
rect := new(Rect)
//注冊(cè)一個(gè)rect服務(wù)
rpc.Register(rect)
var wg sync.WaitGroup
wg.Add(3)
go func() {
//把服務(wù)處理綁定到http協(xié)議上
rpc.HandleHTTP()
err := http.ListenAndServe(":8080", nil)
wg.Wait()
if err != nil {
log.Fatal(err)
defer wg.Done()
}
}()
log.Println("http rpc service start success addr:8080")
go func() {
tcpaddr, _ := net.ResolveTCPAddr("tcp", "127.0.0.1:8081")
tcplisten, err := net.ListenTCP("tcp", tcpaddr)
if err != nil {
log.Fatal(err)
defer wg.Done()
}
for {
conn, err3 := tcplisten.Accept()
if err3 != nil {
continue
}
go rpc.ServeConn(conn)
}
}()
log.Println("tcp rpc service start success addr:8081")
go func() {
tcpaddr, _ := net.ResolveTCPAddr("tcp", "127.0.0.1:8082")
tcplisten, err := net.ListenTCP("tcp", tcpaddr)
if err != nil {
log.Fatal(err)
defer wg.Done()
}
for {
conn, err3 := tcplisten.Accept()
if err3 != nil {
continue
}
go jsonrpc.ServeConn(conn)
}
}()
log.Println("tcp json-rpc service start success addr:8082")
wg.Wait()
}
二、http客戶端
package main
import (
"net/rpc"
"log"
"fmt"
)
type Params struct {
Width, Height int
}
func main() {
//連接遠(yuǎn)程rpc服務(wù)
rpc, err := rpc.DialHTTP("tcp", "127.0.0.1:8080")
if err != nil {
log.Fatal(err)
}
ret := 0;
//調(diào)用遠(yuǎn)程方法
//注意第三個(gè)參數(shù)是指針類型
err2 := rpc.Call("Rect.Area", Params{50, 100}, &ret)
if err2 != nil {
log.Fatal(err2)
}
fmt.Println(ret)
err3 := rpc.Call("Rect.Perimeter", Params{50, 100}, &ret)
if err3 != nil {
log.Fatal(err3)
}
fmt.Println(ret)
}
三、TCP客戶端
package main
import (
"net/rpc"
"fmt"
"log"
)
type Params struct {
Width, Height int
}
func main() {
//連接遠(yuǎn)程rpc服務(wù)
//這里使用Dial，http方式使用DialHTTP，其他代碼都一樣
rpc, err := rpc.Dial("tcp", "127.0.0.1:8081")
if err != nil {
log.Fatal(err)
}
ret := 0
//調(diào)用遠(yuǎn)程方法
//注意第三個(gè)參數(shù)是指針類型
err2 := rpc.Call("Rect.Area", Params{50, 100}, &ret)
if err2 != nil {
log.Fatal(err2)
}
fmt.Println(ret)
err3 := rpc.Call("Rect.Perimeter", Params{50, 100}, &ret)
if err3 != nil {
log.Fatal(err3)
}
fmt.Println(ret)
}
四、json客戶端
package main
import (
"fmt"
"log"
"net/rpc/jsonrpc"
)
type Params struct {
Width, Height int
}
func main() {
//連接遠(yuǎn)程rpc服務(wù)
rpc, err := jsonrpc.Dial("tcp", "127.0.0.1:8082")
if err != nil {
log.Fatal(err)
}
ret := 0
//調(diào)用遠(yuǎn)程方法
//注意第三個(gè)參數(shù)是指針類型
err2 := rpc.Call("Rect.Area", Params{150, 100}, &ret)
if err2 != nil {
log.Fatal(err2)
}
fmt.Println(ret)
err3 := rpc.Call("Rect.Perimeter", Params{150, 100}, &ret)
if err3 != nil {
log.Fatal(err3)
}
fmt.Println(ret)
}
五、運(yùn)行結(jié)果
以上就是Go語言net包RPC遠(yuǎn)程調(diào)用三種方式http與json-rpc及tcp的詳細(xì)內(nèi)容，更多關(guān)于Go語言net包RPC遠(yuǎn)程調(diào)用方式的資料請(qǐng)關(guān)注本站其它相關(guān)文章！
版權(quán)聲明：本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非maisonbaluchon.cn所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學(xué)習(xí)參考，不代表本站立場，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。
相關(guān)文章
關(guān)注官方微信