rabbitmq python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
'localhost',9672))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()
$ sudo rabbitmqctl list_queues
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
channel.basic_consume(callback,
queue='hello',
no_ack=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
channel.start_consuming()
send.py:
!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()
receive.py:
!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
print ' [*] Waiting for messages. To exit press CTRL+C'
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
channel.basic_consume(callback,
queue='hello',
no_ack=True)
channel.start_consuming()
最新文章
- ios蓝牙开发（五）BabyBluetooth蓝牙库介绍
- DDD：Command模式的好处
- java 方法参数-值调用，引用调用问题
- 【BZOJ】2802: [Poi2012]Warehouse Store（贪心）
- Ubuntu 14.04 为 root 帐号开启 SSH 登录
- T-SQL JOIN
- NF3 里面的z cull reverse reload
- C语言的几个有趣问题
- C# list installed softwares
- java concurrent包的学习（转）
- USACO 3.2 Stringsobits
- SQL中LEFT JOIN 和 inner join 的区别
- java中构造方法和this，static关键字
- webpack打包文件
- Linux基础篇
- C++ Opencv split()通道分离函数 merge()通道合并函数 使用操作详解
- qml: 以鼠标为中心进行放缩；
- Maven 本地资源库配置
- 1，rocketmq 的原理与安装教程
- C++基础知识（2）