Evan：/* nginx 配置 */

2021-10-25T09:26:54Z

nginx 配置

新页面

=进阶=

http://rabbitmq.mr-ping.com/tutorials_with_python/[1]Hello_World.html

[https://zhuanlan.zhihu.com/p/63700605 透彻rabbitmq]

[https://www.zhihu.com/question/34243607/answer/1369889869 消息队列的使用场景是怎样的]

https://www.rabbitmq.com/getstarted.html

名师讲坛——Java微服务架构实战（SpringBoot+SpringCloud+Docker+RabbitMQ
http://product.china-pub.com/8066694#ml

http://product.china-pub.com/8063896#ml
Spring Boot微服务实战使用RabbitMQ、Eureka、Ribbon、Zuul和Cucumber开发RESTful服务

=站内资源=
[[Rabbitmq常用命令]]

[https://blog.csdn.net/belonghuang157405/article/details/83540148 docker简易搭建RabbitMQ集群HA-good]

=ins rabbitmq=
<pre>
Sep 22 2021
可以用alpine

cat docker-compose.yml
version: '3.2'
services:
rabbitmq:
image: rabbitmq:3.8.22-management-alpine
ports:
- "5672:5672"
- "4369:4369"
#- "1883:1883"
- "15672:15672"
- "25672:25672"

container_name: rabbitmq01

hostname: rabbitmq01
environment:

RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /

RABBITMQ_DEFAULT_USER: dddadmin

RABBITMQ_DEFAULT_PASS: ddddSNTTo886Gq

RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log

RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log

volumes:
- ./data/rabbitmq:/var/lib/rabbitmq

restart: always

</pre>
==info==
<pre> 适合于 3.610 and 3.7.5 版本
-p 15672:15672 http访问端口
-p 5672:5672 amqp访问端口
-p 4369 #unable to connect to epmd (port 4369) on rabbitmq01: address (cannot connect to host/port)

Thu Sep 10 18:33:00 CST 2020 试过了这个版本现在的能用
sed -i 's!rabbitmq:3.6.10-management!rabbitmq:3.7.26-management-alpine!' docker-compose.yml

git
cd /data/apps
git clone https://github.com/evan886/mq.git
mv mq/docker-compose-mqcluster/ . && rm -rf mq

把你要的在那台机器改为 docker-compose.yml 和改好相关配置然后删除其它的

</pre>
https://x-team.com/blog/set-up-rabbitmq-with-docker-compose/

下面开始的是mq cluster
==mq1==
===Note===
<pre>
如果是 alpine rabbitmq:3.6.10-management 换成其它基础不用变,除了进入容器变成 sh
sed -i 's!rabbitmq:3.6.10-management!rabbitmq:3.7.26-management-alpine!' docker-compose.yml

有一种是 node1 不加别 , node2 add node1 ; node3 add node1 and node2 但是 rabbitmqctl cluster_status 可能看起来有些node alarms是down的不过通过浏览器的不会 </pre>
<pre>

#记得 extra_hosts 改成你的相关IP
mkdir -p /home/data/docker-compose-mqcluster
cd /home/data/docker-compose-mqcluster
##"登录容器请执行:rabbitmq-plugins enable rabbitmq_management 才可>使用WEB管理页面"
vi docker-compose.yml

version: '3.1'
services:
rabbitmq:
image: rabbitmq:3.6.10-management
ports:
- "5672:5672"
- "4369:4369"
#- "1883:1883"
- "15672:15672"
- "25672:25672"

container_name: rabbitmqCluster01

hostname: rabbitmq01
extra_hosts:
#- "rabbitmq01:192.168.10.211"#不要加上自己，不然会老是重启的
- "rabbitmq02:192.168.10.212"
- "rabbitmq03:192.168.10.213"
environment:

RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /

RABBITMQ_DEFAULT_USER: lxtxadmin

RABBITMQ_DEFAULT_PASS: tSNTTo886Gq

RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log

RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log

volumes:
- ./data/rabbitmq:/var/lib/rabbitmq

restart: always
# docker-compose up -d
</pre>

==mq2==
<pre>
mkdir -p /home/data/docker-compose-mqcluster
cd /home/data/docker-compose-mqcluster

vi docker-compose.yml

version: '3.1'
services:
rabbitmq:
image: rabbitmq:3.6.10-management

ports:
- "5672:5672"
- "4369:4369"
#- "1883:1883"
- "15672:15672"
- "25672:25672"

container_name: rabbitmqCluster02
hostname: rabbitmq02
extra_hosts:
- "rabbitmq01:192.168.10.211"
#- "rabbitmq02:192.168.10.212" #不要加上自己，不然会老是重启的
- "rabbitmq03:192.168.10.213"
environment:
RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /
RABBITMQ_DEFAULT_USER: lxtxadmin
RABBITMQ_DEFAULT_PASS: tSNTTo886Gq
RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log
RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log
CLUSTERED: 'true'
CLUSTER_WITH: rabbit1
RAM_NODE: 'true'

volumes:
- ./data/rabbitmq:/var/lib/rabbitmq
restart: always

</pre>

==mq3==
<pre>
mkdir -p /home/data/docker-compose-mqcluster
cd /home/data/docker-compose-mqcluster

vi docker-compose.yml

version: '3.1'
services:
rabbitmq:
image: rabbitmq:3.6.10-management

ports:
- "5672:5672"
- "4369:4369"
#- "1883:1883"
- "15672:15672"
- "25672:25672"

container_name: rabbitmqCluster03

hostname: rabbitmq03
extra_hosts:
- "rabbitmq01:10.3.10.141"
- "rabbitmq02:10.3.10.142"
environment:

RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /

RABBITMQ_DEFAULT_USER: lxtxadmin

RABBITMQ_DEFAULT_PASS: tSNTTo886Gq

RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log

RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log
CLUSTERED: 'true'
CLUSTER_WITH: rabbit1
RAM_NODE: 'true'

volumes:

- ./data/rabbitmq:/var/lib/rabbitmq

restart: always
</pre>

=config=
==将节点2,3加入集群==
<pre>
#在rabbit2机器进入容器的命令行
sudo docker exec -it rabbitmqCluster02 sh #/bin/bash

#加入集群
rabbitmqctl stop_app && rabbitmqctl join_cluster rabbit@rabbitmq01 &&rabbitmqctl start_app

rabbit3执行相同的命令
docker exec -it rabbitmqCluster03 sh #/bin/bash
rabbitmqctl stop_app && rabbitmqctl join_cluster rabbit@rabbitmq01 &&rabbitmqctl start_app

查询集群状态
rabbitmqctl cluster_status
</pre>

== nginx 配置==
<pre>

#如果是yum nginx 在放在 conf.d/mq.conf
server {
listen 80;
server_name mq.com;

location / {
proxy_pass http://10.3.10.141:15672;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header Host $host;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;

}
}

NOTE selinux 记得关掉不然可能是502哦
#SELinux设置
getenforce #查看SELINUX工作模式

sed -i 's/SELINUX=enforcing/SELINUX=disabled/' /etc/selinux/config #禁用SELINUX
setenforce 0 #临时禁用SELINUX，无需重启

SELINUX=enforcing
#此项定义selinux状态。
#enforcing—是强制模式系统受selinux保护。就是你违反了策略，你就无法继续操作下去
#permissive—是提示模式系统不会受到selinux保护，只是收到警告信息。permissive就是Selinux有效，但是即使你违反了策略的话它让你继续操作，但是把你的违反的内容记录下来(警告信息)
#disabled—禁用selinux。

下面的配置是不对的会跑到框架里面去了

页面错误！请稍后再试～

listen 80;

server_name rabbitmq.com;
#index index.html index.html index.php;

#charset koi8-r;
charset utf-8;

location /{
proxy_pass http://cfb.rabbitmq.server:15672;
#proxy_set_header Host $host:$server_port;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
#proxy_set_header REMOTE-HOST $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
#index index.html index.htm index.php;
}

</pre>

==镜像模式==
在我的wiki上
[https://wiki.linuxchina.net/index.php/Rabbitmq%E5%B8%B8%E7%94%A8%E5%91%BD%E4%BB%A4#.E5.BC.80.E5.90.AF.E9.95.9C.E5.83.8F.E6.A8.A1.E5.BC.8F 开启镜像模式]

=RabbitMQ实现延迟队列(使用delay插件=
<pre>

docker cp rabbitmq_delayed_message_exchange-3.6.6.ez c77afe9fa73f:/plugins

: 进入docker容器内 docker exec -t rabbit bash

8. 执行命令让插件生效: 启动延时插件：
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
</pre>
https://www.jianshu.com/p/197715cea172

=troubleshooting =
<pre>

1.docker-compose.yml文件报错
ERROR: The Compose file './docker-compose.yml' is invalid because:
services.rabbitmq.environment.CLUSTERED contains true, which is an invalid type, it should be a string, number, or a null

CLUSTERED: true -->CLUSTERED: 'true'

绑hosts的前进不要全局FQ SSR常常坑我们

问题2
15672 端口不通也就是web界面打不开

问题镜像用了 rabbitmq 而不是rabbitmq-manager

发现过程 web打不开 15672 端口不能，而 5672是通的进入容器发现是ubuntu 而我记得以前是debian呀问了下sy才知道他换了，没全用我的，晕死，坑自己人啊

补救办法开启 rabbitmq-plugins enable rabbitmq_management

crash dump is being written to: erl_crash.dump...sh: echo: I/O error
原来是空间暴了呢

</pre>

https://www.rabbitmq.com/management.html
==RabbitMQ镜像集群脑裂 ==
<pre>

现象：
RabbitMQ GUI上显示

Network partition detected
Mnesia reports that this RabbitMQ cluster has experienced a network partition. There is a risk of losing data. Please read RabbitMQ documentation about network partitions and the possible solutions.

节点3 是挂，以节点1 为准在 node2 node3 上分别执行
rabbitmqctl stop_app
rabbitmqctl start_app

就行
</pre>

==端口在进入容器 cannot exec in a stopped state: unknown ==
今天是端口在 docker restart id 都不行，进程也还在的重启了 docker 服务才行了

==rabbitmq node not running==
<pre>

行情重启了一下 docker mq集群就好了

试过 telnet 15276 有点不太对一下就跳出来了

也登录不了容器一开始还以为是防火墙

docker exec -it af1934d27e21 /bin/bash
root@rabbitmq02:/# rabbitmqctl cluster_status
Cluster status of node rabbit@rabbitmq02
[{nodes,[{disc,[rabbit@rabbitmq01,rabbit@rabbitmq02,rabbit@rabbitmq03]}]},
{alarms,[]}]

再想加入报错
:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@rabbitmq02

root@rabbitmq02:/# rabbitmqctl join_cluster rabbit@rabbitmq01
Clustering node rabbit@rabbitmq02 with rabbit@rabbitmq01
Error: unable to connect to node rabbit@rabbitmq02: nodedown

DIAGNOSTICS
===========

attempted to contact: [rabbit@rabbitmq02]

rabbit@rabbitmq02:
* connected to epmd (port 4369) on rabbitmq02
* epmd reports node 'rabbit' running on port 25672
* TCP connection succeeded but Erlang distribution failed

* Distribution failed unexpectedly while waiting for challenge: {error,
closed}

current node details:
- node name: 'rabbitmq-cli-69@rabbitmq02'
- home dir: /var/lib/rabbitmq
- cookie hash: /HHYeuND8Y2blMJ8WoOg1g==

root@rabbitmq02:/# rabbitmqctl start_app
Starting node rabbit@rabbitmq02
Error: unable to connect to node rabbit@rabbitmq02: nodedown

DIAGNOSTICS
===========

attempted to contact: [rabbit@rabbitmq02]

rabbit@rabbitmq02:
current node details:
- node name: 'rabbitmq-cli-69@rabbitmq02'
- home dir: /var/lib/rabbitmq
- cookie hash: /HHYeuND8Y2blMJ8WoOg1g==

root@rabbitmq02:/# rabbitmqctl start_app
Starting node rabbit@rabbitmq02
Error: unable to connect to node rabbit@rabbitmq02: nodedown

DIAGNOSTICS
===========

attempted to contact: [rabbit@rabbitmq02]

rabbit@rabbitmq02:
* connected to epmd (port 4369) on rabbitmq02
* epmd reports node 'rabbit' running on port 25672
* TCP connection succeeded but Erlang distribution failed

* TCP connection to remote host has timed out. Is the Erlang distribution using TLS?

current node details:
- node name: 'rabbitmq-cli-97@rabbitmq02'
- home dir: /var/lib/rabbitmq
- cookie hash: /HHYeuND8Y2blMJ8WoOg1g==

重启 docker 服务再如上添加不过提示 The node is already a member of this cluster 所以应该是重启docker 就好了

今天是监听的IP不对模板的是10 我用的 192.168
</pre>

=单机版集群=
<pre>
version: '3.1'
services:
rabbitmq01:
image: rabbitmq:3.6.10-management
ports:
- "5672:5672"
#- "4369:4369"
- "15672:15672"
#- "25672:25672"
container_name: rabbitmqCluster01
hostname: rabbitmq01
environment:
RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /
RABBITMQ_DEFAULT_USER: lxtxadmin
RABBITMQ_DEFAULT_PASS: tSNTTo886Gq
RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log
RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log
volumes:
- ./data/rabbitmq:/var/lib/rabbitmq
restart: always

rabbitmq02:
image: rabbitmq:3.6.10-management
ports:
- "5673:5672"
#- "4369:4369"
- "15673:15672"
#- "25672:25672"
container_name: rabbitmqCluster02
hostname: rabbitmq02
links:
- rabbitmq01
environment:
RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /
RABBITMQ_DEFAULT_USER: lxtxadmin
RABBITMQ_DEFAULT_PASS: tSNTTo886Gq
RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log
RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log
volumes:
- ./data/rabbitmq02:/var/lib/rabbitmq
restart: always

rabbitmq03:
image: rabbitmq:3.6.10-management
ports:
- "5674:5672"
#- "4369:4369"
- "15674:15672"
#- "25672:25672"
container_name: rabbitmqCluster03
hostname: rabbitmq03
links:
- rabbitmq01
environment:
RABBITMQ_ERLANG_COOKIE: 'rabbitmqCookie'
RABBITMQ_DEFAULT_VHOST: /
RABBITMQ_DEFAULT_USER: lxtxadmin
RABBITMQ_DEFAULT_PASS: tSNTTo886Gq
RABBITMQ_LOGS: /var/lib/rabbitmq/rabbitmq.log
RABBITMQ_SASL_LOGS: /var/lib/rabbitmq/rabbitmq-sasl.log
volumes:
- ./data/rabbitmq03:/var/lib/rabbitmq
restart: always

然后再加入集群同上
</pre>
=python操作RabbitMQ=
<pre>

pip3 install pika

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# auth : send.py
import pika
# ######################### 生产者 #########################
credentials = pika.PlainCredentials('admin', 'tSNTTo886Gq')
#链接rabbit服务器（localhost是本机，如果是其他服务器请修改为ip地址）
connection = pika.BlockingConnection(pika.ConnectionParameters('192.168.10.51',5672,'/',credentials))
#创建频道
channel = connection.channel()
# 声明消息队列，消息将在这个队列中进行传递。如果将消息发送到不存在的队列，rabbitmq将会自动清除这些消息。如果队列不存在，则创建
channel.queue_declare(queue='hello')
#exchange -- 它使我们能够确切地指定消息应该到哪个队列去。
#向队列插入数值 routing_key是队列名 body是要插入的内容

channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print("开始队列")
#缓冲区已经flush而且消息已经确认发送到了RabbitMQ中，关闭链接
connection.close()

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# auth : receive.py

import pika

# ########################## 消费者 ##########################
credentials = pika.PlainCredentials('admin', 'tSNTTo886Gq')
#链接rabbit服务器（localhost是本机，如果是其他服务器请修改为ip地址）
connection = pika.BlockingConnection(pika.ConnectionParameters('192.168.10.51',5672,'/',credentials))
channel = connection.channel()

# 声明消息队列，消息将在这个队列中进行传递。如果队列不存在，则创建
channel.queue_declare(queue='hello')

# 定义一个回调函数来处理，这边的回调函数就是将信息打印出来。
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)

# 告诉rabbitmq使用callback来接收信息
chan.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
#TypeError: basic_consume() got multiple values for argument 'queue'

#channel.basic_consume(callback,
# queue='hello',
# no_ack=True)
# no_ack=True表示在回调函数中不需要发送确认标识

print(' [*] Waiting for messages. To exit press CTRL+C')

# 开始接收信息，并进入阻塞状态，队列里有信息才会调用callback进行处理。按ctrl+c退出。
channel.start_consuming()

python3 receive.py
[*] Waiting for messages. To exit press CTRL+C
[x] Received b'Hello World!'

</pre>

==py mq==
http://rabbitmq.mr-ping.com/

[https://www.cnblogs.com/pangguoping/p/5720134.html python - 操作RabbitMQ]

[https://www.cnblogs.com/shenh/p/10497244.html python 操作RabbitMq详解]

https://www.rabbitmq.com/tutorials/tutorial-one-python.html

https://www.jianshu.com/p/e5c9f85e18f1

https://www.cnblogs.com/kerwinC/p/5967584.html

=see also=

https://www.rabbitmq.com/clustering.html#peer-discovery-how-does-it-work

[https://my.oschina.net/u/4047016/blog/4553578 RabbitMQ 集群高可用原理及实战部署介绍]

[http://mknight.cn/RabbitMQ%20%E9%9B%86%E7%BE%A4%E9%83%A8%E7%BD%B2.html RabbitMQ 集群部署 ]

[http://josuelima.github.io/docker/rabbitmq/cluster/2017/04/19/setting-up-a-rabbitmq-cluster-on-docker.html Setting up a RabbitMQ Cluster on Docker]

[https://blog.csdn.net/qq_32488647/article/details/81941491 Docker分布式部署RabbitMQ集群]

[https://www.cnblogs.com/cheyunhua/p/8362200.html 多台机器值得看 Docker：搭建RabbitMQ集群]

[https://michael728.github.io/2019/06/07/docker-rabbitmq-env/ docker-compose 安装搭建 RabbitMQ 集群]

[https://blog.csdn.net/belonghuang157405/article/details/83540148 单一台机器母机docker简易搭建RabbitMQ集群]

[https://blog.csdn.net/jinyidong/article/details/80003362 RabbitMQ之集群搭建]

也是单物理机么？
https://www.cnblogs.com/vipstone/p/9362388.html

[https://blog.csdn.net/belonghuang157405/article/details/83540148 docker简易搭建RabbitMQ集群]

[https://cloud.tencent.com/developer/article/1391426 rabbitmq 原理、集群、基本运维操作、常见故障处理]

[[category:ops]]

Rabbitmq cluster on docker-compose - 版本历史

Evan：​/* nginx 配置 */

Evan：/* nginx 配置 */