Слияние кода завершено, страница обновится автоматически
遇到过糟糕的使用redis来做队列的项目，里面消费者代码太多冗余，所以想实现一个跟rabbitMqListener一样简洁方便的消费框架，redisMq框架也是参考rabbitMqListener来实现的
消费一个队列只需要一个方法一个注解搞定，底层的框架来帮我搞定延迟队列，死信交换机制
管理redis队列，可以停止队列消费，防止kill进程导致队列数据丢失，具体可以参考RedisListenerEndpointRegistrar类
引入com.mq.redis包, 参考com.mq.redis.test工程，需要配置redisTemplate连接
实现一个消费者，参考com.mq.test.RedisMqTest.testMQ1
关于配置文件如下
## 单个消费者最大线程数
spring.mq.redis.maxConsumer=5
## 消费者消费失败进入死信后重试次数
spring.mq.redis.retryTimes=3
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Комментарии ( 0 )