Server

    You can implements services in Server side.

    The type of services is not important. You can use customized type to keep states or use or int simplely.

    You should start a TCP or UDP server to serve services.

    And you can aslo set some plugins to add features to the server.

    As service providers, you should define some service first.Currently rpcx only support exported methods as functions of service.And the exported method must satisfy the below rules:

    • exported method of exported type
    • three arguments, the first is of context.Context, both of exported type for three arguments
    • the third argument is a pointer
    • one return value, of type error
      you can use RegisterName to register methods of rcvr and name of this service is name.If you use Register, the generated service name is type name of rcvr.You can add meta data of this service in registry, that can be used by clients or service manager, for example, weight、geolocation、metrics.

    There is an example that implements a Mul method:

    1. import "context"
    3. type Args struct {
    4.     A int
    5.     B int
    6. }
    8. type Reply struct {
    9.     C int
    10. }
    13. func (t *Arith) Mul(ctx context.Context, args *Args, reply *Reply) error {
    14.     reply.C = args.A * args.B
    15.     return nil
    16. }

    And you can define args as Args, this service aslo works.

    Server

    After you define services, you should want to explore to users. You should start a TCP server or UDP server to listen.

    The server supports below approaches to start, serve and close:

    First you use NewServer to create a server instance with options. Second you can invokde Serve or ServeHTTP to serve.

    The server contains some fields (and unexported fields):

    1. type Server struct {
    2.     Plugins PluginContainer
    3.     // AuthFunc can be used to auth.
    4.     AuthFunc func(ctx context.Context, req *protocol.Message, token string) error
    5.     // contains filtered or unexported fields
    6. }

    Plugins caontains all plugins in this server. We will introduce it in later chapters.

    rpcx provides three OptionFn to set options:

    It can set readTimeout, writeTimeout and tls.Config.

    ServeHTTP uses a HTTP connection to serve services. It hijacks the connnection to communicate with clients.

    uses TCP or UDP ptotocol to communicate with clients.

    rpcx supports the below network:

    • tcp: recommended network
    • http: hijack http connection
    • unix: unix domain sockets
    • reuseport: use SO_REUSEPORT socket option, only support Linux kernel 3.9+
    • quic: support
    • kcp: sopport kcp protocol
      There is a server example:
    1. package main
    3.     "flag"
    5.     example "github.com/rpcx-ecosystem/rpcx-examples3"
    6.     "github.com/smallnest/rpcx/server"
    7. )
    9. var (
    10.     addr = flag.String("addr", "localhost:8972", "server address")
    11. )
    13. func main() {
    14.     flag.Parse()
    16.     s := server.NewServer()
    17.     //s.RegisterName("Arith", new(example.Arith), "")
    18.     s.Register(new(example.Arith), "")
    19.     s.Serve("tcp", *addr)

    By smallnest updated 2018-12-04 11:47:26