springboot+mq

springboot整合rabbitmq,支持消息确认机制

安装

推荐一篇博客 https://blog.csdn.net/zhuzhezhuzhe1/article/details/80464291

项目结构

image

POM.XML

image

POM.XML

application.yml

需要将publisher-confrems设为true,启动确认回调, 将 publisher-returns设为true 确认返回回调

image

rabbitmq配置类--RabbitConfig

第一部分, 定义队列

image

第二部分,设置一些消息处理策略

image

/**

  • rabbitMq 配置类
  • @author milicool
  • Created on 2018/9/14 /
    @Configuration
    public class RabbitConfig {
    @Resource
    private RabbitTemplate rabbitTemplate;
    /
    *
  • 定义一个hello的队列
  • Queue 可以有4个参数
  •  1.队列名 
    
  •  2.durable       持久化消息队列 ,rabbitmq重启的时候不需要创建新的队列 默认true 
    
  •  3.auto-delete   表示消息队列没有在使用时将被自动删除 默认是false 
    
  •  4.exclusive     表示该消息队列是否只在当前connection生效,默认是false 
    */
    

@Bean
public Queue helloQueue() {
return new Queue("queue-test");
}
/** ======================== 定制一些处理策=============================*/

  • ConfirmCallback接口用于实现消息发送到RabbitMQ交换器后接收ack回调 即消息发送到exchange ack
  • ReturnCallback接口用于实现消息发送到RabbitMQ 交换器,但无相应队列与交换器绑定时的回调 即消息发送不到任何一个队列中 ack */
    @Bean public RabbitTemplate rabbitTemplate() {
    Logger log = LoggerFactory.getLogger(RabbitTemplate.class);
    // 消息发送失败返回到队列中, yml需要配置 publisher-returns: true
    rabbitTemplate.setMandatory(true);
    // 消息返回, yml需要配置 publisher-returns: true
    rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> { String correlationId = message.getMessageProperties().getCorrelationIdString(); log.debug("消息:{} 发送失败, 应答码:{} 原因:{} 交换机: {} 路由键: {}", correlationId, replyCode, replyText, exchange, routingKey); });
    // 消息确认, yml需要配置 publisher-confirms: true
    rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { if (ack) { // log.debug("消息发送到exchange成功,id: {}", correlationData.getId());
    } else { log.debug("消息发送到exchange失败,原因: {}", cause); } });
    return rabbitTemplate; } }

生产者

/**

  • 生产者
  • @author milicool
  • Created on 2018/9/14
    /
    @Component
    public class Producer {
    @Autowired private RabbitTemplate rabbitTemplate;
    /
    *
  • 给hello队列发送消息 */
    public void send() { for (int i =0; i< 100; i++) { String msg = "hello, 序号: " + i; System.out.println("Producer, " + msg); rabbitTemplate.convertAndSend("queue-test", msg); } }
    }

消费者

/**

  • 消费者

  • @author milicool

  • Created on 2018/9/14
    */
    @Component
    public class Comsumer { private Logger log = LoggerFactory.getLogger(Comsumer.class);

    @RabbitListener(queues = "queue-test")
    public void process(Message message, Channel channel) throws IOException {
    // 采用手动应答模式, 手动确认应答更为安全稳定
    channel.basicAck(message.getMessageProperties().getDeliveryTag(), true); log.info("receive: " + new String(message.getBody())); } }

测试类

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqApplicationTests {
@Autowired
private Producer producer;
@Test
public void contextLoads() { producer.send(); }
}</pre>

[
复制代码

](javascript:void(0); "复制代码")

测试结果

测试结果太长,没有截取全部,可以查看到消费者接收到了全部消息,如果有的消息在没有接收完,消息将被持久化,下次启动时消费

image

web端查看

image

感谢阅读 o(∩_∩)o

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 220,367评论 6 512
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,959评论 3 396
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 166,750评论 0 357
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 59,226评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,252评论 6 397
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,975评论 1 308
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,592评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,497评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,027评论 1 319
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,147评论 3 340
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,274评论 1 352
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,953评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,623评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,143评论 0 23
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,260评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,607评论 3 375
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,271评论 2 358