# -*- coding: UTF-8 -*-
#pip install pika  #Linux和pycharm需要安装pika
import pika
username = 'guest'
pwd = 'guest'
messages = "LinYaoHong"
user_pwd = pika.PlainCredentials(username, pwd)
# connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))#本地
s_conn = pika.BlockingConnection(pika.ConnectionParameters('192.168.199.11', credentials=user_pwd))#创建连接
chan = s_conn.channel()  #在连接上创建一个频道
#durable=True 声明一个持久化消息队列
chan.queue_declare(queue='MMMMM',durable=True) #声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行
chan.basic_publish( exchange='',  #交换机
                    routing_key='MMMMM',#路由键，写明将消息发往哪个队列，本例是将消息发往队列hello
                    body=messages,  #生产者要发送的消息
                    properties=pika.BasicProperties(
                        delivery_mode=2,  #使消息或任务也持久化存储
                    )
                    )
print("[生产者]生产:'hello world")
s_conn.close()#当生产者发送完消息后，可选择关闭连接