CFFI绑定到librabbitmq 0.8.0
rabbitmq的Python项目详细描述
rabbitmq
==
使用cffi将python绑定到librabbitmq
到目前为止,这是相当初级的,但允许在python 3上基本程度地使用librabbitmq,这是我进行这项工作的主要动机。
目前在python3.6和2.7上对librabbitmq 0.8.0进行了测试。它是在python 3.6上的两个负载相当重的消息队列上生产的。
[在pypi上]可用(https://pypi.python.org/pypi/rabbitmq),只需“pip install rabbitmq”。
示例用法:
```python
import rabbitmq
conn=rabbitmq.connection()
conn.open(amqp_broker_主机,amqp_broker_broker_端口)conn.login
conn.login(amqp_broker_vhost,0,amqp_broker_broker_用户,amqp_broker_broker_用户密码)
conn.open conn.open_channel(1)
conn.declaru exchange(1,queuename,queuename,direct)conn.de.声明队列(1,“queuename”)
conn.bind_queue(1,“queuename”,“queuename”,“queuename”)
conn.consume(1,“queuename”)
publish_conn=rabbitmq.connection()
publish_conn.open(amqp_broker_host,amqp_broker_port)
publish_conn.login(amqp_broker_vhost,0,amqp_broker_user,amqp_broker_password)
发布连接打开连接通道(1)
发布连接声明交换(1,“exchangename”,“direct”)
8192:
压缩bz2中大型邮件正文的示例import compress
body=compress(body)
props.content encoding=“bzip2”
发布连接发布(1,“exchangename”,envelope.message.properties.reply-to,body,props)
```
==
使用cffi将python绑定到librabbitmq
到目前为止,这是相当初级的,但允许在python 3上基本程度地使用librabbitmq,这是我进行这项工作的主要动机。
目前在python3.6和2.7上对librabbitmq 0.8.0进行了测试。它是在python 3.6上的两个负载相当重的消息队列上生产的。
[在pypi上]可用(https://pypi.python.org/pypi/rabbitmq),只需“pip install rabbitmq”。
示例用法:
```python
import rabbitmq
conn=rabbitmq.connection()
conn.open(amqp_broker_主机,amqp_broker_broker_端口)conn.login
conn.login(amqp_broker_vhost,0,amqp_broker_broker_用户,amqp_broker_broker_用户密码)
conn.open conn.open_channel(1)
conn.declaru exchange(1,queuename,queuename,direct)conn.de.声明队列(1,“queuename”)
conn.bind_queue(1,“queuename”,“queuename”,“queuename”)
conn.consume(1,“queuename”)
publish_conn=rabbitmq.connection()
publish_conn.open(amqp_broker_host,amqp_broker_port)
publish_conn.login(amqp_broker_vhost,0,amqp_broker_user,amqp_broker_password)
发布连接打开连接通道(1)
发布连接声明交换(1,“exchangename”,“direct”)
8192:
压缩bz2中大型邮件正文的示例import compress
body=compress(body)
props.content encoding=“bzip2”
发布连接发布(1,“exchangename”,envelope.message.properties.reply-to,body,props)
```