mq集群之napster架构

《mq集群之napster架构》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、】JTangMQ集群之Napster架构一、架构图采用类似于Napster文件系统架构，即一个Master多个Slave，Master同时也具有Slave的功能。架构图如图1所示：图1集群架构图1.1.主服务器Master1.1.1Master的特点Master管理Destination的管理和客户端路由及普通Slave的功能。Master上保存着整个系统中Destination的信息以及他们存在哪个Slave上。Master的配置文件中Destination添加一个属性，表示他在哪个Slave上。只有Master上有专门管理员控制台，并可以通过它来监控所有的Slave的状态，管理员可

2、以通过控制台决定哪些Destination由哪个Slave来负责。创建的Destination如果没有分配出去，默认存放在Master上，分配给某个Slave，则从Master中移除，添加到Slave上。Master启动的时候，读取配置文件，按照配置文件中的分配Destination.1.1.2Master启动过程A．读取Slave列表信息，然后往这些Slave上发送Master启动信息，让所有在线的Slave全部重启；】JTangMQ集群之Napster架构一、架构图采用类似于Napster文件系统架构，即一个Master多个Slave，Master同时也具有Slave的功能。架构图

3、如图1所示：图1集群架构图1.1.主服务器Master1.1.1Master的特点Master管理Destination的管理和客户端路由及普通Slave的功能。Master上保存着整个系统中Destination的信息以及他们存在哪个Slave上。Master的配置文件中Destination添加一个属性，表示他在哪个Slave上。只有Master上有专门管理员控制台，并可以通过它来监控所有的Slave的状态，管理员可以通过控制台决定哪些Destination由哪个Slave来负责。创建的Destination如果没有分配出去，默认存放在Master上，分配给某个Slave，则从Ma

4、ster中移除，添加到Slave上。Master启动的时候，读取配置文件，按照配置文件中的分配Destination.1.1.2Master启动过程A．读取Slave列表信息，然后往这些Slave上发送Master启动信息，让所有在线的Slave全部重启；】JTangMQ集群之Napster架构一、架构图采用类似于Napster文件系统架构，即一个Master多个Slave，Master同时也具有Slave的功能。架构图如图1所示：图1集群架构图1.1.主服务器Master1.1.1Master的特点Master管理Destination的管理和客户端路由及普通Slave的功能。Mas

5、ter上保存着整个系统中Destination的信息以及他们存在哪个Slave上。Master的配置文件中Destination添加一个属性，表示他在哪个Slave上。只有Master上有专门管理员控制台，并可以通过它来监控所有的Slave的状态，管理员可以通过控制台决定哪些Destination由哪个Slave来负责。创建的Destination如果没有分配出去，默认存放在Master上，分配给某个Slave，则从Master中移除，添加到Slave上。Master启动的时候，读取配置文件，按照配置文件中的分配Destination.1.1.2Master启动过程A．读取Slave列

6、表信息，然后往这些Slave上发送Master启动信息，让所有在线的Slave全部重启；A．Master启动结束后，将所有的Destination信息发送给对应的Slave里，标识哪些已经成功的发送给Slave了，还有没发给对应Slave的，及对应Slave没有接收的，定期的继续发。B．Master与Slave之间的通讯采用Mina。1.1.1Master配置文件Master具有jtangmq_master.xml和jtangmqconfig.xml两个配置文件。其中jtangmq_master.xml为该Master所具有的Slave的配置信息，包括Master开通的与Slave通讯

7、的端口（这个端口可能没用，先留着）及各Slave的名字和IP和与Master通讯的端口。这个配置文件只有管理员通过控制台可改，Slave不能操作这个文件（当然也可以在未启动前，手动配置修改这个文件）。jtangmqconfig.xml文件是基于单机版的JTangMQ的配置文件来的，稍做了修改：Destination节点内之前只有一个Queues和一个Topics节点，现改为由多个Queues和多个Topics组成，其中每个Queues和每个To