send.py 文件源码

def send(self, message_list, username, pwd, ip, port,queue_name):
        '''
        ????????????
        :param message_list ????
        :param username     ??RabbitMQ??????
        :param pwd          ??
        :param ip           ?????ip
        :param port         ??
        :param queue_name   ??????????
        :return 
        '''
        user_pwd = pika.PlainCredentials(username, pwd)
        s_conn = pika.BlockingConnection(pika.ConnectionParameters(ip, port, '/', credentials=user_pwd))  # ????
        channel = s_conn.channel()  # ??????????

        channel.queue_declare(queue=queue_name, durable=True)  # ???????task_queue????????????????????????????
        print '???????????:', len(message_list)
        for g in range(len(message_list)):
            message = message_list[g]
            message = message.encode('utf-8')#??????????????????
            channel.basic_publish(exchange='',
                                  routing_key=queue_name,  # ??????????worker
                                  body=message,  # ??????
                                  properties=pika.BasicProperties(delivery_mode=2, )  # ?????????????????????2??????????
                                  )
            print g, ':', message
            time.sleep(0.02)  # ????
        print g