在Spring项目中,可以使用Spring-Rabbit
去操作RabbitMQ
尤其是在spring boot项目中只需要引入对应的amqp启动器依赖
即可,方便的使用RabbitTemplate
发送消息,使用注解接收消息。
一般在开发过程中: 生产者工程:
消费者工程:
创建一个Spring Boot
项目:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
#端口
server.port=8111
#rabbitmq配置
#这里是自己的ip地址
spring.rabbitmq.host=192.168.57.129
spring.rabbitmq.port=5672
#自己设置的有权限的账号密码
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin
@Configuration
public class RabbitMQConfig {
//交换机名称
public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
//队列名称
public static final String ITEM_QUEUE = "item_queue";
//声明交换机
@Bean("itemTopicExchange")
public Exchange topicExchange(){
return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
}
//声明队列
@Bean("itemQueue")
public Queue itemQueue(){
return QueueBuilder.durable(ITEM_QUEUE).build();
}
//绑定队列和交换机
@Bean
public Binding itemQueueExchange(@Qualifier("itemQueue") Queue queue,
@Qualifier("itemTopicExchange") Exchange exchange){
return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
}
}
@RestController
public class SendMsgController {
//注入rabbitmq模板
@Autowired
private RabbitTemplate rabbitTemplate;
@GetMapping("/sendmsg")
public String sendMsg(@RequestParam String msg,@RequestParam String key){
/**
* 发送消息
* 参数1:交换机名称
* 参数2:路由 key
* 参数3:发送的消息
*/
rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE,key,msg);
//返回消息
return "发送消息成功";
}
}
创建一个Spring Boot
项目:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
@Component
public class MyListener {
@RabbitListener(queues = "item_queue")
public void msg(String msg){
System.out.println("消费者运行:"+msg);
}
}
路径为:localhost:8111/sendmsg?msg=这是一个测试鸭&key=item.test
个人博客为: MoYu’s HomePage