RabbitMQ基本示例，轮询机制，no_ack作用

一、RabbitMQ简介：

'''
RabbitMQ就是消息队列
  之前不是学了Queue了吗，都是队列还学RabbitMQ干嘛？
  干的事情是一样的
  Python的Queue有两个，
     一个线程Queue生产者消费者模型，一个进程Queue用于父进程与子进程交互
     两个完全独立的Python程序就不能交互了，或者两台机器之间的Queue，Java跟Python之间不能交互了
     所以有了RabbitMQ
     
QQ跟Word通信：
    1、用socket直接通信
    2、通过硬盘通信
    3、QQ通过socket发给中间商，中间商通过socket发给Word
    第1个和第3个有啥区别呢？
    第一种直接通信比较复杂，
    第二种中间商可以省去网络通信维护的工作，而且可以实现三方或者更多方的通信
    这个中间商就叫RabbitMQ
Python语言连接RabbitMQ的模块有：
    pika主流常用、 celery分布式消息队列
'''

二、简单的示例：

import pika

# 相当于建立最基本的socket
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
# 声明一个管道
channel = connection.channel()
# 在管道里声明一个队列
channel.queue_declare(queue='q1')
# 通过管道发消息
channel.basic_publish(exchange='',
                      routing_key='q1', # 队列名
                      body='Hello World') # 消息内容
print("send: Hello World")
connection.close()

producer生产者