test12.py 文件源码

python
阅读 18 收藏 0 点赞 0 评论 0

项目:DIS_MeituanReptile 作者: myvary 项目源码 文件源码
def receive(self,username,pwd,ip,port):#????????????????????????
        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='city_task_queue', durable=True)
        channel.basic_qos(prefetch_count=1)
        print '???????????'
        channel.basic_consume(self.callback,
                              queue='city_task_queue',
                              )
        channel.start_consuming()
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号