Golang implementation of JSON-RPC 2.0 server with generics
Go to file
Alexander Kiryukhin 262768e3a2
Fix http transport send headers
2022-05-22 02:56:33 +03:00
example Improvments. Breaking changes 2022-05-21 20:38:21 +03:00
rpc Improvments. Breaking changes 2022-05-21 20:38:21 +03:00
transport Fix http transport send headers 2022-05-22 02:56:33 +03:00
LICENSE.md Added license 2022-01-31 20:55:38 +03:00
README.md Update README.md 2022-05-21 20:39:31 +03:00
go.mod Improvments. Breaking changes 2022-05-21 20:38:21 +03:00
go.sum Improvments. Breaking changes 2022-05-21 20:38:21 +03:00

README.md

JSON-RPC 2.0

Golang implementation of JSON-RPC 2.0 server with generics.

Go 1.18+ required

Features:

  • HTTP/HTTPS transport
  • TCP transport
  • WebSocket transport

Usage (http transport)

  1. Create JSON-RPC server:
    import "go.neonxp.dev/jsonrpc2/rpc"
    ...
    s := rpc.New()
  1. Add required transport(s):
    import "go.neonxp.dev/jsonrpc2/transport"
    ...
    s.AddTransport(&transport.HTTP{Bind: ":8000"})
    s.AddTransport(&transport.TCP{Bind: ":3000"})
  1. Write handler:
    func Multiply(ctx context.Context, args *Args) (int, error) {
        return args.A * args.B, nil
    }

Handler must have exact two arguments (context and input of any json serializable type) and exact two return values (output of any json serializable type and error)

  1. Wrap handler with rpc.H method and register it in server:
    s.Register("multiply", rpc.H(Multiply))
  1. Run RPC server:
    s.Run(ctx)

Custom transport

Any transport must implement simple interface transport.Transport:

type Transport interface {
	Run(ctx context.Context, resolver Resolver) error
}

Complete example

Full code

package main

import (
   "context"

   "go.neonxp.dev/jsonrpc2/rpc"
   "go.neonxp.dev/jsonrpc2/transport"
)

func main() {
   s := rpc.New()

   s.AddTransport(&transport.HTTP{Bind: ":8000"}) // HTTP transport
   s.AddTransport(&transport.TCP{Bind: ":3000"}) // TCP transport

   s.Register("multiply", rpc.H(Multiply))
   s.Register("divide", rpc.H(Divide))

   s.Run(context.Background())
}

func Multiply(ctx context.Context, args *Args) (int, error) {
    //...
}

func Divide(ctx context.Context, args *Args) (*Quotient, error) {
    //...
}

type Args struct {
	A int `json:"a"`
	B int `json:"b"`
}

type Quotient struct {
	Quo int `json:"quo"`
	Rem int `json:"rem"`
}

Author

Alexander Kiryukhin i@neonxp.dev

License

GPL v3