FolkMQ v1.7.8

部署 Single-Proxy 模式集群说明

Single-Proxy 模式集群,需要启动(技术架构模型,参考: 《Socket.D 集群模式》):

  • 一个 folkmq-proxy 服务实例
  • 多个 folkmq-broker 服务实例,
    • 每个实例连接 folkmq-proxy 服务,且自己不再启动消息端口
    • 每个实例的快照持久化数据,各自独立

1、部署示例

  • docker-compose 部署方式

下载 docker-compose-cluster.yml,运行命令:

docker-compose -f docker-compose-cluster.yml up

client 连 folkmq-proxy 地址

//客户端
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
        .nameAs("demoapp")
        .connect();
  • jar 部署方式

启动服务

#启动一个 folkmq-proxy 服务
java -Dserver.port=8602 -jar folkmq-proxy.jar

#启动两个 folkmq-server 服务
java -Dserver.port=8101 -Dfolkmq.broker='folkmq://127.0.0.1:18602' -jar folkmq-broker.jar
java -Dserver.port=8102 -Dfolkmq.broker='folkmq://127.0.0.1:18602' -jar folkmq-broker.jar

client 连 folkmq-proxy 地址

//客户端
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
        .nameAs("demoapp")
        .connect();

2、部署架构示意图

在 folkmq-broker 层面,多了一条(或多条)副线。体系内,会采用轮询负载均衡策略