Disque集群部署

1. 下载代码

代码位置位于: https://github.com/antirez/disque/archive/1.0-rc1.tar.gz 可以使用wget来下载。

2.解压编译

tar -xvf 1.0-rc1.tar.gz
cd disque-1.0-rc1/
make
make test

3.启动服务开始测试

进入src 目录,可以看到我们需要的程序(disque,disque-server)已经编译完成。 按照下面的目录结构创建目录

进入到对应的目录启动disque_server

因为disque启动的时候会创建nodes.conf,所以必须到对应的目录启动 单个服务启动成功的结果: 全部启动成功的结果如下图所示:

4. 客户端连接##

全部客户端连接成功的结果: 查看当前的cluster. 可以看到目前的cluster_known_nodes 只有1个。 cluster_reachable_nodes 有0个。 增加一个cluster以后查看cluster. 可以看到目前的cluster_known_nodes 只有2个。 cluster_reachable_nodes 有1个。 cluster全部添加好以后的结果。 生产者客户端生产数据。 每个消费者读取数据

  • 第一个消费者

第二个消费者 第三个消费者 第四个消费者

停止一个cluster以后,查看cluster信息

可以看到可达节点数少一个。