【问题标题】:JSONRPC over HTTP in Go [duplicate]Go中基于HTTP的JSONRPC [重复]
【发布时间】:2017-12-24 17:28:11
【问题描述】:

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

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))
        }
    }
}

【问题讨论】:

  • 什么是“rpc http 处理程序”?
  • @CeriseLimon this 函数在默认 http 服务器中注册 http 处理程序。

标签: http go json-rpc


【解决方案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 而不是连接。

【讨论】:

  • JSON-RPC specification 提到您必须使用 GET 或 POST 作为 HTTP 方法,但我认为您的方式不正确。
  • @ParhamAlvani 您的问题和对问题的评论指向此解决方案。更新问题以说出您想要的内容。
  • 谢谢,我更新了我的问题。但我认为这个解决方案是基于 Go 内置库的最佳解决方案。
猜你喜欢
  • 1970-01-01
  • 2016-07-22
  • 2023-04-07
  • 2021-12-02
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2011-08-26
相关资源
最近更新 更多