MQ的简单使用
2024-01-03 15:30:16
1、创建一个配置类,这里根据enable变量判断是否开启mq配置
package com.lili.office.config;
import org.apache.commons.lang3.StringUtils;
import org.springframework.amqp.core.Queue;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
@Configuration
public class RabbitmqConfig {
@Value("${spring.rabbitmq.host:}")
private String rabbitmqHost;
public static boolean enable = false;
@PostConstruct
public void init() {
enable = StringUtils.isNotEmpty(rabbitmqHost);
}
public final static String QUEUE_NAME = "ly-jamiechyi_test";
@Bean
public Queue queue() {
return new Queue(QUEUE_NAME);
}
}
2、发送消息
@Autowired
private AmqpTemplate rabbitTemplate;
@GetMapping("/test1")
public void test1(){
if (RabbitmqConfig.enable){
// 发送一条消息
rabbitTemplate.convertAndSend(RabbitmqConfig.QUEUE_NAME,"2");
}
}
3、主动消费方式
if (RabbitmqConfig.enable){
// 接收一条消息
Object o = rabbitTemplate.receiveAndConvert(RabbitmqConfig.QUEUE_NAME);
// 其他逻辑
}
4、监听消息进行消费方式
@Component
public class MessageConsumer {
@RabbitListener(queues = RabbitmqConfig.QUEUE_NAME)
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
// 在这里编写处理消息的逻辑
}
}
文章来源:https://blog.csdn.net/qijing19991210/article/details/135363959
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!