逍遥阁

RabbitMQ的使用

关键词: RabbitMQ

RabbitMQ的使用

###用docker搭建服务

`docker-compose.yml`文件内容如下

```
version: "2"
services:
    rabbitmq:
        image: rabbitmq:3
        hostname: test
        container_name: rabbitmq
        ports:
            - "5672:5672"
        volumes:
            - /home/test/data/disk/rabbitmq:/var/lib/rabbitmq
        environment:
            - RABBITMQ_ERLANG_COOKIE=test
            - RABBITMQ_NODENAME=rabbit@test
            - RABBITMQ_DEFAULT_USER=root
            - RABBITMQ_DEFAULT_PASS=1234
        restart: always
```

###demo

`pika`是python操作RabbitMQ的库

生产者代码

```
#!/usr/bin/env python
# -*- encoding: utf-8 -*-
import time,pika

RABBITMQ_HOST = "192.168.1.100"
RABBITMQ_PORT = 5672
RABBITMQ_USERNAME = "root"
RABBITMQ_PASSWORD = "1234"
RABBITMQ_QUEUE = "news"
RABBITMQ_ROUTING_KEY = "news"

if __name__ == "__main__":
    while True:
        time.sleep(1)
        credentials = pika.PlainCredentials(RABBITMQ_USERNAME, RABBITMQ_PASSWORD)
        connection = pika.BlockingConnection(pika.ConnectionParameters(RABBITMQ_HOST, RABBITMQ_PORT, "/", credentials))
        channel = connection.channel()
        channel.queue_declare(queue=RABBITMQ_QUEUE)
        channel.basic_publish(exchange="", routing_key=RABBITMQ_ROUTING_KEY, body="test")
        connection.close()
```

消费者代码

```
#!/usr/bin/env python
# -*- encoding: utf-8 -*-
import time,pika

RABBITMQ_HOST = "192.168.1.20"
RABBITMQ_PORT = 5672
RABBITMQ_USERNAME = "root"
RABBITMQ_PASSWORD = "pw2017"
RABBITMQ_QUEUE = "news"
RABBITMQ_ROUTING_KEY = "news"

def callback(ch, method, properties, body):
    print body
    time.sleep(5)
    #确认消息
    ch.basic_ack(delivery_tag=method.delivery_tag)

if __name__ == "__main__":
    credentials = pika.PlainCredentials(RABBITMQ_USERNAME, RABBITMQ_PASSWORD)
    connection = pika.BlockingConnection(pika.ConnectionParameters(RABBITMQ_HOST, RABBITMQ_PORT, '/', credentials))
    channel = connection.channel()
    channel.queue_declare(queue=RABBITMQ_QUEUE)
    channel.basic_consume(callback, queue=RABBITMQ_QUEUE, no_ack=False)
    """
    如果每一条消息不需要确认，no_ack设置为True
    如果每一条消息都需要确认，no_ack设置为False
    """
    channel.start_consuming()
```

admin
2017-03-31 13:22:31
python

文章分类

文章标签

文章归档

友情链接

RabbitMQ的使用