代码库
https://gitee.com/liyghting/springrabbitmqdemo
原理
基于spring启动的时候加载发布订阅配置,发送基于json的消息。
step1:实现Spring接口
step2:生产者配置信息Spring的Bean生成
step3:消费者配置信息初始化和建立监听
具体代码请看RabbitmqConfig.java
发布消息例子
配置application.yml
rabbitmqProducerMap:
testProducer1:
exchangeName: testExchange
routingKey: test1
producerBeanName: test1Producer
testProducer2:
exchangeName: testExchange
routingKey: test2
producerBeanName: test2Producer
代码
ProducerUtil.send("test1Producer", user);
具体请看TestProducer.java
订阅消息例子
配置application.yml
rabbitmqBindingMap:
test1Binding:
queueName: test1Queue
exchangeName: testExchange
routingKey: test1
consumerBeanName: test1Consumer
test2Binding:
queueName: test2Queue
exchangeName: testExchange
routingKey: test2
consumerBeanName: test2Consumer
代码实现BaseConsumer两个方法
@Override
public ParameterizedTypeReference<ReceiveUser> getParameterizedTypeReference() {
return new ParameterizedTypeReference<ReceiveUser>() {
};
}
@Override
public void handleMsg(ReceiveUser msg) {
logger.info("Test1Consumer " + msg);
}
具体请看Test1Consumer.java
相关推荐
基于SpringBoot+RabbitMQ用户注册实现异步发送验证码源码。基于SpringBoot+RabbitMQ用户注册实现异步发送验证码源码。基于SpringBoot+RabbitMQ用户注册实现异步发送验证码源码。...基于SpringBoot+Rabbit
基于SpringBoot+RabbitMQ+Redis开发的秒杀系统源码+数据库.zip 下载即用无需修改。 基于SpringBoot+RabbitMQ+Redis开发的秒杀系统源码+数据库.zip 下载即用无需修改。基于SpringBoot+RabbitMQ+Redis开发的秒杀...
Springboot整合RabbitMQ最简单demo,适用于springcloud项目,作为消息总线适用,需要安装RabbitMQ,Mac linux可以使用命令行一键安装,在项目配置文件配置好端口即可(已默认配置),启动项目访问8080端口,参数见controller.
基于springboot和rabbitmq的消息收发demo,学习共享 基于springboot和rabbitmq的消息收发demo,学习共享
基于SpringBoot整合RabbitMQ发送邮件通知---构建springcloud微服务资源搭建。
SpringBoot整合RabbitMQ的详细过程 **1.该篇博文首先讲述了交换机和队列之间的绑定关系** ①direct、②fanout、③topic **2.然后讲消息的回调** 四种情况下,确认触发哪个回调函数: ①消息推送到server,但是在...
springboot+rabbitMQ+websocket,实现消息推送聊天,简单的demo
文件内包含了rabbit安装的必需文件以及springboot整合rabbitmq的完整代码,代码里包含了原生的rabbitmq使用代码和整合springboot后的使用代码,还有rabbit队列的所有消息队列模式,代码简单易懂,解压打开就可以使用
使用springboot+rabbitmq搭建一个简单的消息队列项目。
springboot使用rabbitmq工具类,里面包含比较原生的方法,还有一套是我结合springboot框架写的一套方法,里面有两个方法,看情况使用,一般使用框架的方法比较好,因为框架方法时前辈们封装好经过检验的没有问题的方法,...
基于SpringBoot的Rabbitmq和Redis调用示例,在Springboot框架中,简单调用Redis和Rabbitmq
SpringBoot整合Rabbitmq发送接收消息实战 另外,博主发起了SpringBoot整合Rabbitmq这一系列的gitchat交流会。刚兴趣的童鞋可以进入交流:https://gitbook.cn/gitchat/activity/5b90f9214fb1bd5c9acd4338 交流QQ:...
该示例通过 rabbitmq_delayed_message_exchange 插件实现自定义延时时间的延时队列。 示例是纯净的,只引入了需要的架包 启动示例时,请确保MQ已经安装了延时插件(附件里带有插件及安装说明)以及示例的MQ相关的配置...
SpringBoot整合RabbitMQ 实现消息发送确认与消息接收确认机制 源码及教材 可以参考博客: https://blog.csdn.net/qq_29914837/article/details/93376741
springboot整合rabbitmq,开启手工确认,保证消息100%投递。springboot整合rabbitmq,开启手工确认,保证消息100%投递。
springBoot整合RabbitMQ案例
springboot,rabbitmq,maven,postman
SpringBoot集成RabbitMQ消息中间件的使用。消息管理中心,消息提供方,消息消费方,并实现消息提供返回的ack校验以及借用redis完成消息补偿机制。
基于 SpringBoot、Vue、Mybatis、RabbitMq、Mysql、Redis 等开发的轻量级的物联网综合业务支撑平台。支持物联网卡、物联网模组、卡+模组融合管理。提供状态、资费、客户、进销存、合同、订单、续费、充值、诊断、...
主要为大家详细介绍了SpringBoot下RabbitMq实现定时任务,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下