1.RPC的基本知识介绍:
RPC叫做远程调用框架(Remote Procedure Call),远程调用原理如下所示:
比如 A (client) 调用 B (server) 提供的remoteAdd方法:
首先,A与B之间建立一个TCP连接;
然后,A把需要调用的方法名(这里是remoteAdd)以及方法参数(10, 20)序列化成字节流发送出去;
接着,B接受A发送过来的字节流,然后反序列化得到目标方法名,方法参数,接着执行相应的方法调用(可能是localAdd)并把结果30返回;
最后,A接受远程调用结果,输出30。
RPC框架就是把我刚才说的这几点些细节给封装起来,给用户暴露简单友好的API使用。
RPC与Socket的区别:
RPC(远程过程调用)采用客户机/服务器模式实现两个进程之间相互通信。socket是RPC经常采用的通信手段之一,RPC是在Socket的基础上实现的,它比socket需要更多的网络和系统资源。除了Socket,RPC还有其他的通信方法,比如:http、操作系统自带的管道等技术来实现对于远程程序的调用。
RPC与REST的区别:
REST API 和 RPC 都是在 Server端 把一个个函数封装成接口暴露出去,以供 Client端 调用,不过 REST API 是基于 HTTP协议的,REST致力于通过http协议中的POST/GET/PUT/DELETE等方法和一个可读性强的URL来提供一个http请求。而 RPC 则可以不基于 HTTP协议。
因此,如果是后端两种语言互相调用,用 RPC 可以获得更好的性能(省去了 HTTP 报头等一系列东西),应该也更容易配置。
REST API的介绍,可以参考:Go 语言之restful 基础
2. Go Rpc 的实现例子介绍
对于Go语言来说RPC的实现主要有三种类型,Http Rpc, Tcp Rpc和Json Rpc三种架构。
1) Tcp RPC与Http RPC的比较:
上面这个代码和http的服务器相比,不同在于:在此处我们采用了TCP协议,然后需要自己控制连接,当有客户端连接上来后,我们需要把这个连接交给rpc来处理。
2) Json RPC与Tcp RPC比较:
JSON RPC是数据编码采用了JSON,而不是gob编码,其他和上面介绍的RPC概念一模一样,json-rpc是基于TCP协议实现的,目前它还不支持HTTP方式。
2.1 Http Rpc
基于Http协议实现的Rpc架构,主要涉及到的API为,rpc.HandleHTTP() 、http.ListenAndServe(":1234", nil)、rpc.DialHTTP("tcp", "127.0.0.1"+":1234"),client.Call("HttpRpcServer.Print", &a, &outStr)
服务端代码:
package main
import (
"fmt"
"strconv"
"net/http"
"net/rpc"
)type HttpRpcServer struct {
a int
}
// 入参的数量和返回值这些格式是固定的
func (s *HttpRpcServer) Print( a *int, o *string) error {
fmt.Println("HttpRpcServer.Print:",*a)
*o = strconv.Itoa(*a)
return nil
}func main() {
fmt.Println("Main start...")
server := new(HttpRpcServer)
rpc.Register(server)
rpc.HandleHTTP()
err := http.ListenAndServe(":1234", nil) // httprpc对于服务器的连接的控制管理,已经封装好了
if err != nil {
fmt.Println(err.Error())
}
}
客户端:
package main
import (
"fmt"
"log"
"net/rpc"
)func main() {
client, err := rpc.DialHTTP("tcp", "127.0.0.1"+":1234")// 与服务器建立连接
if err != nil {
log.Fatal("dialing:", err)
}
var a int = 10
var outStr string
fmt.Println("Client:send:",a)
// 通过字符串的命名格式来调用对应的API,这里是调用了HttpRpcServer这个数据结构中的Print函数,a和outStr作为入参来处理,err作为Print函数的返回值。
err = client.Call("HttpRpcServer.Print", &a, &outStr)
if err != nil {
log.Fatal("arith error:", err)
}
fmt.Println("CLient revieve:",a,outStr)
}
运行结果:
服务端:
Main start...
HttpRpcServer.Print: 10
客户端:
Client:send: 10
CLient revieve: 10 10
2.2 Tcp Rpc
Tcp Rpc主要涉及到的API接口
net.ResolveTCPAddr("tcp", ":1234"),net.ListenTCP("tcp", tcpAddr),
listener.Accept(),rpc.ServeConn(conn),rpc.Dial("tcp", "127.0.0.1"
+":1234"),client.Call("HttpRpcServer.Print", &a, &outStr)
服务端:
package main
import (
"fmt"
"strconv"
"net"
"net/rpc"
)type HttpRpcServer struct {
a int
}func (s *HttpRpcServer) Print( a *int, o *string) error {
fmt.Println("HttpRpcServer.Print:",*a)
*o = strconv.Itoa(*a)
return nil
}func main() {
fmt.Println("Main start...")
server := new(HttpRpcServer)
rpc.Register(server)
tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234") // 这里指定协议为tcp
if err != nil {
fmt.Println(err.Error())
}
listener, err := net.ListenTCP("tcp", tcpAddr) // 服务端分开监听对应的连接
if err != nil {
fmt.Println(err.Error())
}
for {
// AcceptTCP接收下一个呼叫,并返回一个新的*TCPConn。
conn, err := listener.Accept()
if err != nil {
continue
}
rpc.ServeConn(conn) // 这里是阻塞的,同时支持多个的话,需要用到go
}
}
客户端:
package main
import (
"fmt"
"log"
"net/rpc"
)func main() {
client, err := rpc.Dial("tcp", "127.0.0.1"+":1234") // tcp的协议来处理
if err != nil {
log.Fatal("dialing:", err)
}
var a int = 10
var outStr string
fmt.Println("Client:send:",a)
err = client.Call("HttpRpcServer.Print", &a, &outStr)
if err != nil {
log.Fatal("arith error:", err)
}
fmt.Println("CLient revieve:",a,outStr)
}
运行结果:
服务端:
Main start...
HttpRpcServer.Print: 10
客户端:
Client:send: 10
CLient revieve: 10 10
2.3 Json Rpc
Json Rpc主要涉及到的API接口:
net.ResolveTCPAddr("tcp", ":1234"),net.ListenTCP("tcp", tcpAddr),
listener.Accept(),jsonrpc.ServeConn(conn),client.Call("HttpRpcServer.Print", &a, &outStr)
服务端:
package mainimport (
"fmt"
"strconv"
"net"
"net/rpc"
"net/rpc/jsonrpc"
)type HttpRpcServer struct {
a int
}func (s *HttpRpcServer) Print( a *int, o *string) error {
fmt.Println("HttpRpcServer.Print:",*a)
*o = strconv.Itoa(*a)
return nil
}func main() {
fmt.Println("Main start...")
server := new(HttpRpcServer)
rpc.Register(server)
tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234") // 这里指定协议为tcp
if err != nil {
fmt.Println(err.Error())
}
listener, err := net.ListenTCP("tcp", tcpAddr)
if err != nil {
fmt.Println(err.Error())
}
for {
// AcceptTCP接收下一个呼叫,并返回一个新的*TCPConn。
conn, err := listener.Accept()
if err != nil {
continue
}
jsonrpc.ServeConn(conn) // 这里是阻塞的,同时支持多个的话,需要用到go
}
}
客户端:
package main
import (
"fmt"
"log"
"net/rpc/jsonrpc"
)func main() {
client, err := jsonrpc.Dial("tcp", "127.0.0.1"+":1234")
if err != nil {
log.Fatal("dialing:", err)
}
var a int = 10
var outStr string
fmt.Println("Client:send:",a)
err = client.Call("HttpRpcServer.Print", &a, &outStr)
if err != nil {
log.Fatal("arith error:", err)
}
fmt.Println("CLient revieve:",a,outStr)
}
运行结果:
服务端:
Main start...
HttpRpcServer.Print: 10
客户端:
Client:send: 10
CLient revieve: 10 10
参考文档:
http://www.kancloud.cn:8080/uvohp5na133/golang/934246
https://golang.org/pkg/net/rpc/
灰子学技术:
【Go语言之GRPC】
文章图片
推荐阅读
- go语言深拷贝和浅拷贝
- 通过golang context实现请求超时控制和goroutine生命周期控制
- go protobuf 使用教程(windows环境下)
- 网络协议与网络编程|Go语言进行web开发(二) Go中的Socket编程
- go的gin框架使用(一)(Hello World)
- golang|Go语言入门——从一个简单例子入门
- go语言之脚本命令的使用
- Golang中的"继承"
- 2018|Base58编码解码Go实现