RabbitMQ与Springboot结合
业务场景描述:
客户端发起订单请求到订单系统,订单系统处理完订单后,将消息转发到消息中间件,然后库存系统监听该消息中间件相应的队列。一、依赖
主项目为maven项目,在主项目上新增两个module,分别为生产者和消费者
主项目pom文件,主要定义spring-boot-start-parent
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.3.RELEASE</version>
</parent>
<groupId>cn.zeus</groupId>
<artifactId>amqp-demo</artifactId>
<packaging>pom</packaging>
<version>1.0-SNAPSHOT</version>
<modules>
<module>spring-boot-rabbitmq-producer</module>
<module>spring-boot-rabbitmq-consumer</module>
</modules>
</project>
二个子项目的pom
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>amqp-demo</artifactId>
<groupId>cn.zeus</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>spring-boot-rabbitmq-producer</artifactId>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.57</version>
</dependency>
</dependencies>
</project>
二、生产者
1.启动类
@SpringBootApplication
public class AppOrder {
public static void main(String[] args) {
SpringApplication.run(AppOrder.class);
}
}
2.配置类
@Configuration
public class RabbitmqConfig {
@Bean
public ConnectionFactory connectionFactory(){
CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost",5672);
// connectionFactory.setHost("localhost");
// connectionFactory.setPort(5672);
connectionFactory.setUsername("admin");
connectionFactory.setPassword("admin");
connectionFactory.setVirtualHost("testhost");
//是否开启消息确认机制
//connectionFactory.setPublisherConfirms(true);
return connectionFactory;
}
//配置tomcat端口
@Bean
public TomcatServletWebServerFactory tomcatServletWebServerFactory(){
TomcatServletWebServerFactory tomcatServletWebServerFactory = new TomcatServletWebServerFactory(8080);
return tomcatServletWebServerFactory;
}
//如果使用yml,这个RabbitTemplate是不用配置的
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
// rabbitTemplate.setConnectionFactory(connectionFactory);
//消息转化器
// rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
return rabbitTemplate;
}
//创建交换机
@Bean
public DirectExchange directExchange(){
return new DirectExchange("directExchage");
}
//创建队列
@Bean
public Queue queue(){
return new Queue("testQueue",true);
}
//创建绑定
@Bean
public Binding binding(){
return BindingBuilder.bind(queue()).to(directExchange()).with("direct.key");
}
}
3.发送消息工具类
@Component
public class RabbitmqMessageSend {
@Autowired
RabbitTemplate rabbitTemplate;
public void sendMessage(String message, String routingKey,String exchangeName){
rabbitTemplate.convertAndSend(exchangeName,routingKey,message);
}
}
4.接口类
@RestController
public class OrderController {
@Autowired
RabbitmqMessageSend rabbitmqMessageSend;
@RequestMapping("/order.do")
public Object order(String message, String name,String routingKey){
rabbitmqMessageSend.sendMessage(message, routingKey,name);
return "下单成功";
}
}
5.接口调用
http://localhost:8080/order.do?message=123&routingKey=direct.key&name=directExchage
三、消费者
1.启动类
@SpringBootApplication
public class AppRepertory {
public static void main(String[] args) {
SpringApplication.run(AppRepertory.class,args);
}
}
2.配置类
Configuration
public class RabbitmqConfig {
@Bean
public ConnectionFactory connectionFactory(){
CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost",5672);
// connectionFactory.setHost("localhost");
// connectionFactory.setPort(5672);
connectionFactory.setUsername("admin");
connectionFactory.setPassword("admin");
connectionFactory.setVirtualHost("testhost");
//是否开启消息确认机制
connectionFactory.setPublisherConfirms(true);
return connectionFactory;
}
//如果使用yml,这个RabbitTemplate是不用配置的
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
// rabbitTemplate.setConnectionFactory(connectionFactory);
return rabbitTemplate;
}
//配置tomcat端口
@Bean
public TomcatServletWebServerFactory tomcatServletWebServerFactory(){
TomcatServletWebServerFactory tomcatServletWebServerFactory = new TomcatServletWebServerFactory(8082);
return tomcatServletWebServerFactory;
}
}
3.监听队列类
@Component
public class RabbitmqUtil {
@RabbitListener(queues = "testQueue")
public void get(String message ){
System.out.println(message);
}
}