doulu8341
doulu8341
2017-12-24 17:28

Go中基于HTTP的JSONRPC [重复]

已采纳

This question already has an answer here:

How can I use JSON-RPC over HTTP based on this specification in Go?

Go provides JSON-RPC codec in net/rpc/jsonrpc but this codec use network connection as input so you cannot use it with go RPC HTTP handler. I attach sample code that uses TCP for 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
")
            go server.ServeCodec(jsonrpc.NewServerCodec(conn))
        }
    }
}
</div>
  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

1条回答

  • ds3422222 ds3422222 4年前

    The built-in RPC HTTP handler uses the gob codec on a hijacked HTTP connection. Here's how to do the same with the JSONRPC.

    Write an HTTP handler that runs the JSONRPC server with a hijacked connection.

    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
    
    ")
        jsonrpc.ServeConn(conn)
    }
    

    Register this handler with the HTTP server. For example:

     http.HandleFunc("/rpcendpoint", serveJSONRPC)
    

    EDIT: OP has since updated question to make it clear that they want GET/POST instead of connect.

    点赞 评论 复制链接分享

相关推荐