# 拉取官方镜像（含管理插件）
docker pull rabbitmq:4-management

# 启动容器
docker run -d \
  --name rabbitmq \
  -p 5672:5672 \
  -p 15672:15672 \
  -e RABBITMQ_DEFAULT_USER=admin \
  -e RABBITMQ_DEFAULT_PASS=admin123 \
  -v rabbitmq_data:/var/lib/rabbitmq \
  rabbitmq:4-management

# 检查容器状态
docker ps --filter name=rabbitmq

# 查看日志
docker logs rabbitmq --tail 50

# 验证管理界面
curl -u admin:admin123 http://localhost:15672/api/overview

# 使用 rabbitmqctl 检查
docker exec rabbitmq rabbitmqctl status
docker exec rabbitmq rabbitmqctl list_queues

# 安装依赖
sudo apt-get update
sudo apt-get install -y curl gnupg apt-transport-https

# 添加 RabbitMQ 签名密钥
curl -1sLf 'https://github.com/rabbitmq/signing-keys/releases/download/3.0/rabbitmq-release-signing-key.asc' | sudo gpg --dearmor -o /usr/share/keyrings/com.rabbitmq.team.gpg

# 添加 Erlang 仓库
curl -1sLf 'https://github.com/rabbitmq/signing-keys/releases/download/3.0/cloudsmith.rabbitmq-erlang.E495BB49CC4BBE5B.key' | sudo gpg --dearmor -o /usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg

# 添加仓库源
echo "deb [arch=amd64 signed-by=/usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg] https://ppa1.rabbitmq.com/rabbitmq/rabbitmq-erlang/deb/ubuntu jammy main" | sudo tee /etc/apt/sources.list.d/rabbitmq.list

echo "deb [signed-by=/usr/share/keyrings/com.rabbitmq.team.gpg] https://ppa1.rabbitmq.com/rabbitmq/rabbitmq-server/deb/ubuntu jammy main" | sudo tee -a /etc/apt/sources.list.d/rabbitmq.list

sudo apt-get update
sudo apt-get install -y rabbitmq-server

# 启动服务
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

# 查看状态
sudo systemctl status rabbitmq-server
sudo rabbitmqctl status

# 安装依赖
sudo yum install -y epel-release
sudo yum install -y socat logrotate

# 导入签名密钥
sudo rpm --import 'https://github.com/rabbitmq/signing-keys/releases/download/3.0/rabbitmq-release-signing-key.asc'

# 添加仓库
cat << 'EOF' | sudo tee /etc/yum.repos.d/rabbitmq.repo
[rabbitmq_erlang]
name=rabbitmq_erlang
baseurl=https://ppa1.rabbitmq.com/rabbitmq/rabbitmq-erlang/rpm/el/8/$basearch
gpgcheck=1
enabled=1
gpgkey=https://github.com/rabbitmq/signing-keys/releases/download/3.0/rabbitmq-release-signing-key.asc

[rabbitmq_server]
name=rabbitmq_server
baseurl=https://ppa1.rabbitmq.com/rabbitmq/rabbitmq-server/rpm/el/8/$basearch
gpgcheck=1
enabled=1
gpgkey=https://github.com/rabbitmq/signing-keys/releases/download/3.0/rabbitmq-release-signing-key.asc
EOF

sudo yum install -y rabbitmq-server
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

# 启用管理插件
sudo rabbitmq-plugins enable rabbitmq_management

# 验证插件状态
sudo rabbitmq-plugins list

# 重启服务使插件生效
sudo systemctl restart rabbitmq-server

# 添加用户
sudo rabbitmqctl add_user myuser mypassword

# 设置用户角色
sudo rabbitmqctl set_user_tags myuser administrator

# 设置用户权限（VHost / 配置权限 / 写权限 / 读权限）
sudo rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*"

# 查看所有用户
sudo rabbitmqctl list_users

# 查看用户权限
sudo rabbitmqctl list_permissions

# 修改密码
sudo rabbitmqctl change_password myuser newpassword

# 删除用户
sudo rabbitmqctl delete_user guest

# 清除用户权限
sudo rabbitmqctl clear_permissions -p / myuser

# 添加用户
curl -u admin:admin123 -X PUT http://localhost:15672/api/users/myuser \
  -H "Content-Type: application/json" \
  -d '{"password":"mypassword","tags":"administrator"}'

# 设置权限
curl -u admin:admin123 -X PUT http://localhost:15672/api/permissions/%2F/myuser \
  -H "Content-Type: application/json" \
  -d '{"configure":".*","write":".*","read":".*"}'

# 创建 VHost
sudo rabbitmqctl add_vhost production

# 查看所有 VHost
sudo rabbitmqctl list_vhosts

# 设置用户权限
sudo rabbitmqctl set_permissions -p production myuser ".*" ".*" ".*"

# 删除 VHost
sudo rabbitmqctl delete_vhost production

# /etc/rabbitmq/rabbitmq.conf

# === 网络配置 ===
# 监听端口
listeners.tcp.default = 5672
# 管理界面端口
management.tcp.port = 15672

# === 内存限制 ===
# 内存阈值（系统内存的 60%）
vm_memory_high_watermark.relative = 0.6
# 内存告警后的消息发布策略
vm_memory_high_watermark_paging_ratio = 0.75

# === 磁盘限制 ===
# 磁盘空闲空间阈值
disk_free_limit.absolute = 2GB

# === 连接配置 ===
# 最大连接数
# channel_max = 2048
# 心跳超时（秒）
heartbeat = 60

# === 日志配置 ===
log.file.level = info
log.dir = /var/log/rabbitmq

# === 安全配置 ===
# 禁用默认 guest 用户远程登录
loopback_users.guest = true

# === 队列默认配置 ===
# 默认队列类型（quorum 或 classic）
# default_queue_type = quorum

%% /etc/rabbitmq/advanced.config
[
  {rabbit, [
    {tcp_listen_options, [
      {backlog, 128},
      {nodelay, true},
      {exit_on_close, false},
      {sndbuf, 196608},
      {recbuf, 196608}
    ]},
    {collect_statistics_interval, 5000},
    {queue_index_embed_msgs_below, 4096}
  ]}
].

# docker-compose.yml
version: '3.8'

services:
  rabbitmq1:
    image: rabbitmq:4-management
    container_name: rabbitmq1
    hostname: rabbitmq1
    environment:
      RABBITMQ_ERLANG_COOKIE: "my_secret_cookie"
      RABBITMQ_DEFAULT_USER: admin
      RABBITMQ_DEFAULT_PASS: admin123
    ports:
      - "5672:5672"
      - "15672:15672"
    volumes:
      - rabbitmq1_data:/var/lib/rabbitmq

  rabbitmq2:
    image: rabbitmq:4-management
    container_name: rabbitmq2
    hostname: rabbitmq2
    environment:
      RABBITMQ_ERLANG_COOKIE: "my_secret_cookie"
    ports:
      - "5673:5672"
      - "15673:15672"
    volumes:
      - rabbitmq2_data:/var/lib/rabbitmq

  rabbitmq3:
    image: rabbitmq:4-management
    container_name: rabbitmq3
    hostname: rabbitmq3
    environment:
      RABBITMQ_ERLANG_COOKIE: "my_secret_cookie"
    ports:
      - "5674:5672"
      - "15674:15672"
    volumes:
      - rabbitmq3_data:/var/lib/rabbitmq

volumes:
  rabbitmq1_data:
  rabbitmq2_data:
  rabbitmq3_data:

# 启动集群
docker-compose up -d

# 将 rabbitmq2 加入集群
docker exec rabbitmq2 rabbitmqctl stop_app
docker exec rabbitmq2 rabbitmqctl reset
docker exec rabbitmq2 rabbitmqctl join_cluster rabbit@rabbitmq1
docker exec rabbitmq2 rabbitmqctl start_app

# 将 rabbitmq3 加入集群
docker exec rabbitmq3 rabbitmqctl stop_app
docker exec rabbitmq3 rabbitmqctl reset
docker exec rabbitmq3 rabbitmqctl join_cluster rabbit@rabbitmq1
docker exec rabbitmq3 rabbitmqctl start_app

# 验证集群状态
docker exec rabbitmq1 rabbitmqctl cluster_status

# 所有队列在所有节点上镜像
docker exec rabbitmq1 rabbitmqctl set_policy ha-all \
  '.*' '{"ha-mode":"all","ha-sync-mode":"automatic"}' \
  --apply-to queues

# Cookie 文件权限
chmod 400 /var/lib/rabbitmq/.erlang.cookie
chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie