Go中的JSONRPC over HTTP [复制]

问题描述 投票:2回答:1

这个问题在这里已有答案:

如何在Go中使用基于this specification的HTTP上的JSON-RPC?

Go在net/rpc/jsonrpc中提供了JSON-RPC编解码器,但是这个编解码器使用网络连接作为输入,所以你不能将它与go RPC HTTP处理程序一起使用。我附加了使用TCP进行JSON-RPC的示例代码:

func main() {
    cal := new(Calculator)
    server := rpc.NewServer()
    server.Register(cal)
    listener, e := net.Listen("tcp", ":1234")
    if e != nil {
        log.Fatal("listen error:", e)
    }
    for {
        if conn, err := listener.Accept(); err != nil {
            log.Fatal("accept error: " + err.Error())
        } else {
            log.Printf("new connection established\n")
            go server.ServeCodec(jsonrpc.NewServerCodec(conn))
        }
    }
}
http go json-rpc
1个回答
1
投票

内置的RPC HTTP处理程序在被劫持的HTTP连接上使用gob编解码器。以下是如何使用JSONRPC执行相同操作。

编写一个HTTP处理程序,运行带有被劫持连接的JSONRPC服务器。

func serveJSONRPC(w http.ResponseWriter, req *http.Request) {
    if req.Method != "CONNECT" {
        http.Error(w, "method must be connect", 405)
        return
    }
    conn, _, err := w.(http.Hijacker).Hijack()
    if err != nil {
        http.Error(w, "internal server error", 500)
        return
    }
    defer conn.Close()
    io.WriteString(conn, "HTTP/1.0 Connected\r\n\r\n")
    jsonrpc.ServeConn(conn)
}

向HTTP服务器注册此处理程序。例如:

 http.HandleFunc("/rpcendpoint", serveJSONRPC)

编辑:OP已经更新了问题,以明确他们想要GET / POST而不是连接。

© www.soinside.com 2019 - 2024. All rights reserved.