轉(zhuǎn)載自：

http://www.cnblogs.com/jfl-xx/p/7324285.html#3899115

首先終端輸入netstat -nltp

看下tcp6的端口是5671還是5672

然后在下面的代碼中相應(yīng)地改為5671或者5672

send.py

#!/usr/bin/env python3 # -*- coding: utf-8 -*-import pika import random# 新建連接，rabbitmq安裝在本地則hostname為'localhost' # hostname = '192.168.1.133' hostname='localhost' parameters = pika.ConnectionParameters(hostname,5671) connection = pika.BlockingConnection(parameters)# 創(chuàng)建通道 channel = connection.channel() # 聲明一個隊列，生產(chǎn)者和消費者都要聲明一個相同的隊列，用來防止萬一某一方掛了，另一方能正常運行 channel.queue_declare(queue='hello')number = random.randint(1, 1000) body = 'hello world:%s' % number # 交換機; 隊列名,寫明將消息發(fā)往哪個隊列; 消息內(nèi)容 # routing_key在使用匿名交換機的時候才需要指定，表示發(fā)送到哪個隊列 channel.basic_publish(exchange='', routing_key='hello', body=body) print " [x] Sent %s" % body connection.close()
reveive.py

#!/usr/bin/env python3 # -*- coding: utf-8 -*-import pika import random# 新建連接，rabbitmq安裝在本地則hostname為'localhost' # hostname = '192.168.1.133' hostname='localhost' parameters = pika.ConnectionParameters(hostname,5671) connection = pika.BlockingConnection(parameters)# 創(chuàng)建通道 channel = connection.channel() # 聲明一個隊列，生產(chǎn)者和消費者都要聲明一個相同的隊列，用來防止萬一某一方掛了，另一方能正常運行 channel.queue_declare(queue='hello')number = random.randint(1, 1000) body = 'hello world:%s' % number # 交換機; 隊列名,寫明將消息發(fā)往哪個隊列; 消息內(nèi)容 # routing_key在使用匿名交換機的時候才需要指定，表示發(fā)送到哪個隊列 channel.basic_publish(exchange='', routing_key='hello', body=body) print " [x] Sent %s" % body connection.close()

運行方法：

python send.py

python receive.py

總結(jié)

以上是生活随笔為你收集整理的rabbitMQ基本通信代码使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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