day10-rabbitmq

#!/usr/bin/env  python
#coding:utf8

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()

#!/usr/bin/env  python
#coding:utf8

import pika
import time

connection=pika.BlockingConnection(pika.ConnectionParameters(host=‘localhost‘))#连接rabbitmq-server的IP
channel=connection.channel()#打开通道

#######################消费者##########################
channel.queue_declare(queue=‘hello‘)#创建队列
#如果这行代码注释,程序运行的时候会找指定的hello队列,如果hello不存在则会报错.
#如果server端口先启动并且创建了hello队列,这里运行的时候可以不创建队列.因为server已创建



def callback(ch,method,properties,body):
        print(" [x] Received %r" % body)
        import time
        time.sleep(10)
        print ‘ok‘
        ch.basic_ack(delivery_tag = method.delivery_tag)#处理完消息之后会发送ack信号


channel.basic_consume(callback,#往队列取回消息之后执行回调函数
                      queue=‘hello‘,#队列名称
                      no_ack=False,
                      )
                    #no_ack=False 保证消息不丢失.如果消费者收到消息后正在处理,此时网络中断或机器断电.RabbitMQ会重新将该任务添加到队列中
channel.start_consuming()#关闭连接

#!/usr/bin/env  python
#coding:utf8

import pika

connection=pika.BlockingConnection(pika.ConnectionParameters(host=‘localhost‘))
channel=connection.channel()


#######################发布者##########################
channel.queue_declare(queue=‘hello1‘,durable=True)#创建队列

#保证消息在rabbitmq里面不丢失需要满足2点:
#1.队列持久化 durable=True
#2.发送的消息持久化
# properties=pika.BasicProperties(
#                       delivery_mode=2, # make message persistent
#                       )



channel.basic_publish(exchange=‘‘,#交换器
                      routing_key=‘hello1‘,#发布的消息绑定到指定的队列
                      body=‘hello,world!‘,#消息内容
                      properties=pika.BasicProperties(
                      delivery_mode=2, # make message persistent
                      ))

print "[x] Sent ‘Hello,world!‘"
connection.close()

#!/usr/bin/env  python
#coding:utf8

import pika
import time

connection=pika.BlockingConnection(pika.ConnectionParameters(host=‘localhost‘))#连接rabbitmq-server的IP
channel=connection.channel()#打开通道

#######################消费者##########################
channel.queue_declare(queue=‘hello1‘,durable=True)#创建队列
#如果这行代码注释,程序运行的时候会找指定的hello队列,如果hello不存在则会报错.
#如果server端口先启动并且创建了hello队列,这里运行的时候可以不创建队列.因为server已创建
#队列持久化 durable=True


def callback(ch,method,properties,body):
        print(" [x] Received %r" % body)
        import time
        # time.sleep(10)
        # print ‘ok‘
        ch.basic_ack(delivery_tag = method.delivery_tag)#处理完消息之后会发送ack信号


channel.basic_consume(callback,#往队列取回消息之后执行回调函数
                      queue=‘hello1‘,#队列名称
                      no_ack=False,
                      )
                    #no_ack=False 保证消息不丢失.如果消费者受到消息后正在处理,此时网络中断或机器断电.消息还保存在队列不会丢失.
channel.start_consuming()#关闭连接