RabbitMQ依賴erlang,所以先安裝erlang，然后再安裝RabbitMQ;

先安裝erlang,雙擊erlang的安裝文件即可，然后配置環(huán)境變量：
ERLANG_HOME=D:\Program Files\erl7.1
追加到path=%ERLANG_HOME%\bin;

驗(yàn)證erlang是否安裝成功， 打開cmd命令窗口，進(jìn)入erlang的bin路徑，輸入erl命令，如果出現(xiàn)如下提示，則說明erlang安裝成功：

D:\Program Files\erl7.1\bin>erl

Eshell V7.1 (abort with ^G)

再安裝RabbitMQ，雙擊安裝文件即可，安裝完畢后， 設(shè)置環(huán)境變量：
RABBITMQ_SERVER=D:\Program Files\RabbitMQ Server\rabbitmq_server-3.5.6
追加到path=%RABBITMQ_SERVER%\sbin;

驗(yàn)證RabbitMQ是否安裝成功，在CMD命令窗口輸入：

C:\Windows\system32>rabbitmq-service

?

?

安裝好后,我們進(jìn)入rabbitMQ安裝目錄下的sbin目錄,在目錄下shift+右鍵打開命令行? ?【必須要進(jìn)行這一步，不然中途會(huì)發(fā)現(xiàn)使用不了，連接不上.使用版本rabbitmq-server-3.7.9.】

?

使用rabbitmq-plugins.bat enable rabbitmq_management開啟網(wǎng)頁(yè)管理界面,然后重啟rabbitMQ

遠(yuǎn)程連接需要 添加用戶，可在網(wǎng)頁(yè)admin頁(yè)面添加，，添加之后一定要給權(quán)限，不給權(quán)限的話還是不行，，詳細(xì)見【客戶端-開始任務(wù)完成】

?

#添加用戶

#rabbitmqctl add_vhost vh #rabbitmqctl add_user test test #rabbitmqctl set_user_tags test management #rabbitmqctl set_permissions -p vh test ".*" ".*" ".*" def start(self):disconnected = Truewhile disconnected:try:disconnected = Falseself.channel.start_consuming() # blocking callexcept pika.exceptions.ConnectionClosed: # when connection is lost, e.g. rabbitmq not runninglogging.error("Lost connection to rabbitmq service on manager")disconnected = Truetime.sleep(10) # reconnect timerlogging.info("Trying to reconnect...")self.connect()self.clear_message_queue() #could this make problems if the manager replies too fast?# 參照文檔 https://blog.csdn.net/csdn_am/article/details/79894662 View Code---報(bào)錯(cuò)處理【長(zhǎng)時(shí)間未調(diào)用斷開處理】---這里使用的是死循環(huán)處理，

RabbitMQ是一個(gè)在AMQP基礎(chǔ)上完整的，可復(fù)用的企業(yè)消息系統(tǒng)。他遵循Mozilla Public License開源協(xié)議。 1：安裝RabbitMQ需要先安裝Erlang語言開發(fā)包。下載地址 http://www.erlang.org/download.html 在win7下安裝Erlang最好默認(rèn)安裝。設(shè)置環(huán)境變量ERLANG_HOME= C:\Program Files\erlx.x.x 添加到PATH %ERLANG_HOME%\bin;2：安裝RabbitMQ 下載地址 http://www.rabbitmq.com/download.html 安裝教程：http://www.rabbitmq.com/install-windows.html設(shè)置環(huán)境變量RABBITMQ_SERVER=C:\Program Files\rabbitmq_server-x.x.x。添加到PATH %RABBITMQ_SERVER%\sbin;找到環(huán)境變量中的path變量:雙擊path，在其后面增加：;%RABBITMQ_SERVER%\sbin （注意前面的分號(hào)），然后確定即可現(xiàn)在打開windows命令行（“cmd”），輸入rabbitmq-service如果出現(xiàn)如下所示提示，即表示環(huán)境變量配置成功。3：進(jìn)入%RABBITMQ_SERVER%\sbin 目錄以管理員身份運(yùn)行 rabbitmq-plugins.bat rabbitmq-plugins.bat enable rabbitmq_management安裝完成之后以管理員身份啟動(dòng) rabbitmq-service.bat rabbitmq-service.bat stop rabbitmq-service.bat install rabbitmq-service.bat start4：瀏覽器訪問localhost:55672 默認(rèn)賬號(hào)：guest 密碼：guest5． Rabbit還自帶監(jiān)控功能. cmd進(jìn)到sbin目錄，鍵入rabbitmq-plugins enable rabbitmq_management啟用監(jiān)控管理，然后重啟Rabbitmq服務(wù)器。 打開網(wǎng)址http://localhost:55672，用戶名和密碼都是guest。 6． 現(xiàn)在打開瀏覽器，輸入：http://localhost:15672/ ，如果出現(xiàn)以下頁(yè)面，則表示服務(wù)器配置成功。 默認(rèn)用戶名為guest,密碼：guest如果沒有出現(xiàn)以上頁(yè)面，嘗試在windows命令行中輸入(以管理員方式運(yùn)行)： rabbitmq-plugins enable rabbitmq_management 然后運(yùn)行下面的命令來安裝： rabbitmq-service stop rabbitmq-service install rabbitmq-service start

?

rabbitMQ 生產(chǎn)者工作模式import pika1 創(chuàng)建socketconnection = pika.BlockingConnextion(pika.ConnectionParameters('localhost'))2 聲明一個(gè)管道channel = connection.channel()3 聲明queuechannel.queue_declare(queue='hello',durable=True)durable:聲明是持久化的隊(duì)列，默認(rèn)是隊(duì)列存在內(nèi)在中的，服務(wù)崩了之后，是不會(huì)恢復(fù)的4 發(fā)消息channel.basic_publish(exchange='',routing_key='hello', # 隊(duì)列的名字body='hello word!' #消息內(nèi)容properties=pika.BasicProperties(delivery_mode=2,))properties #消息持久化，主要語句 delivery_mode5 發(fā)送完畢，關(guān)閉隊(duì)列connection.close()消費(fèi)者工作模式1 創(chuàng)建socketconnection = pika.BlockingConnextion(pika.ConnectionParameters('localhost'))2 聲明一個(gè)管道channel = connection.channel()3 聲明queuechannel.queue_declare(queue='hello')4 消費(fèi)消息def callback(ch,method,properties,body):print(' x Received %r'%body)# ch 就是管道的內(nèi)存對(duì)象地址# method 就是包含發(fā)送信息的列表，# properties # 消息處理完，需要手動(dòng)跟服務(wù)端確認(rèn)#　ch.basic_ack(delivery_tag=method.delivery_tag) #加上下面這個(gè)相當(dāng)于負(fù)載勻衡的權(quán)重值,處理慢的加上這個(gè)channel.basic_qos(prefetch_count=1)channel.basic_consume(callback, #如果收到消息調(diào)用處理,回調(diào)函數(shù)queue='hello',#隊(duì)列的名字　no_ack=True #消息處理完了，表示不確認(rèn)，一般不加,處理完了，由客戶端來向服務(wù)端確認(rèn)（a_1.basic_ack(delivery_tag=a_2.delivery_tag) ） ) 5 啟動(dòng)就一直運(yùn)行，沒有消息就阻塞 channel.start_consuming() exchange: 轉(zhuǎn)發(fā)器 fanout: 所有bind到此exchange的queue都可以接收消息 direct:通過routingkey和exchange決定的那個(gè)唯一的qu eue可以接收消息 topic:所有符合routingKey(此時(shí)可以是一個(gè)表達(dá)式)的r outingKey所bind的queue可以接收消息 headers:通過headers來決定把消息發(fā)給哪些queue import pika conn = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channll = conn.channel() channll.queue_declare('url',durable=True) for i in range(1,10):channll.publish(exchange='',routing_key='url',body='https://wh.lianjia.com/ershoufang/pg%s/'%i) conn.close() View Code--lianjia_ser----服務(wù)端-生成10頁(yè)__鏈家 # python 3.7 import pika import re import requests,pymysql credential_s = pika.PlainCredentials('root','liu') conn = pika.BlockingConnection(pika.ConnectionParameters(host='176.215.44.242',credentials=credential_s)) channel = conn.channel() channel.queue_declare('url',durable=True)class Lianjia(object):def __init__(self,static_url=''):self.headers = {'Host':'wh.lianjia.com','Referer': 'https://wh.lianjia.com/ershoufang/','Upgrade-Insecure-Requests': '1','User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.102 Safari/537.36'}if not static_url:self.static_url='https://wh.lianjia.com/ershoufang/pg%s/'else:self.static_url = static_urlself.patten='data-sl="">.*?data-sl="">(.*?)</a>.*?data-log_index=".*?" data-el=".*?">(.*?)</a>(.*?)</div>.*?</span>.*?<a href=".*?" target="_blank">(.*?)</a></div>.*?<.*?</span>.*?<span>(.*?)</span>'self.conn = pymysql.connect(host='176.215.44.242', user='root', password="liu",database='test', port=3306, charset='utf8')self.cur = self.conn.cursor()def get_page(self):res = requests.get(url=self.static_url,headers=self.headers,proxies={'http':'http://58.53.128.83:3128'})if res.status_code==200:self.write_res(res.text)def write_res(self,text):for i in re.findall(self.patten,text):a_1 = i[0] # 標(biāo)題a_2 = i[1] # 小區(qū)名a_3 = i[2] #　詳情a_4 = i[3] # 位置a_5 =i[4] #價(jià)格sql = 'insert into lianjia(b_t,x_q_1,x_q_2,w_z,j_g) values(%s,%s,%s,%s,%s)'self.cur.execute(sql, [a_1, a_2, a_3, a_4, a_5])self.conn.commit()def callback(a_1,a_2,a_3,body):print('接收到body',body)l = Lianjia(static_url=body)l.get_page()a_1.basic_ack(delivery_tag=a_2.delivery_tag)print(body,'完成，')channel.basic_consume(callback,queue='url') channel.start_consuming() View Code--lianjia_cli----客戶端-開始任務(wù)完成就開始下一條

?

fanout:廣播模式（其他地方一樣）生產(chǎn)者需要更改的地方：１　channel.exchange_declare(exchange='logs',type='fanout')#定義轉(zhuǎn)發(fā)器的名字,在消費(fèi)端上需要bind ２　channel.basic_publish(exchange='logs',routing_key='',body='消息隨便來')消費(fèi)者需要更改的地方：１　channel.exchange_declare(exchange='logs',type='fanout')２　result = channel.queue_declare(exclusive=True)#排他，唯一的，不指定queue名字，rabbit會(huì)隨機(jī)分配一個(gè)名字，exclusive=True會(huì)在使用此queue的消費(fèi)者斷開后，自動(dòng)將queue刪除３　queue_name = result.method.queue#然后使用queue_name來進(jìn)行操作，然后需要綁定轉(zhuǎn)發(fā)器４　channel.queue_bind(exchange='logs',queue=queue_name)#綁定 direct :生產(chǎn)者：1 channel.exchange_declare(exchange='direct_logs',type='direct')2 severity = 'info'｜'warning'｜'error' #級(jí)別3 channel.basic_publish(exchange='logs',routing_key=severity,body='消息隨便來')消費(fèi)者：1 severitys = ['info','warning','error']2 result = channel.queue_declare(exclusive=True)３　queue_name = result.method.queue4 for severity in severitys:channel.queue_bind(exchange='direct_logs',queue=queue_name,routing_key=severity)#循環(huán)列表去綁定 topic: '#'是所有都收生產(chǎn)者:跟direct基本一樣，1 channel.exchange_declare(exchange='direct_logs',type='topic')消費(fèi)者:跟direct基本一樣，1 需要更改exchange='topic'

先暫時(shí)寫到這里吧，下次更新其他模式

轉(zhuǎn)載于:https://www.cnblogs.com/Skyda/p/10018332.html

總結(jié)

以上是生活随笔為你收集整理的rabbit MQ 的环境及命令使用（一）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。