[发明专利]应用于静态集群上的分布式通信系统及方法

摘要

本发明公开了一种应用于静态集群上的分布式通信系统及方法，在包括N台主机，m个应用服务进程的静态集群上，服务于该静态集群的分布式通信系统包括设于每台主机上的天使服务进程，极速配置库和m个天使客户端库；每个应用服务进程均调对应的用天使客户端库，天使服务进程和各个应用服务进程均与极速配置库连接，天使服务进程分别与各个应用服务进程连接，N≥1，m≥2；本发明具有面对静态集群环境、实现简单、效率高的特点。

主权项

1.一种应用于静态集群上的分布式通信系统的方法，其特征是，应用于静态集群上的分布式通信系统包括N台主机（2），m个应用服务进程（23）的静态集群上，服务于该静态集群的分布式通信系统包括设于每台主机上的天使服务进程（21），极速配置库（22）和m个天使客户端库（24）；每个应用服务进程均调用对应的 天使客户端库，天使服务进程和各个应用服务进程均与极速配置库连接，天使服务进程分别与各个应用服务进程连接，N≥1，m≥2；极速配置库中设有应用服务进程信息表与天使服务进程信息表；应用服务进程信息表由4个字段构成，4个字段分别为应用服务进程服务名，应用服务进程编号，应用服务进程对应的天使服务进程编号和应用服务进程在线状态；其中，应用服务进程服务名是应用服务进程信息表的主键；应用服务进程在线状态字段是动态字段，应用服务进程根据应用服务进程与天使服务进程之间的连接状态进行更新，其它字段均为静态字段；天使服务进程信息表由5个字段构成，5个字段分别为天使服务进程地址信息，天使服务进程编号，天使服务进程附属应用服务进程起始编号，天使服务进程附属应用服务进程个数和天使服务进程在线状态；天使服务进程地址信息是天使服务进程信息表的主键，天使服务进程为动态字段，天使服务进程在线状态根据本地天使服务进程与其它天使服务进程之间的连接状态进行更新，同时更新的包括天使服务进程附属的应用服务进程在线状态；包括关系表的插入过程：步骤1：从要插入行的行内容中取出主键内容；步骤2：对主键进行哈希计算，得到哈希值；步骤3：在哈希区寻找与哈希值对应节点的位置，如果该节点没有被使用，转入步骤4，如果该节点已经被使用，转入步骤6；步骤4：在节点内写入节点信息，节点信息包括主键、行号和下个节点偏移；其中，行号为关系表的表头中的待插入行号，表头包括行数目；步骤5：将行内容写入待插入行号的行，待插入行号加1；步骤6：按照节点信息中下一个节点偏移信息，依次寻找下一个节点，直到下一个节点偏移为‑1，将‑1改为拉链区可用节点偏移，在拉链区可用偏移的位置上，写入节点信息，将拉链区可用偏移号加1；步骤7：将行内容写入待插入行号的行，待插入行号加1；其中，哈希计算包括如下步骤：步骤1：采用公用的哈希算法对主键进行哈希，得到一个整数；步骤2：将整数对行数目取余，得到一个哈希值；还包括应用服务进程登录过程:步骤1：在主机i上，应用服务进程j在天使服务进程i上登录，应用服务进程j调用天使客户端库的登录接口，传入自己的服务名jX；i=1,2,…,N；j=1,2,…,m；步骤2：天使服务进程i接到应用服务进程j登录请求，按照服务名j查询查询本地极速配置库；如果查到极速配置库里面存在该服务的配置，返回应用服务进程j的编号及登录成功的信息，修改极速配置库内应用服务进程j的登录状态为已经登录，转入步骤3；如果没有查到极速配置库里面存在该服务的配置，返回‑1及登录失败的信息；步骤3：天使服务进程i将应用服务进程j的已登录状态广播发送给天使服务进程2到N；天使服务进程2至天使服务进程N收到应用服务进程j的已登录状态，分别转入步骤4；步骤4：天使服务进程2至天使服务进程N将应用服务进程j的已登录状态写入本地极速配置库；还包括应用服务进程之间通信过程：应用服务进程j向应用服务进程k发送一个消息；k=1,2,…,m；k≠j；步骤1：应用服务进程j通过本地极速配置库，按照应用服务进程k的服务名，查询应用服务进程k的编号与在线状态；若查询到应用服务进程的编号且应用服务进程的在线状态为在线，转入步骤2；反之，返回失败信息，通信结束；步骤2：应用服务进程j构建消息包，向天使服务进程i发送该消息包；步骤3：天使服务进程i收到该消息包，按照该消息包包头内容，查询极速配置库，查出应该转发的目标天使进程N，并查询目标天使进程N的在线状态；步骤4：天使服务进程i将消息包发送给天使服务进程N；步骤5：天使服务进程N收到该消息包，按照该消息包包头内容，查询极速配置库，查出应用服务进程k；步骤6：天使服务进程N将消息包发送给应用服务进程k。