简单了解如何在spring中使用RabbitMQ

2023-08-04 15:41:03 74

这篇文章主要介绍了简单了解如何在spring中使用RabbitMQ,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

常见的消息中间件产品:

（1）ActiveMQ

ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMSProvider实现。

（2）RabbitMQ

AMQP协议的领导实现，支持多种场景。淘宝的MySQL集群内部有使用它进行通讯，OpenStack开源云平台的通信组件，最先在金融行业得到运用。我们在本次课程中介绍RabbitMQ的使用。

（3）ZeroMQ

史上最快的消息队列系统

（4）Kafka

Apache下的一个子项目。特点：高吞吐，在一台普通的服务器上既可以达到10W/s的吞吐速率；完全的分布式系统。适合处理海量数据。

（5）RocketMQ阿里巴巴

消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，它可以在分布式环境下扩展进程间的通信。对于消息中间件，常见的角色大致也就有Producer（生产者）、Consumer（消费者）。

消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。

Spring-amqp是对AMQP协议的抽象实现，而spring-rabbit是对协议的具体实现，也是目前的唯一实现。底层使用的就是RabbitMQ。

已经配置好了ssm的开发环境

1.导入依赖



com.rabbitmq
amqp-client
5.5.3


org.springframework.amqp
spring-rabbit
2.1.3.RELEASE



com.fasterxml.jackson.core
jackson-databind
2.9.5

2.编写生产者

2.1配置文件

2.2发送方代码

这里是往RabbitMQ队列中放入任务，让消费者去取

packagecn.test.rabbitmq.spring;

importorg.springframework.amqp.core.AmqpTemplate;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Component;

@Component
publicclassMqSender{
@Autowired
privateAmqpTemplateamqpTemplate;
publicvoidsendMessage(){
//根据key发送到对应的队列
amqpTemplate.convertAndSend("user.insert","spring整合RabbitMQ消息");
System.out.println("发送成功........");
}
}

2.3测试代码

packagecn.test.rabbitmq.spring;

importorg.junit.Test;
importorg.junit.runner.RunWith;
importorg.springframework.amqp.core.AmqpTemplate;
importorg.springframework.amqp.rabbit.core.RabbitTemplate;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.context.support.ClassPathXmlApplicationContext;
importorg.springframework.test.context.ContextConfiguration;
importorg.springframework.test.context.junit4.SpringJUnit4ClassRunner;
importorg.springframework.test.context.junit4.SpringRunner;

importjava.util.HashMap;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext-mq-send.xml")
publicclassMqSendDemo{

@Autowired
privateMqSendermqSender;
@Test
publicvoidtest(){
//根据key发送到对应的队列
mqSender.sendMessage();
}
}

3.编写消费者

3.1配置文件

3.2监听代码

packagecn.test.rabbitmq.spring;

importorg.springframework.amqp.core.Message;
importorg.springframework.amqp.core.MessageListener;
importorg.springframework.stereotype.Component;

importjava.io.UnsupportedEncodingException;

publicclassMqListenerimplementsMessageListener{

publicvoidonMessage(Messagemessage){
try{
System.out.println(message.getBody());
Stringms=newString(message.getBody(),"UTF-8");
System.out.println(ms);
}catch(Exceptione){
e.printStackTrace();
}
}
}

3.3测试代码

packagecn.itcast.rabbitmq.spring;

importorg.junit.Test;
importorg.junit.runner.RunWith;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.test.context.ContextConfiguration;
importorg.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:applicationContext-mq-receive.xml")
publicclassMqReceiveDemo{

@Test
publicvoidtest(){
//等待队列中放入任务，如果有任务，立即消费任务
while(true){
}
}
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

简单了解如何在spring中使用RabbitMQ

热门推荐

随机推荐