架构师小飞传第三弹 - Golang的原生RPC与Node.js通讯

背景

621589303026_.pic_hd.jpg

小飞休息的时候也喜欢搞一些自己的小项目。花了几天的时间，小飞搞出了一套系统门户网站。其中包括广告管理，新闻管理，用户中心，统一登录，图片PaaS服务。

image.png

HTTP + RPC

小飞觉得，服务间通讯，Web和服务之间通讯都使用HTTP协议，未免觉得有点LOW。于是乎小飞决定WEB和服务间用HTTP通讯，而服务之间用Go的RPC协议通讯。这样写又面临着一个问题，一个服务要监听2个端口，一个是HTTP端口，另一个是RPC的端口。这让小飞无比的恼火。小飞找了一遍Go的Document，RPC包有这么几个方法吸引了小飞。HandleHTTP，DialHTTP。这说明什么，证明Golang的RPC包提供以HTTP协议为载体的方法。这样的话，就可以HTTP服务和RPC服务共用同一个接口了。看了下Golang RPC的代码是这样写的。

arith := new(Arith)
rpc.Register(arith)
rpc.HandleHTTP()
l, e := net.Listen("tcp", ":1234")
if e != nil {
    log.Fatal("listen error:", e)
}
go http.Serve(l, nil)

稍加改变，变成这样。

arith := new(Arith)
rpc.Register(arith)
rpc.HandleHTTP()
router := httprouter.New()
router.GET("/", GetIndex)
l, e := net.Listen("tcp", ":1234")
if e != nil {
    log.Fatal("listen error:", e)
}
go http.Serve(l, router)

用Postman测了一下，通了！完美解决。不过发现HTTP协议是通了，不过RPC协议的接口却返回404 Not Pages。看来方法不行，没办法开始Debug客户端代码，找到这个代码。

func DialHTTPPath(network, address, path string) (*Client, error) {
    var err error
    conn, err := net.Dial(network, address)
    ...
    io.WriteString(conn, "CONNECT "+path+" HTTP/1.0\n\n")
    ...
}

哇哦！原来是这样，DialHTTP会向服务器发出CONNECT /_goRPC_ HTTP/1.0 这就有办法了，用http.Handle方法接收“CONNECT /_goRPC_” 请求。然后在接收函数里，把写管道中的连接（net.Connect）勾出来，再用conn创建rpc响应应该就可以了。

func RPC(w http.ResponseWriter, r *http.Request, params httprouter.Params) {
    conn, _, err := w.(http.Hijacker).Hijack()
    if err != nil {
        log.Print("rpc hijacking ", r.RemoteAddr, ": ", err.Error())
        return
    }
    io.WriteString(conn, "HTTP/1.0 200 Connected to Go RPC\n\n")
    if err != nil {
        log.Print("rpc hijacking ", r.RemoteAddr, ": ", err.Error())
        return
    }
    rpc.ServeConn(conn)
}

func main() {
    wait := make(chan bool)
    arith := new(Arith)
    rpc.Register(arith)
    router := httprouter.New()
    router.Handle("CONNECT", rpc.DefaultRPCPath, RPC)
    l, _ := net.Listen("tcp", ":9999")
    go http.Serve(l, router)
    <- wait
}

完美解决，现在HTTP和RPC就共用同一个端口了。

就在调通的一刻，小飞发现rpc.Server实现了serveHTTP方法！也就是rpc.Server本身就是一个http.Handler。这么半天白费劲了！直接把代码改成如下就行。

// router.Handle("CONNECT", rpc.DefaultRPCPath, RPC)
router.Handler("CONNECT", rpc.DefaultRPCPath, rpc.DefaultServer)

项目就这样运行起来了。给每一个rpc服务都写个专门的SDK，把一些不需要访问数据库的服务去掉了，相互之间访问数据就需要用rpc来传输。

不过下一个问题很快就到了，单点登录需要用户中心，而用户中心的访问权就需要单点登录。Golang还有个问题就是循环引用。解决这个循环登录的问题，小飞想到的就是“前后分离”。

前后分离

架构图变成了现在这样。

image.png

前端都有前端的服务，不访问数据库。对Web提供HTTP服务，而后端对前端的服务提供RPC服务。但是很快一个心痒难耐的事儿就发生了。做Web服务，Node.js语言可能要比Golang更合适。因为JavaScript动态语言灵活性，V8引擎的高性能。第三方库丰富到让其他语言开发者都眼馋。

image.png

JSON-RPC

一波未平一波又起，Golang的问题有暴露出来了，就是他的原生RPC库只能支持同语言。主要还是因为Golang默认RPC用的序列化编码是gob，这样选择一个通用的编码方式就好了XML或者JSON都是比较好的序列化编码方式。最后小飞选择了JSON。不为别的，Golang标准库中包含jsonrpc库。

image.png

HTTP和JSON-RPC

起初小飞想到的方法是，服务之间用HTTP作为载体，其中HTTP Body用JSON-RPC编码。于是乎代码变成了这个样子。

// server.go
func RPC(w http.ResponseWriter, r *http.Request, params httprouter.Params) {
    conn, _, err := w.(http.Hijacker).Hijack()
    if err != nil {
        log.Print("rpc hijacking ", r.RemoteAddr, ": ", err.Error())
        return
    }
    io.WriteString(conn, "HTTP/1.0 200 Connected to Go RPC\n\n")
    if err != nil {
        log.Print("rpc hijacking ", r.RemoteAddr, ": ", err.Error())
        return
    }
    jsonrpc.ServeConn(conn)
}

// client
conn, err := net.Dial("tcp", "127.0.0.1:9999")
if err != nil {
    log.Fatal("dialing:", err)
}
io.WriteString(conn, "CONNECT " + rpc.DefaultRPCPath +" HTTP/1.0\n\n")
client := jsonrpc.NewClient(conn)

这样的话会出现一个问题，jsonrpc只能解码JSON数据。而HTTP返回数据中不只有数据体，而且还有HTTP头。这样默认的jsonrpc解码器就不起作用了，会出现超级恶心的'H'没法解码的问题。这时候需要做的就是，从新定义解码器。而既然已经前后分离，后端服务也没有必要非得用HTTP协议作为载体，那么干脆直接走原生jsonrpc来的痛快。于是乎代码编程了这样。

Node.js JSON-RPC

问题解决了，应该可以运行了吧。几行代码搞起个Node.js服务，再npm装个json-rpc库。F**K居然没有一个可以用的，都是八九年前的库。唯一看起来能用的居然是用采取了之前废掉的HTTP为载体数据体用JSON-RPC的方式玩的。这么看来，这些个库都是自嗨。根本就不能完成跨语言的调用。好像除了gRPC其他的框架真的不能完成跨语言调用吗？为了不给心爱的电脑添加更多的负担，坚决不用gRPC。

image.png

自己写吧，因为通过之前的研究，Golang的rpc已经掌握的差不多了，有信心写一个rpc客户端。用net.Socket写了个go-rpc客户端。Cool！自此所有的服务都按部就班了。

const net = require('net')

var port = 9999;
var host = '127.0.0.1';
var client = new net.Socket();

client.connect(port, host, function() {
    const buf = JSON.stringify({"method":"Arith.Multiply","params":[{"A":7,"B":8}],"id":0})
    const buf2 = JSON.stringify({"method":"Arith.Multiply","params":[{"A":7,"B":8}],"id":1})
    client.write(`${buf}${buf2}`);
});

client.on('data', function(data){
    console.log(data.toString());
})

有疑问加站长微信联系（非本文作者）