标签：过期 RabbitMQ 限流 build TTL message public

消费端限流

在并发量高的情况下，如秒杀、抢票等场景，如果不对 RabbitMQ 推送信息给消费者的速度进行限流的话，很容易打崩系统

RabbitMQ 的限流机制：

• 必要条件：消费端 ack 机制为手动签到
• 如果限流数为1，表示消费端每次只能从mq拉去一条消息来消费，直到手动确认消费完毕后，才会继续拉去下一条信息。使用这种机制来对消费端进行限流

具体配置：

spring:
  rabbitmq:
#    配置消费端
    listener:
      simple:
        acknowledge-mode: manual
        # 消费端限流数，表示每次只能拉取1000条信息
        prefetch: 1000

消息存活时间TTL

RabbitMQ允许您为某个消息和队列中的所有消息设置TTL（生存时间）。如果两者都设置了，则以时间短的为准。

过期的消息不会立刻从队列中被清除，而是等到它轮询到队头的时候判断它是否过期，过期再清除。有点类似于Redis的惰性清理。

为队列设置过期时间

参数是：x-message-ttl

@Configuration
public class RabbitMQConfig {
    private static final String SB_TOPIC_QUEUE="sb_topic_queue1";

    // 声明队列
    @Bean
    public Queue queue1(){
        Queue build = QueueBuilder.durable(SB_TOPIC_QUEUE).build();
        build.addArgument("x-message-ttl",3000);
        return  build;
    }
}

为单个消息设置过期时间

    @Test
    public void testTTLOneMessage(){
        MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws AmqpException {
                message.getMessageProperties().setExpiration(String.valueOf(8000));
                return message;
            }
        };
        for (int i = 0; i < 10; i++) {
            template.convertAndSend("sb_topic_exchange","user2.info",(Object) "这个消息的ttl为8s",messagePostProcessor);
        }

    }

标签：过期,RabbitMQ,限流,build,TTL,message,public
来源： https://www.cnblogs.com/sang-bit/p/14798622.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。