rpcx

rpcx

Easy to use and developer friendly RPC library

Difference Between Other RPC Libraries

• Once Callable established, local and remote are both in Full duplex mode.
• No more client or server roles, Callables can call/called each others
• Lots of Middlewares and developer can Custom their own middleware!
• It works without any proto files , just define functions as usual.
• Based on asynchronous I/O (liblpc) and provides synchronous call semantics
• High Performace: event drivend, msgpack(for serialize),reuse context,goroutine pool...

Usage

import "github.com/gen-iot/rpcx"

Overview

• Developer friendly
• Middlewares: dump,proxy,recover,validate...

Getting Started

RPC Functions Formal

Remember :param ctx,err always required

1. Both have in&out

func Function(ctx rpcx.Context, in InType)(out OutType, err error)

1. Only err

func Function(ctx rpcx.Context)(err error)

1. out and err

func Function(ctx rpcx.Context) (out OutType,err error)

1. in and err

func Function(ctx rpcx.Context, in InType)(err error)

Create RPC

rpc, err := rpcx.New()

Close RPC

err := rpc.Close()

Register RPC Function

rpc, err := rpcx.New()
std.AssertError(err, "new rpc")
rpc.RegFuncWithName(
    "hello", // manual specified func name
    func(ctx rpcx.Context, msg string) (string, error) {
        return "hello from server", nil
    })

Connect To RPC

sockAddr, err := liblpc.ResolveTcpAddr("127.0.0.1")
std.AssertError(err,"resolve addr")
callable := rpc.NewClientCallable(sockAddr,nil)
callable.Start()

Add Exist Conn To RPC

// `fd` must be a valid file descriptor
callable := rpc.NewConnCallable(fd, nil)
callable.Start()

Invoke RPC Functions

Suppose there is a remote function:

func hello(ctx rpcx.Context)(string,error)

Now call it

out := new(string)
err := callable.Call3(time.Second*5, "hello", out)
std.AssertError(err, "call 'hello'")
fmt.Println("result:",*out)

Callable Calls

All Call[0-6] support Timeout And Middlewares

Middleware

middlewares works like AOP as we know in java.

📌Import middlewares before use

import "github.com/gen-iot/rpcx/middleware"

RPC Core

📌middlewares apply on rpc core will affect whole rpc context

rpc, err := rpcx.New()
std.AssertError(err, "new rpc")
rpc.Use(
    middleware.Recover(true), // recover 
    middleware.ValidateStruct( // validator
        middleware.ValidateInOut,
        std.NewValidator(std.LANG_EN)),
)

RPC Functions

rpc, err := rpcx.New()
std.AssertError(err, "new rpc")
rpc.RegFuncWithName("hello",
    func(ctx rpcx.Context, msg string) (string, error) {
        return "hello from server", nil
    },
    middleware.LoginRequred(),  // require logined
    middleware.MustAdmin(),       // require admin role
)

Callable

err := callable.Call("hello",
    middleware.Recover(true), // recover 
)

More Example

try examples

License

Released under the MIT License