rpcx服务框架浅析3-服务发布流程

RPCX分布式服务框架主要致力于提供高性能和透明化的RPC远程服务调用。

服务发布

服务发布是服务提供方向注册中心注册服务的过程，以便服务消费方从注册中心查询并调用服务。本文以zookeeper作为注册中心说明rpcx框架服务发布过程。

服务Handler约定

rpcx框架规定服务Handler必须是如下形式：

func Handler(ctx context.Context, in *CmdIn, out *CmdOut) error

第一个参数：context.Context
第二个参数：输入参数(用户自己定义)
第三个参数：输出参数(用户自己定义)，必须是指针
函数返回值：必须是error

假设系统定义一个Hello服务

输入参数：

type CmdIn struct {Param string
}

输出参数：

type CmdOut struct {Result intInfo string
}

Hello服务：

type Hello struct {Param string
}func (this *Hello) Test1(ctx context.Context, in *CmdIn, out *CmdOut) error {fmt.Println("1 recv:",in)out.Result=12345678out.Info="set value"+in.Paramreturn nil
}func (this *Hello) Test2(ctx context.Context, in *CmdIn, out *CmdOut) error {fmt.Println("2 recv:",in)out.Result=0out.Info=in.Paramreturn nil
}

服务提供方启动流程中关键步骤

1.通过反射机制Build系统所有服务map

系统最终会生成一个map

type service struct {
name string //服务名称，如Hello
method map[string]*methodType //服务提供的所有方法，如Test1,Test2
}

serviceMap map[string]*service //系统所有服务，如Hello1,Hello2,Hello3....

消费方在申请服务的时候会输入服务名、方法名。通过serviceMap即可找出服务端对应的handler

2.将本机服务相关信息注册到zookeeper

如当前服务提供方地址为：tcp@192.168.10.25:10001，提供Hello服务，那么系统初始化时会向zookeeper写入如下信息：

Hello节点表示系统提供了Hello服务，服务消费方可以通过查询其下所有服务提供方信息。

临时节点的作用主要是：

服务提供方会定时向zookeeper写该节点，相当于心跳的作用，当服务提供方宕机后，临时节点消失，服务消费方能够知道服务提供方宕机。
服务消费方通过查询该节点信息，能够知道Hello服务有哪些服务提供方及RPC地址。

系列文章

rpcx服务框架浅析1-角色说明
rpcx服务框架浅析2-服务发布(以zookeeper作为注册中心的Provider例子)
rpcx服务框架浅析3-服务发布流程
rpcx服务框架浅析4-消费方服务引用
rpcx服务框架浅析5-消费方(以zookeeper作为注册中心的Consumer例子)
rpcx服务框架浅析6-注册中心
rpcx服务框架浅析7-负载均衡策略
rpcx服务框架浅析8-群集容错机制
rpcx服务框架浅析9-序列化
rpcx服务框架浅析10-扩展Plugin
rpcx服务框架浅析11-调用拦截链
rpcx服务框架浅析12-断路器
rpcx服务框架浅析13-远程调用