实战|python消费rabbitMQ

怼烎@ 2023-01-07 04:59 81阅读 0赞

必须的包为pika，话不多说，上代码

#!/usr/bin/env python
    # -*- encoding: utf-8 -*-
    """
    @File    :  CosumerMQ.py
    @Contact :  dtboys507@163.com
    @License :  (C)Copyright 1997-2021, XXXXXXXXXXXXX CO.,LTD.
    @Modify Time      @Author    @Version    @Desciption
    ------------      -------    --------    -----------
    2021/1/5 16:33    liqb       1.0         kill some bugs
    """
    # ########################### 消费者 ##########################
    import pika
    import time
    
    # 远程rabbitmq服务的配置信息
    userid = '${username}'  # 指定远程rabbitmq的用户名密码
    passwd = '${passwd}'
    ipaddr = '${ipaddr}'
    port   = ${port}
    
    credentials = pika.PlainCredentials(username, pwd)
    connection = pika.BlockingConnection(pika.ConnectionParameters(ip_addr, port_num, '/', credentials))
    channel = connection.channel()
    
    # 消费成功的回调函数
    def callback(ch, method, properties, body):
        print(" [%s] Received %r" % (time.time(), body))
        # time.sleep(0.2)
    
    # 开始依次消费balance队列中的消息
    channel.basic_consume(queue='huhangyong_vehicle', on_message_callback=callback, auto_ack=True)
    
    print(' [*] Waiting for messages. To exit press CTRL+C')
    channel.start_consuming()  # 启动消费

发表评论取消回复

表情：

评论列表（有 0 条评论，81人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ消费端限流

RabbitMQ消费端限流 ![在这里插入图片描述][df0a4170766c44d58c0d42a5cde83b43.png] 配置yml Consumer 限

￡神魔★判官ぃ/ 2024年03月24日 11:29/ 0 赞/ 108 阅读

相关 RabbitMQ重复消费

造成重复消费的原因： MQ向消费者推送message，消费者向MQ返回ack，告知所推送的消息消费成功。但是由于网络波动等原因，可能造成消费者向MQ返回的ack丢失。MQ长时

以你之姓@/ 2023年09月23日 20:17/ 0 赞/ 134 阅读

相关 RabbitMQ发布和消费消息

凉月如眉挂柳湾，越中山色镜中看序介绍一个RabbitMQ官方发布和消费消息的例子。[官方例子][Link 1] 生产消息 public class

悠悠/ 2023年06月20日 06:59/ 0 赞/ 17 阅读

相关实战|python消费rabbitMQ

必须的包为pika，话不多说，上代码 !/usr/bin/env python -- encoding: utf-8 -- """ @Fil

怼烎@/ 2023年01月07日 04:59/ 0 赞/ 82 阅读

相关 RabbitMQ消息重复消费问题

业务背景消息队列在数据传输的过程中，为了保证消息传递的可靠性，一般会对消息采用ack确认机制，如果消息传递失败，消息队列会进行重试，此时便可能存在消息重复消费的问题。

Bertha 。/ 2022年09月05日 04:08/ 0 赞/ 220 阅读

相关使用rabbitmq 实现延迟消费

使用场景介绍 1、发版时经常需要不停机发版，遇到mq消费者，消费一半停机就会出现消息丢失（没有使用手动确认的情况） 2、例如支付场景，准时支付、超过未支付将执行不同的方

我会带着你远行/ 2022年06月07日 00:29/ 0 赞/ 328 阅读

相关 RabbitMQ延迟消费和重复消费

转载自 [https://blog.csdn.net/quliuwuyiz/article/details/79301054][https_blog.csdn.net_quli

忘是亡心i/ 2022年05月14日 14:07/ 0 赞/ 319 阅读

相关 RabbitMQ集成Webflux消费消息

pom.xml： <dependency> <groupId>org.springframework.boot</groupId> <

雨点打透心脏的1/2处/ 2022年01月22日 13:43/ 0 赞/ 438 阅读

相关【RabbitMq 篇二】-RabbitMq 发送与消费

前言本文介绍RabbitMq各个消息类型，以及用使用Fanout 类型进行消息的发送和消费，让大家对RabbitMq有一个简单的认识。正文使用所

╰+攻爆jí腚メ/ 2022年01月14日 12:17/ 0 赞/ 438 阅读

相关 rabbitMq消息消费日志rabbitmq_tracing

在使用rabbitmq时，我们有时需要查看消息队列生产/消费了那些消息，便于我们排错。rabbitmq中提供一个插件rabbitmq\_tracing用于记录消息的日志，默认是

柔情只为你懂/ 2021年05月12日 11:49/ 0 赞/ 708 阅读