1卦尊,簡介:
RabbitMQ 是一個開源的消息代理和隊(duì)列服務(wù)器叛拷,用來通過普通協(xié)議在完全不同的應(yīng)用之間共享數(shù)據(jù),RabbitMQ是使用 Erlang語言來編寫的岂却,并且RabbitMQ是基于AMQP(AMQP忿薇,即Advanced Message Queuing Protocol,一個提供統(tǒng)一消息服務(wù)的應(yīng)用層標(biāo)準(zhǔn)高級消息隊(duì)列協(xié)議,是應(yīng)用層協(xié)議的一個開放標(biāo)準(zhǔn),為面向消息的中間件設(shè)計(jì)))
應(yīng)用場景(能做什么)
rabbitMQ實(shí)現(xiàn)消息推送,rabbitMQ為異步消息處理提出了一個很好的解決方案躏哩,它是一個非常好用的消息中間件署浩。主要解決當(dāng)生產(chǎn)者大量產(chǎn)生數(shù)據(jù)時,消費(fèi)者無法快速消費(fèi)的問題扫尺。這個時候需要一個中間層筋栋,保存這個數(shù)據(jù),rabbitMQ是一個很好的解決方案正驻。
1二汛、注冊時發(fā)送郵件或發(fā)送短信
2、日志分析使用拨拓,多個服務(wù)產(chǎn)生的數(shù)據(jù)發(fā)送到中間件發(fā)送到分析服務(wù)肴颊。
3、消息復(fù)制渣磷,用于跨機(jī)房數(shù)據(jù)傳輸婿着、搜索、離線數(shù)據(jù)計(jì)算等醋界。
4竟宋、延遲消息發(fā)送和暫存,把中間件當(dāng)成可靠的消息暫存地形纺。接受消息丘侠,暫時先不發(fā)送。
總的來說逐样,redis作為一個消息中間件蜗字,可以實(shí)現(xiàn)系統(tǒng)解耦(將生產(chǎn)者和消費(fèi)者分割開來),作為中間緩存可以實(shí)現(xiàn)流量削峰
rabbit模型:
生產(chǎn)者:發(fā)送消息
交換機(jī):將收到的消息根據(jù)路由規(guī)則路由到特定隊(duì)列
隊(duì)列:用于存儲消息
消費(fèi)者:收到消息并消費(fèi)
rabbit當(dāng)中消息的流轉(zhuǎn)過程
相關(guān)概念
Message:消息脂新,服務(wù)器和應(yīng)用程序之間傳送的數(shù)據(jù)挪捕,由Properties和Body組成。Properties可以對消息進(jìn)行修飾争便,比如消息的優(yōu)先級级零、延遲等高級特性;Body則是消息體的內(nèi)容
Exchange:消息交換機(jī)滞乙,它指定消息按什么規(guī)則奏纪,路由到哪個隊(duì)列(交換機(jī)鉴嗤,接收消息,根據(jù)路由鍵轉(zhuǎn)發(fā)消息到綁定的隊(duì)列)序调。
Queue:消息隊(duì)列載體躬窜,每個消息都會被投入到一個或多個隊(duì)列。
Binding:Exchange和Queue之間的虛擬連接,binding中可以包含routing key炕置。
Routing Key:路由關(guān)鍵字荣挨,exchange根據(jù)這個關(guān)鍵字進(jìn)行消息投遞;一個路由規(guī)則朴摊,虛擬機(jī)可用它確定如何路由一個特定消息默垄。
vhost:虛擬地址,用于進(jìn)行邏輯隔離甚纲,最上層的消息路由口锭。同一個Virtual Host里面不能有相同名稱的Exchange或Queue。
Producer:消息生產(chǎn)者介杆,就是投遞消息的程序鹃操。
Consumer:消息消費(fèi)者,就是接受消息的程序春哨。
Channel:網(wǎng)絡(luò)信道荆隘,幾乎所有的操作都在Channel中進(jìn)行,Channel是進(jìn)行消息讀寫的通道赴背∫埽客戶端可建立多個Channel,每個Channel代表一個會話任務(wù)
工作過程:
消息隊(duì)列的創(chuàng)建過程
1凰荚,客戶端連接到消息隊(duì)列服務(wù)器燃观,打開一個channel(每個chanel代表一個會話任務(wù))
2,客戶端先后聲明exchenge和queue便瑟,并設(shè)置其相關(guān)屬性
3缆毁,客戶端使用routing key,在exchenge和queue之間建立綁定關(guān)系
消息隊(duì)列的使用過程
1到涂,投遞消息
客戶端投遞消息到exchenge里面
2脊框,取消息
建立連接以后即監(jiān)聽相關(guān)queue,里面有消息則取出處理
rabbit安裝過程
1.centos7中安裝RabbitMQ
1).首先需要安裝erlang
rpm -Uvh http://download.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-8.noarch.rpm
yum install erlang
安裝過程中會有提示养盗,一路輸入“y”即可缚陷。
2).完成后安裝RabbitMQ:
先下載rpm:
wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm
下載完成后安裝:
yum install rabbitmq-server-3.6.6-1.el7.noarch.rpm
完成后啟動服務(wù):
service rabbitmq-server start
可以查看服務(wù)狀態(tài):
service rabbitmq-server status
****啟動命令
service rabbitmq-server start#查看狀態(tài)
service rabbitmq-server status#停止
service rabbitmq-server stop#重啟
service rabbitmq-server restart
****啟用插件适篙,開放端口
rabbitmq-plugins enable rabbitmq_management
iptables -A INPUT -p tcp -m st
****配置用戶
新增用戶 admin 密碼 adminpassword
rabbitmqctl add_user admin adminpasspord
分配角色
rabbitmqctl set_user_tags admin administrator
更改密碼
rabbitmqctl change_password admin 123456
****卸載rabbitmq
卸載前先停掉rabbitmq服務(wù)往核,執(zhí)行命令
service rabbitmq-server stop
查看rabbitmq安裝的相關(guān)列表
yum list | grep rabbitmq
卸載rabbitmq已安裝的相關(guān)內(nèi)容
yum -y remove rabbitmq-server.noarch
卸載erlang
查看erlang安裝的相關(guān)列表
yum list | grep erlang
卸載erlang已安裝的相關(guān)內(nèi)容
yum -y remove erlang-*
yum remove erlang.x86_64
卸載完之后就可以重新安裝了
otp包安裝方式如下:
https://blog.csdn.net/java_1996/article/details/86600980