RabbitMQ 使用与原理

192.168.16.137 node1
192.168.16.138 node2
192.168.16.139 node3

scp /var/lib/rabbitmq/.erlang.cookie root@node2:/var/lib/rabbitmq/.erlang.cookie
scp /var/lib/rabbitmq/.erlang.cookie root@node3:/var/lib/rabbitmq/.erlang.cookie

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@node2
rabbitmqctl start_app

Cluster name:rabbitenodel

Disk Nodes

rabbit@nodel
rabbitanode2
rabbitanode3

Running Nodes

rabbit@nodel
rabbitanode2
rabbitenode3

Versions

rabbit@nodel:RabbitMQ 3.8.16 on Erlang 23.3.4.11
rabbitanode2:RabbitMQ 3.8.16 on Erlang 23.3.4.11
rabbitenode3:RabbitMQ 3.8.16 on Erlang 23.3.4.11

Maintenance status

Node:rabbit@nodel,status:not under maintenance
Node:rabbitenode2,status:not under maintenance
Node:rabbitanode3,status:not under maintenance

Alarms

(none)

Network Partitions

(none)

Listeners

Node:rabbitenodel,interface:[:]port:15672,protocol:http,purpose:HTTP API
Node:rabbitenodel,interface:[:]port:25672,protocol:clustering,purpose:inter-node and CLI tool communication
Node:rabbitanodel,interface:[]port:5672,protocol:amgp,purpose:AMQP 0-9-1 and AMQP 1.0
Node:rabbitenode2,interface:[:]port:15672,protocol:http,purpose:HTTP API
Node:rabbit@node2,interface:[]port:25672,protocol:clustering,purpose:inter-node and CLI tool communication
Node:rabbitenode2,interface:[:]port:5672,protocol:amqp,purpose:AMQP 0-9-1 and AMQP 1.0
Node:rabbitenode3,interface:[:]port:15672,protocol:http,purpose:HTTP API
Node:rabbitanode3,interface:[:]port:25672,protocol:clustering,purpose:inter-node and CLI tool communication
Node:rabbitanode3,interface:[]port:5672,protocol:amqp,purpose:AMQP 0-9-1 and AMQP 1.0

Feature flags

Flag:drop unroutable metric,state:enabled
Flag:empty_basic_get_metric,state:enabled
Flag:implicit_default_bindings,state:enabled
Flag:maintenance_mode_status,state:enabled
Flag:quorum_queue,state:enabled

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
rabbitmqctl cluster_status
rabbitmgctl forget cluster_node rabbit@node2 (node1节点上执行)

·Name：policy的名称，用户自定义。
·Pattern：queue的匹配模式（正则表达式）。^表示所有队列都是镜像队列。
·Definition：镜像定义，包括三个部分ha-sync-mode、ha-mode、ha-params。
    。ha-mode：指明镜像队列的模式，有效取值范围为all/exactly/nodes。
        ·all：表示在集群所有的代理上进行镜像。
        ·exactly：表示在指定个数的代理上进行镜像，代理的个数由ha-params指定。
        ·nodes：表示在指定的代理上进行镜像，代理名称通过ha-params指定。
    。ha-params：ha-mode模式需要用到的参数。
    。ha-sync-mode：表示像队列中消息的同步方式，有效取值范围为：automatic，manually。
·automatic：表示自动向master同步数据。
·manually：表示手动向masterl同步数据。
·Priority：可选参数，policy的优先级。

#全局配置
global
    #设置日志
    log 127.0.0.1 local0 info
    #当前工作日录
    chroot /usr/local/haproxy
    #用户与用户细
    user haproxy
    group haproxy
    #运行进程ID
    uid 99
    gid 99
    #守护进程启动
    daemon
    #最人连接数
    maxconn 4096
    
# 默认配置
defaults
    #应用全局的日志配置
    log global
    #默认的模式mode{tcp http|health}
    #TCP是4层，HTTP是7层，health只返回oK
    mode tcp
    #日志类别tcp1og
    option tcplog
    #不记录健康检查日志信息
    option dontlognull
    #3次失败则认为服务不可用
    retries 3
    #每个进程可用的最大连接数
    maxconn 2000
    #连接超时
    timeout connect 5s
    #客户端超时
    timeout client 120s
    #服务端超时
    timeout server 120s
    
#绑定配置
listen rabbitmq_cluster
    # 5672 已被占用
    bind 192.168.16.138:5671
    #配置TCP模式
    mode tcp
    #简单的轮询
    balance roundrobin
    #RabbitMo集群节点配置
    server node1 192.168.16.137:5672 check inter 5000 rise 2 fall 2
    server node2 192.168.16.138:5672 check inter 5000 rise 2 fall 2
    server node3 192.168.16.139:5672 check inter 5000 rise 2 fall 2

#haproxy监控页面地址
listen monitor
    bind 192.168.16.138:8100
    mode http
    option httplog
    stats enable
    #项日名为rabbitmq_stats,ip+端口+项目名即可访问
    stats uri /rabbitmq_stats
    #自动刷新时间
    stats refresh 5s

> service haproxy start|stop|restartreload|condrestart|statuscheck