Docker開啟RabbitMQ延時訊息佇列
阿新 • • 發佈:2019-12-31
前言
經常在開發中會遇到一些不需要同步執行的業務,那我們就需要用到訊息佇列來進行非同步執行,但是對於某些業務就還需要用到延時的功能,比如訂單支付超時關閉,那麼這個時候我們就需要開啟訊息佇列的延時功能,當然也有朋友說有其他的解決辦法,例如:資料庫輪訓以及執行緒休眠,但是這些相對於延時訊息佇列來說,都顯得比較遜色。
正文
安裝Docker
docker的安裝就不用多說了,在Centos下就一行命令搞定(其他的系統版本請自行查閱):
yum update -y && yum install -y docker && service docker start複製程式碼
拉取RabbitMQ映象並啟動
docker pull rabbitmq:managementdocker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61613 -p 1883:1883 rabbitmq:management複製程式碼
RABBITMQ_DEFAULT_USER
RABBITMQ_DEFAULT_PASS
為預設密碼,請自行修改即可
安裝延時外掛
首先先到rabbitmq官網下載自己rabbitmq對應版本的延時外掛rabbitmq_delayed_message_exchange
到服務端,我的是3.7.x,所以執行:
wget https://dl.bintray.com/rabbitmq/community-plugins/3.7.x/rabbitmq_delayed_message_exchange/rabbitmq_delayed_message_exchange-20171201-3.7.x.zip複製程式碼
下載完成之後我們將zip檔案進行解壓,然後我們執行docker ps
[root@121 download]# docker psCONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMESc5e3d04e3141 rabbitmq:management "docker-entrypoint..." 7 days ago Up 7 days 4369/tcp,0.0.0.0:1883->1883/tcp,5671/tcp,0.0.0.0:5672->5672/tcp,0.0.0.0:15672->15672/tcp,0.0.0.0:25672->25672/tcp,0.0.0.0:61613->61613/tcp,15671/tcp rabbit複製程式碼
接著我們將外掛拷貝到容器的外掛目錄下:
docker cp rabbitmq_delayed_message_exchange-20171201-3.7.x.ez c5e3d04e3141:/plugins# c5e3d04e3141是自己的容器ID複製程式碼
然後我們進入到容器的bash中:
sudo docker exec -it c5e3d04e3141 /bin/bash複製程式碼
進入到plugins
目錄檢視是否有rabbitmq_delayed_message_exchange-20171201-3.7.x.ez
檔案,有的話就說明成功拷貝到rabbitmq的外掛目錄了,接著我們就執行最後一步,開啟外掛:
root@my-rabbit:/plugins# rabbitmq-plugins enable rabbitmq_delayed_message_exchangeEnabling plugins on node rabbit@my-rabbit:rabbitmq_delayed_message_exchangeThe following plugins have been configured:rabbitmq_delayed_message_exchangerabbitmq_managementrabbitmq_management_agentrabbitmq_web_dispatchApplying plugin configuration to [email protected] following plugins have been enabled:rabbitmq_delayed_message_exchangestarted 1 plugins.複製程式碼
執行rabbitmq-plugins enable rabbitmq_delayed_message_exchange
在log最後出現started 1 plugins.
,就說明開啟成功,退出rabbitmq的bash之後執行docker restart rabbit
重啟rabbitmq就可以使用延時訊息佇列來處理業務了。
後記
在以前的業務中我都是用的文章開頭說的稍顯遜色的做法來處理這種業務,但是這種方法顯然是不可靠的,當然以前我不用訊息佇列的原因就是聽著這個名字就覺得很難,後來真正用上了之後發現很好上手的,所以不能再事情未開始之前就給自己下了死刑,加油!