RabbitMq集群镜像同步与应用

• RabbitMq集群镜像同步与应用
  • Queue存放问题
  • 启动镜像
    • 设置为ha-all政策
    • 问题1
    • 自动同步策略
    • 指定随机机器同步策略
    • 指定节点同步策略
  • .netcore重试连接集群

Queue存放问题

启动镜像

设置为ha-all政策

问题1

自动同步策略

指定随机机器同步策略

HTTP API

PUT /api/policies/%2f/ha-two
{
  "pattern":"^test",
  "definition": {
    "ha-mode":"exactly",
    "ha-params":2,
    "ha-sync-mode":"automatic"
  }
}

指定节点同步策略

.netcore重试连接集群

var factory = new ConnectionFactory()
{
    UserName = "bob",
    Password = "bob",
    AutomaticRecoveryEnabled = true,
    TopologyRecoveryEnabled = true
};
// 创建一个链接
using (var connection = factory.CreateConnection(new string[] { "10.211.55.4", "10.211.55.5", "10.211.55.6" }))
{
    // 创建一个通道
    using (var channel = connection.CreateModel())
    {
        var properties = channel.CreateBasicProperties();
        // 我们创建15条消息
        for (var i = 0; i < int.MaxValue; i++)
        {
            try
            {
                channel.BasicPublish(
                    exchange: string.Empty,
                    routingKey: "test1",
                    basicProperties: properties,
                    body: Encoding.UTF8.GetBytes($"新消息{i}")
                    );
                System.Console.WriteLine($"Publish: 新消息{i}");
            }
            catch (Exception ex)
            {
                System.Console.WriteLine($"[ERROR]:{ex.Message}");
            }
            finally
            {
                Thread.Sleep(3000);
            }
        }
        Console.WriteLine("Finish");
        Console.ReadLine();
    }
}