名称

类型

方法

说明

Node

interface

扩展

Runnable接口

void init()

节点初始化

接口Node: 代表分布式节点，Master或Slave节点，分布式节点，Master节MasterNodel和Slave节SlaveNode实现本接口

void start()

节点启动

void stop()

节点停止

void reset()

节点重启

名称

类型

方法

说明

MasterNode

class

实现Node接口

Master节点，负责管理Slave节点，分发命令给Slave

名称

类型

方法

说明

SlaveNode

class

实现Node接口

Slave节点，负责接收Master节点分发的命令，并执行命令，将结果封装成命令发送到Master节点

名称

类型

方法

说明

SlaveNode

class

实现Node接口

Slave节点，负责接收Master节点分发的命令，并执行命令，将结果封装成命令发送到Master节点

名称

类型

方法

说明

interface

Command produce()

产生Command

Command提供者接口，业务代码提供实现该接口的Provider，因为采用Slave主动拉取Command的机制，CommandProvider为SlaveNode用来生产Command。

后面考虑支持Master主动推送Command到Slave.

List produce(long count)

批量产生Commnad

名称

类型

方法

说明

interface

void init()

初始化

Slave端负责底层网络通信的，网络服务客户端，负责和Master节点通信。采用nio实现。

void start()

启动

void stop()

停止

void reset()

重启

名称

类型

方法

说明

class

void init()

初始化会话

Master和Slave之间的会话，Master通过Session来跟中，管理Slave。Session通过一个线程来接收Command，执行Command，发送Command。SessionManager负责管理, 分配,回收这个Session. SessionManager会定时转换Session的状态,如果Session的状态转换到MS_SESSION_STATE_DEAD 状态,就会在在下次被回收.但是如果Master接收到Slave的心跳命令,就会将Session的状态置为MS_SESSION_STATE_ALIVE ,以表示Slave还存活.

void start()

启动会话

void destroy()

销毁会话

void alive()

当Master接收到Slave的心跳Command时，会将调用本函数，将当前的Session置为“存活”状态

void free()

释放会话，已被以后重新利用，并不是销毁，防止频繁创建，销毁会话(线程)

void isDead

会话是否已经“死掉”，这意味着Master长时间没有收到对应的Slave的心跳Command，Master会认为这个Slave已经“死掉”。

void onRead()

NetWorkServer会在会话的Socket有数据可读时，会调用Session的这个函数，让Session接收Slave发送的数据包

void onWrite()

NetWorkServer会在会话的Socket可写时，调用Session的这个函数，Session可以将自己的数据输出缓存队列的数据通过网络发送到Slave。

void run

Runnable接口的函数，循环从自己的输入缓存队列中解析出Command并通过CommandDispatcher分发Command并将结果Command写到自己的输出缓冲队列.

void transitState()

根据Session当前的状态转换到下一个状态,SessionManager会有一个定时任务,负责调用本函数,来转换Session的状态.

名称

类型

方法

说明

interface

void init()

初始化

Master端负责底层网络通信的，网络服务器，负责和Slave节点通信。采用nio实现一个线程处理所有的网络操作。

void freeSession(Session session)

释放Session,实际上是被回收,以备再分配

SessionnewSession(java.nio.channels.SocketChannel channel)

分配Session

void destroy()

名称

类型

方法

说明

class

ByteBuffer

getPayLoad()

获得Comamnd的负载,业务相关的数据

Master和Slave之间交换的命令,业务可以定义的自己的Command并提供对应的Command处理器,Command可以用来分发任务,也可以用来传输数据,这完全由业务来决定怎么处理

void setPayLoad(ByteBuffer payLoad)

设置Comamnd的负载,业务相关的数据

Long getType()

获得Command的类型,业务可以定义自己的Command类型,并负责处理

void setType(Long type)

设置Command的类型,业务可以定义自己的Command类型,并负责处理

Session getSession()

Master端,获得Command对应的Session

void setSession(Session session)

Master端,设置Command对应的Session

名称

类型

方法

说明

interface

Command handle(Command command)

处理命令,并返回以Command封装的结果

负责处理Command的接口, 业务定义新的Command需要提供实现该接口的Command处理器

名称

类型

方法

说明

interface

void int()

初始化

Master和Slave负责分发Command的接口，通过业务配置的命令路由表，分发Command到具体的Command处理器

Command

dispatch(Command command)

通过业务配置的命令路由表，分发Command到具体的Command处理器