Loading [MathJax]/jax/output/CommonHTML/config.js
前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >专栏 >springboot消息之@RabbitListener和@EnableRabbit

springboot消息之@RabbitListener和@EnableRabbit

作者头像
西西嘛呦
发布于 2020-08-26 07:37:19
发布于 2020-08-26 07:37:19
1.2K00
代码可运行
举报
运行总次数:0
代码可运行

接上一节。

使用上述两个注解可以实现监听消息队列

1、我们在主配置类中加上@EnableRabbit开启基于注解的RabbitMq

2、我们建立一个BookService.java并为相关方法加上@RabbitListener注解,启动服务器

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
package com.gong.springbootrabbitmq.service;

import com.gong.springbootrabbitmq.bean.Book;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class BookService {

    @RabbitListener(queues = "gong.news")
    public void recieve(Book book){
        System.out.println("收到消息:"+book);
    }

}

服务器启动时我们就收到了消息,因为上一节我们往gong.news队列中添加了一条消息。

我们如果继续添加一条消息:也收到了

3、第二种收消息的模式

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
    @RabbitListener(queues = "gong")
    public void recieve2(Message message){
        System.out.println(message.getBody());
        System.out.println(message.getMessageProperties());
    }

启动服务器:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
[B@3c45f2e3
MessageProperties [headers={__TypeId__=com.gong.springbootrabbitmq.bean.Book}, contentType=application/json, contentEncoding=UTF-8, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=false, receivedExchange=exchange.fanout, receivedRoutingKey=, deliveryTag=1, consumerTag=amq.ctag-Y2Y5J6jRFYdOOzkrxz9VLA, consumerQueue=gong]
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020-02-11 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
【RabbitMQ】消息确认机制ACK
消费者从RabbitMQ收到消息并处理完成后,反馈给RabbitMQ,RabbitMQ收到反馈后才将此消息从队列中删除
后端码匠
2023/11/12
3400
SpringBoot 整合 RabbitMQ
特殊说明: 解决问题的光鲜,藏着磕Bug的痛苦。 万物皆入轮回,谁也躲不掉! 以上文章,均是我实际操作,写出来的笔记资料,不会出现全文盗用别人文章!烦请各位,请勿直接盗用!
收心
2022/01/17
4630
RabbitMQ从概念到使用、从Docker安装到RabbitMQ整合Springboot【1.5w字保姆级教学】
我们先来聊聊消息中间件: 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。(来自百度百科)
掉发的小王
2022/07/11
5030
RabbitMQ从概念到使用、从Docker安装到RabbitMQ整合Springboot【1.5w字保姆级教学】
RabbitMQ消息监听异常问题探究「建议收藏」
在使用Spring RabbitMQ做消息监听时,如果监听程序处理异常了,且未对异常进行捕获,会一直重复接收消息,然后一直抛异常。为了更好的描述问题,下面写个简单的例子。
全栈程序员站长
2022/09/22
1K0
RabbitMQ消息监听异常问题探究「建议收藏」
springboot + 消息队列
第一种:用户注册信息写入数据库后在按照顺序先后发送注册邮件和短信,走完这三步后用户才完成注册
桑鱼
2020/03/18
1.1K0
springboot + 消息队列
原创 | SpringBoot监听rabbitmq和创建交换器,队列
高级消息队列协议(AMQP)是面向消息的中间件的平台中立的线级协议。Spring AMQP项目将核心Spring概念应用于基于AMQP的消息传递解决方案的开发。Spring Boot通过RabbitMQ使用AMQP提供了一些便利,包括spring-boot-starter-amqp “Starter”。
润森
2020/01/14
2.1K0
原创 | SpringBoot监听rabbitmq和创建交换器,队列
一文掌握RabbitMQ的简单使用与整合
首先来聊一聊什么是消息中间件,以及消息中间件能帮助我们解决什么问题。 消息中间件是基于队列与消息传递技术,在网络环境中为应用系统提供同步或异步、可靠的消息传输的支撑性软件系统,简单来说,消息中间件能够为我们的系统提供异步处理能力。 举个例子,某个系统在使用之前需要用户进行注册,用户在完成注册后需要发送短信和邮件提醒用户注册成功,如果按照同步的流程走,它应该是这样的:
wangweijun
2022/01/10
3780
一文掌握RabbitMQ的简单使用与整合
springboot下使用rabbitMQ之开发配置方式(二)
消息参数传递在开发中也是个坑,不论使用内置的SimpleMessageConverter还是Jackson2JsonMessageConverter均无法让Consumer接收动态参数
上帝
2023/10/16
5730
springboot下使用rabbitMQ之开发配置方式(二)
【RabbitMQ】消息可靠性投递
什么是消息的可靠性投递?即保证消息百分百发送到消息队列中去,消息发送端需要接受到mq服务端接受到消息的确认应答。除此之外还应有完善的消息补偿机制,发送失败的消息可以再感知并二次处理。 生产者到交换机通过confirmCallback,交换机到队列通过returnCallback
后端码匠
2023/11/12
3350
springboot消息之整合rabbitmq
首先是删除掉上一节进行测试的全部消息,点击Purge--Purge messages。然后运行测试,在rabbitmq界面上查看,成功发送了过来。
西西嘛呦
2020/08/26
3840
springboot消息之整合rabbitmq
【Spring Boot】集成RabbitMQ
Spring-AMQP是Spring框架的AMQP消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的POJO的消息监听等。
后端码匠
2023/11/12
3360
Spring-boot 整合RabbitMQ ------基于注解的开发
spring: rabbitmq: host: 192.168.3.193 username: guest password: guest package com.shi.amqp; import org.springframework.amqp.rabbit.annotation.EnableRabbit; import org.springframework.boot.SpringApplication; import org.springframework.boot.a
用户5927264
2019/08/01
1.6K0
第三篇:SpringBoot与消息
版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/pyycsd/article/details/80969583
用户1212940
2019/06/20
6410
第三篇:SpringBoot与消息
【RabbitMQ】一文带你搞定RabbitMQ死信队列
RabbitMQ是流行的开源消息队列系统,使用erlang语言开发,由于其社区活跃度高,维护更新较快,性能稳定,深得很多企业的欢心(当然,也包括我现在所在公司【手动滑稽】)。
弗兰克的猫
2019/07/15
13.9K0
【RabbitMQ】一文带你搞定RabbitMQ死信队列
SpringBoot 笔记 ( 六):消息
SpringBoot 笔记 (六): 消息 1.基本概念 1.应用场景 2.重要概念 消息代理(broker):消息队列服务器 目的地:消息消费者 1.消息队列的两种目的地: 队列:点对点的通讯,这种
lwen
2018/06/19
7320
SpringBoot 整合 Rabbitmq
场景:用户注册,信息写入数据库后,需要给用户发送注册成功的邮件,再发送注册成功的邮件。
jwangkun
2021/12/23
4380
SpringBoot 整合 Rabbitmq
SpringBoot与消息
AMQP 中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别, AMQP 中增加了Exchange 和 Binding 的角色。生产者把消息发布到 Exchange 上,消息最终到达队列并被消费者接收,而 Binding 决定交换器的消息应该发送到那个队列。
OY
2022/03/12
4150
SpringBoot与消息
SpringBoot整合rabbitMQ
本文在已掌握rabbit基础用法的基础上书写,安装等操作不再赘述,默认文章使用的是单播模式; 创建工程
暴躁的程序猿
2022/09/16
2450
SpringBoot整合rabbitMQ
使用@RabbitListener注解消费消息
@RabbitListener注解指定目标方法作为消费消息的方法,通过注解参数指定所监听的队列或者Binding。
JavaEdge
2021/02/23
2.7K0
使用@RabbitListener注解消费消息
springboot消息之AmqpAdmin管理组件的使用
package com.gong.springbootrabbitmq; import com.gong.springbootrabbitmq.bean.Book; import org.junit.After; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.amqp.core.AmqpAdmin; import org.springframework.amqp.core.Binding
西西嘛呦
2020/08/26
7840
相关推荐
【RabbitMQ】消息确认机制ACK
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验