
RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。
简单来说,就是跟远程访问或者web请求差不多,都是一个clIEnt向远端服务器请求服务返回结果,但是web请求使用的网络协议是http高层协议,而rpc所使用的协议多为TCP,是网络层协议,减少了信息的包装,加快了处理速度。
golang本身有rpc包,可以方便的使用,来构建自己的rpc服务,下边是一个简单是实例,可以加深我们的理解
它的工作流程如下图:
@L_403_0@
golang 使用 RPC的例子如下:
服务器端代码:
这里暴露了一个RPC接口,一个http接口
package main
import (
"fmt"
"io"
"net"
"net/http"
"net/rpc"
)
type Watcher int
func (w *Watcher) GetInfo(arg int,result *int) error {
*result = 1
return nil
}
func main() {
http.HandleFunc("/ghj1976",Ghj1976Test)
watcher := new(Watcher)
rpc.Register(watcher)
rpc.Handlehttp()
l,err := net.Listen("tcp",":1234")
if err != nil {
fmt.Println("监听失败,端口可能已经被占用")
}
fmt.Println("正在监听1234端口")
http.Serve(l,nil)
}
func Ghj1976Test(w http.ResponseWriter,r *http.Request) {
io.WriteString(w,"<HTML><body>ghj1976-123</body></HTML>")
}
客户端代码:
package main
import (
"fmt"
"net/rpc"
)
func main() {
clIEnt,err := rpc.Dialhttp("tcp","127.0.0.1:1234")
if err != nil {
fmt.Println("链接rpc服务器失败:",err)
}
var reply int
err = clIEnt.Call("Watcher.GetInfo",1,&reply)
if err != nil {
fmt.Println("调用远程服务失败",err)
}
fmt.Println("远程服务返回结果:",reply)
}
服务器端代码执行截图
客户端代码执行截图
http网页执行截图:
总结以上是内存溢出为你收集整理的golang rpc实例分析全部内容,希望文章能够帮你解决golang rpc实例分析所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)