您好,登錄后才能下訂單哦!
這篇文章主要講解了“RabbitMQ消息中間件搭建過程”,文中的講解內容簡單清晰,易于學習與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學習“RabbitMQ消息中間件搭建過程”吧!
消息中間件也可以稱消息隊列,是指用高效可靠的消息傳遞機制進行與平臺無關的數據交流,并基于數據通信來進行分布式系統的集成。通過提供消息傳遞和消息隊列模型,可以在分布式環境下擴展進程的通信。 RabbitMQ是使用Erlang語言開發的開源消息隊列系統,基于AMQP協議來實現。AMQP的主要特征是面向消息、隊列、路由(包括點對點和發布/訂閱)、可靠性、安全。AMQP協議更多用在企業系統內對數據一致性、穩定性和可靠性要求很高的場景,對性能和吞吐量的要求還在其次。 Erlang是一種通用的面向并發的編程語言 特點
可靠性
擴展性
高可用性
多種協議
多語言客戶端
管理界面
插件機制
準備三臺虛擬機 192.168.13.139 rabbitmq-1 192.168.13.142 rabbitmq-2 192.168.13.143 rabbitmq-3
配置hosts文件更改三臺MQ節點的計算機名分別為rabbitmq-1、rabbitmq-2 和rabbitmq-3,然后修改hosts配置件,并關閉防火墻和selinux
192.168.13.139 [root@rabbitmq-1 ~]# hostnamectl set-hostname rabbitmq-1 [root@rabbitmq-1 ~]# vim /etc/hosts 127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 ::1 localhost localhost.localdomain localhost6 localhost6.localdomain6 192.168.13.139 rabbitmq-1 192.168.13.142 rabbitmq-2 192.168.13.143 rabbitmq-3 [root@rabbitmq-1 ~]# systemctl stop firewalld && setenforce 0
192.168.13.142 [root@rabbitmq-2 ~]# hostnamectl set-hostname rabbitmq-2 [root@rabbitmq-2 ~]# vim /etc/hosts 127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 ::1 localhost localhost.localdomain localhost6 localhost6.localdomain6 192.168.13.139 rabbitmq-1 192.168.13.142 rabbitmq-2 192.168.13.143 rabbitmq-3 [root@rabbitmq-2 ~]# systemctl stop firewalld && setenforce 0
192.168.13.143 [root@rabbitmq-3 ~]# hostnamectl set-hostname rabbitmq-3 [root@rabbitmq-3 ~]# vim /etc/hosts 127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 ::1 localhost localhost.localdomain localhost6 localhost6.localdomain6 192.168.13.139 rabbitmq-1 192.168.13.142 rabbitmq-2 192.168.13.143 rabbitmq-3 [root@rabbitmq-3 ~]# systemctl stop firewalld && setenforce 0
安裝rabbitmq軟件以及配置
192.168.13.139 [root@rabbitmq-1 ~]# yum install -y *epel* gcc-c++ unixODBC unixODBC-devel openssl-devel ncurses-devel 1.yum安裝erlang [root@rabbitmq-1 ~]# wget --content-disposition https://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-20.3-1.el7.centos.x86_64.rpm/download.rpm #Erlang環境包 [root@rabbitmq-1 ~]# yum install erlang-20.3-1.el7.centos.x86_64.rpm -y 測試; [root@rabbitmq-1 ~]# erl Erlang/OTP 20 [erts-9.3] [source] [64-bit] [smp:1:1] [ds:1:1:10] [async-threads:10] [hipe] [kernel-poll:false] Eshell V9.3 (abort with ^G) 1> 2.安裝rabbitmq [root@rabbitmq-1 ~]# wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.5/rabbitmq-server-3.7.5-1.el7.noarch.rpm [root@rabbitmq-1 ~]# yum -y install rabbitmq-server-3.7.5-1.el7.noarch.rpm 3.啟動 [root@rabbitmq-1 ~]# systemctl daemon-reload [root@rabbitmq-1 ~]# systemctl start rabbitmq-server [root@rabbitmq-1 ~]# systemctl enable rabbitmq-server [root@rabbitmq-1 ~]# systemctl status rabbitmq-server [root@rabbitmq-1 ~]# rabbitmq-plugins enable rabbitmq_management #管理界面 #如果報錯,重啟服務就好了
192.168.13.139 4.創建用戶 注意:在一臺機器操作 添加用戶和密碼 [root@rabbitmq-1 ~]# rabbitmqctl add_user yjssjm yjssjm Adding user "yjssjm" ... 設置為管理員 [root@rabbitmq-1 ~]# rabbitmqctl set_user_tags yjssjm administrator Setting tags for user "yjssjm" to [administrator] ... 查看用戶 [root@rabbitmq-1 ~]# rabbitmqctl list_users Listing users ... guest [administrator] yjssjm [administrator] ...done. [root@rabbitmq-1 ~]# rabbitmqctl set_permissions -p "/" yjssjm ".*" ".*" ".*" Setting permissions for user "yjssjm" in vhost "/" ... #此處設置權限時注意'.*'之間需要有空格 三個'.*'分別代表了conf權限,read權限與write權限 例如:當沒有給 5.開啟用戶遠程登錄 [root@rabbitmq-1 ~]# cd /etc/rabbitmq/ [root@rabbitmq-1 rabbitmq]# cp /usr/share/doc/rabbitmq-server-3.7.5/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config [root@rabbitmq-1 rabbitmq]# ls enabled_plugins rabbitmq.config [root@rabbitmq-1 rabbitmq]# vim rabbitmq.config 修改如下: 在61行左右 {loopback_users, []} [root@rabbitmq-1 ~]# systemctl restart rabbitmq-server #重啟服務
192.168.13.142 [root@rabbitmq-2 ~]# yum install -y *epel* gcc-c++ unixODBC unixODBC-devel openssl-devel ncurses-devel 1.yum安裝erlang [root@rabbitmq-2 ~]# wget --content-disposition https://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-20.3-1.el7.centos.x86_64.rpm/download.rpm #Erlang環境包 [root@rabbitmq-2 ~]# yum install erlang-20.3-1.el7.centos.x86_64.rpm -y [root@rabbitmq-2 ~]# erl Erlang/OTP 20 [erts-9.3] [source] [64-bit] [smp:1:1] [ds:1:1:10] [async-threads:10] [hipe] [kernel-poll:false] Eshell V9.3 (abort with ^G) 1> 2.安裝rabbitmq [root@rabbitmq-2 ~]# wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.5/rabbitmq-server-3.7.5-1.el7.noarch.rpm [root@rabbitmq-2 ~]# yum -y install rabbitmq-server-3.7.5-1.el7.noarch.rpm 3.啟動 [root@rabbitmq-2 ~]# systemctl daemon-reload [root@rabbitmq-2 ~]# systemctl start rabbitmq-server [root@rabbitmq-2 ~]# systemctl enable rabbitmq-server [root@rabbitmq-2 ~]# systemctl status rabbitmq-server [root@rabbitmq-2 ~]# rabbitmq-plugins enable rabbitmq_management #管理界面 #如果報錯,重啟服務就好了 4.開啟用戶遠程登錄 [root@rabbitmq-2 ~]# cd /etc/rabbitmq/ [root@rabbitmq-2 rabbitmq]# cp /usr/share/doc/rabbitmq-server-3.7.5/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config [root@rabbitmq-2 rabbitmq]# ls enabled_plugins rabbitmq.config [root@rabbitmq-2 rabbitmq]# vim rabbitmq.config 修改如下: 在61行左右 {loopback_users, []} [root@rabbitmq-2 ~]# systemctl restart rabbitmq-server
192.168.13.143 [root@rabbitmq-3 ~]# yum install -y *epel* gcc-c++ unixODBC unixODBC-devel openssl-devel ncurses-devel 1.yum安裝erlang [root@rabbitmq-3 ~]# wget --content-disposition https://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-20.3-1.el7.centos.x86_64.rpm/download.rpm #Erlang環境包 [root@rabbitmq-3 ~]# yum install erlang-20.3-1.el7.centos.x86_64.rpm -y [root@rabbitmq-3 ~]# erl Erlang/OTP 20 [erts-9.3] [source] [64-bit] [smp:1:1] [ds:1:1:10] [async-threads:10] [hipe] [kernel-poll:false] Eshell V9.3 (abort with ^G) 1> 2.安裝rabbitmq [root@rabbitmq-3 ~]# wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.5/rabbitmq-server-3.7.5-1.el7.noarch.rpm [root@rabbitmq-3 ~]# yum -y install rabbitmq-server-3.7.5-1.el7.noarch.rpm 3.啟動 [root@rabbitmq-3 ~]# systemctl daemon-reload [root@rabbitmq-3 ~]# systemctl start rabbitmq-server [root@rabbitmq-3 ~]# systemctl enable rabbitmq-server [root@rabbitmq-3 ~]# systemctl status rabbitmq-server [root@rabbitmq-3 ~]# rabbitmq-plugins enable rabbitmq_management #管理界面 #如果報錯,重啟服務就好了 4.開啟用戶遠程登錄 [root@rabbitmq-3 ~]# cd /etc/rabbitmq/ [root@rabbitmq-3 rabbitmq]# cp /usr/share/doc/rabbitmq-server-3.7.5/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config [root@rabbitmq-3 rabbitmq]# ls enabled_plugins rabbitmq.config [root@rabbitmq-3 rabbitmq]# vim rabbitmq.config 修改如下: 在61行左右 {loopback_users, []} [root@rabbitmq-3 ~]# systemctl restart rabbitmq-server
查看端口 [root@rabbitmq-1 rabbitmq]# netstat -lntp Active Internet connections (only servers) Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name tcp 0 0 0.0.0.0:4369 0.0.0.0:* LISTEN 1205/epmd tcp 0 0 0.0.0.0:22 0.0.0.0:* LISTEN 985/sshd tcp 0 0 0.0.0.0:15672 0.0.0.0:* LISTEN 988/beam.smp tcp 0 0 127.0.0.1:25 0.0.0.0:* LISTEN 1285/master tcp 0 0 0.0.0.0:25672 0.0.0.0:* LISTEN 988/beam.smp tcp6 0 0 :::4369 :::* LISTEN 1205/epmd tcp6 0 0 :::22 :::* LISTEN 985/sshd tcp6 0 0 ::1:25 :::* LISTEN 1285/master tcp6 0 0 :::5672 :::* LISTEN 988/beam.smp ========================================================================================= 4369 -- erlang端口 5672 --程序連接端口 15672 -- 管理界面ui端口 25672 -- server間內部通信端口
訪問頁面:192.168.13.139:15672 rabbitmq默認管理員用戶:guest 密碼:guest 新添加的用戶為:yjssjm 密碼:yjssjm
192.168.13.139 1.首先創建好數據存放目錄和日志存放目錄: [root@rabbitmq-1 ~]# mkdir -p /data/rabbitmq/data [root@rabbitmq-1 ~]# mkdir -p /data/rabbitmq/logs [root@rabbitmq-1 ~]# chmod 777 -R /data/rabbitmq [root@rabbitmq-1 ~]# chown rabbitmq.rabbitmq /data/ -R [root@rabbitmq-1 ~]# vim /etc/rabbitmq/rabbitmq-env.conf #創建配置文件 添加下面的內容: RABBITMQ_MNESIA_BASE=/data/rabbitmq/data RABBITMQ_LOG_BASE=/data/rabbitmq/logs [root@rabbitmq-1 ~]# systemctl restart rabbitmq-server #重啟服務 2.拷erlang.cookie Rabbitmq的集群是依附于erlang的集群來工作的,所以必須先構建起erlang的集群。Erlang的集群中 各節點是經由各個cookie來實現的,這個cookie存放在/var/lib/rabbitmq/.erlang.cookie中,文件是400的權限。所以必須保證各節點cookie一致,不然節點之間就無法通信. (官方在介紹集群的文檔中提到過.erlang.cookie 一般會存在這兩個地址:第一個是home/.erlang.cookie;第二個地方就是/var/lib/rabbitmq/.erlang.cookie。如果我們使用解壓縮方式安裝部署的rabbitmq,那么這個文件會在{home}目錄下,也就是$home/.erlang.cookie。如果我們使用rpm等安裝包方式進行安裝的,那么這個文件會在/var/lib/rabbitmq目錄下。) ======================================================================================= [root@rabbitmq-1 ~]# cat /var/lib/rabbitmq/.erlang.cookie HOUCUGJDZYTFZDSWXTHJ scp的方式將rabbitmq-1節點的.erlang.cookie的值復制到其他兩個節點中。 [root@rabbitmq-1 ~]# scp /var/lib/rabbitmq/.erlang.cookie root@192.168.13.142:/var/lib/rabbitmq/ [root@rabbitmq-1 ~]# scp /var/lib/rabbitmq/.erlang.cookie root@192.168.13.143:/var/lib/rabbitmq/
192.168.13.142 1.首先創建好數據存放目錄和日志存放目錄: [root@rabbitmq-2 ~]# mkdir -p /data/rabbitmq/data [root@rabbitmq-2 ~]# mkdir -p /data/rabbitmq/logs [root@rabbitmq-2 ~]# chmod 777 -R /data/rabbitmq [root@rabbitmq-2 ~]# chown rabbitmq.rabbitmq /data/ -R [root@rabbitmq-2 ~]# vim /etc/rabbitmq/rabbitmq-env.conf #創建配置文件 添加下面的內容: RABBITMQ_MNESIA_BASE=/data/rabbitmq/data RABBITMQ_LOG_BASE=/data/rabbitmq/logs [root@rabbitmq-2 ~]# systemctl restart rabbitmq-server #重啟服務 2.將mq-2作為內存節點加到mq-1節點集群中 [root@rabbitmq-2 ~]# rabbitmqctl stop_app #停止節點,切記不是停止服務 [root@rabbitmq-2 ~]# rabbitmqctl reset #如果有數據需要重置,沒有則不用
如果執行# rabbitmqctl stop_app 這條命令報錯
注意查看回顯,如果不是以上圖片中的就是錯誤;如果報錯,重啟rabbitmq服務 [root@rabbitmq-2 ~]# systemctl restart rabbitmq-server 如果還是報錯:將傳過來的文件給與正確的權限 [root@rabbitmq-2 ~]# chmod 400 /var/lib/rabbitmq/.erlang.cookie [root@rabbitmq-2 ~]# chown rabbitmq.rabbitmq /var/lib/rabbitmq/.erlang.cookie
將節點2加入集群,指定角色 [root@rabbitmq-2 ~]# rabbitmqctl join_cluster --ram rabbit@rabbitmq-1 #添加到內存節點 Clustering node 'rabbit@rabbitmq-2' with 'rabbit@rabbitmq-1' ... [root@rabbitmq-2 ~]# rabbitmqctl start_app #啟動節點 Starting node 'rabbit@rabbitmq-2' ... completed with 3 plugins.
192.168.13.143 1.首先創建好數據存放目錄和日志存放目錄: [root@rabbitmq-3 ~]# mkdir -p /data/rabbitmq/data [root@rabbitmq-3 ~]# mkdir -p /data/rabbitmq/logs [root@rabbitmq-3 ~]# chmod 777 -R /data/rabbitmq [root@rabbitmq-3 ~]# chown rabbitmq.rabbitmq /data/ -R [root@rabbitmq-3 ~]# vim /etc/rabbitmq/rabbitmq-env.conf 添加下面的內容: RABBITMQ_MNESIA_BASE=/data/rabbitmq/data RABBITMQ_LOG_BASE=/data/rabbitmq/logs [root@rabbitmq-3 ~]# systemctl restart rabbitmq-server 2.將mq-2作為內存節點加到mq-1節點集群中 [root@rabbitmq-3 ~]# rabbitmqctl stop_app [root@rabbitmq-3 ~]# rabbitmqctl reset [root@rabbitmq-3 ~]# rabbitmqctl join_cluster --ram rabbit@rabbitmq-1 Clustering node 'rabbit@rabbitmq-3' with 'rabbit@rabbitmq-1' ... [root@rabbitmq-3 ~]# rabbitmqctl start_app Starting node 'rabbit@rabbitmq-3' ... completed with 3 plugins.
(1)默認rabbitmq啟動后是磁盤節點,在這個cluster命令下,mq-2和mq-3是內存節點, mq-1是磁盤節點。 (2)如果要使mq-2、mq-3都是磁盤節點,去掉--ram參數即可。 (3)如果想要更改節點類型,可以使用命令rabbitmqctl change_cluster_node_type disc(ram),前提是必須停掉rabbitmq應用
查看集群狀態
在 RabbitMQ 集群任意節點上執行 rabbitmqctl cluster_status來查看是否集群配置成功。 在mq-1磁盤節點上面查看 [root@rabbitmq-1 ~]# rabbitmqctl cluster_status
每臺機器顯示出三臺節點,表示已經添加成功! 登錄查看 打開瀏覽器輸入http://192.168.13.139:15672
感謝各位的閱讀,以上就是“RabbitMQ消息中間件搭建過程”的內容了,經過本文的學習后,相信大家對RabbitMQ消息中間件搭建過程這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關知識點的文章,歡迎關注!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。