ActiveMQ 和 JMS的关系?
ActiveMQ是流行的开源消息中间件,JMS是Java平台定义的一种消息传递的标准。ActiveMQ实现了JMS规范,因此可以使用JMS API来与ActiveMQ进行交互。
JMS定义了一种标准的API。API包括了一些接口和类,用于创建、发送、接收和处理消息。ActiveMQ实现了这些接口和类,并提供了一些额外的功能,例如消息持久化、消息过滤、事务支持等。
JmsMessagingTemplate跟ActiveMQ的关系?
JmsMessagingTemplate是Spring框架提供的JMS消息发送工具类,封装了JMS API的细节,使得发送JMS消息变得更加简单和方便。
JmsMessagingTemplate可以与任何实现了JMS规范的消息中间件集成,包括ActiveMQ。使用JmsMessagingTemplate发送消息时,需要指定目标消息队列或主题,以及消息内容。JmsMessagingTemplate会将消息封装成JMS消息对象,并通过JMS API将消息发送到指定的消息队列或主题。ActiveMQ则负责接收JMS消息,并将其存储在消息队列或主题中,等待消费者进行消费。
@JmsListener的作用?
@JmsListener是Spring JMS提供的一个注解,用于监听JMS消息队列或主题,并在收到消息时执行相应的方法。文章来源:https://www.toymoban.com/news/detail-712499.html
ActiveMQ用法
引入依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId>
</dependency>
</dependencies>
application.properties配置文件
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin
# 队列名-支持自定义
spring.activemq.queue-name=queueTest
# 主题名-支持自定义
spring.activemq.topic-name=topicTest
配置类
// 加上@EnableJms是异步,不加默认是同步
@Configuration
public class ActiveMqConfig {
@Value("${spring.activemq.broker-url}")
private String brokerUrl;
@Value("${spring.activemq.user}")
private String userName;
@Value("${spring.activemq.password}")
private String password;
@Value("${spring.activemq.queue-name}")
private String queueName;
@Value("${spring.activemq.topic-name}")
private String topicName;
@Bean(name = "queue")
public Queue queue() {
return new ActiveMQQueue(queueName);
}
@Bean(name = "topic")
public Topic topic(){
return new ActiveMQTopic(topicName);
}
@Bean
public ConnectionFactory connectionFactory(){
return new ActiveMQConnectionFactory(userName, password, brokerUrl);
}
/**
* 在Queue模式中,对消息的监听需要对containerFactory进行配置
* @param connectionFactory
* @return
*/
@Bean("queueListener")
public JmsListenerContainerFactory<?> queueJmsListenerContainerFactory(ConnectionFactory connectionFactory){
SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
// false的队列,true是主题
factory.setPubSubDomain(false);
return factory;
}
/**
* 在topic模式中,对消息的监听需要对containerFactory进行配置
* @param connectionFactory
* @return
*/
@Bean("topicListener")
public JmsListenerContainerFactory<?> topicJmsListenerContainerFactory(ConnectionFactory connectionFactory){
SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
// false的队列,true是主题
factory.setPubSubDomain(true);
return factory;
}
}
生产者
@RestController
@RequestMapping("/activemq")
public class ProducerController {
@Resource
private JmsMessagingTemplate jmsMessagingTemplate;
@Autowired
private Queue queue;
@Autowired
private Topic topic;
/**
* queue模式mq消息发送
* @param msg
* @return
*/
@GetMapping("/queue")
public String sendQueue(String msg) {
jmsMessagingTemplate.convertAndSend(queue, msg);
return "success, 发送消息:" + msg;
}
/**
* topic模式一对多的消息队列的生产者
* @param msg
*/
@GetMapping("/topic")
public String sendMsgTopic(@RequestParam String msg){
jmsMessagingTemplate.convertAndSend(topic,msg);
return "success, 发送消息:" + msg;
}
}
消费者
@Component
public class Consumer {
/**
* queue模式的消费者
* @param msg
*/
@JmsListener(destination="${spring.activemq.queue-name}", containerFactory="queueListener")
public void queueConsumer(String msg) {
System.out.println("queue收到消息:" + msg);
}
/**
* topic模式的消费者
* @param msg
*/
@JmsListener(destination = "${spring.activemq.topic-name}", containerFactory = "topicListener")
public void topicConsumer(String msg){
System.out.println("topic收到消息:" + msg);
}
}
原文博客:https://blog.csdn.net/imVainiycos/article/details/126021665?spm=1001.2014.3001.5506文章来源地址https://www.toymoban.com/news/detail-712499.html
到了这里,关于ActiveMQ用法的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!