Golang JSON RPC

Go’s rpc package has an example for the default rpc implementation but nothing for the jsonrpc package. Here is how to get it work. The rpc example uses some helpers built into the rpc package, I just looked at that code in Go’s stdlib to figure out the proper way to get the jsonrpc package to work.

package main
import (
    "fmt"
    "log"
    "net"
    "net/rpc"
    "net/rpc/jsonrpc"
    "test/server"
)
func startServer() {
    arith := new(server.Arith)
    server := rpc.NewServer()
    server.Register(arith)
    server.HandleHTTP(rpc.DefaultRPCPath, rpc.DefaultDebugPath)
    l, e := net.Listen("tcp", ":8222")
    if e != nil {
        log.Fatal("listen error:", e)
    }
    for {
        conn, err := l.Accept()
        if err != nil {
            log.Fatal(err)
        }
        go server.ServeCodec(jsonrpc.NewServerCodec(conn))
    }
}
func main() {
    go startServer()
    conn, err := net.Dial("tcp", "localhost:8222")
    if err != nil {
        panic(err)
    }
    defer conn.Close()
    args := &server.Args{7, 8}
    var reply int
    c := jsonrpc.NewClient(conn)
    for i := 0; i < 1; i++ {
        err = c.Call("Arith.Multiply", args, &reply)
        if err != nil {
            log.Fatal("arith error:", err)
        }
        fmt.Printf("Arith: %d*%d=%d", args.A, args.B, reply)
    }
}

Michael Crosby