springboot整合rabbitmq
加入依賴：
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>1.5.6.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
</dependencies>
配置文件配置院溺，查看org.springframework.boot.autoconfigure.amqp.RabbitProperties這個類识樱，
具體的配置如下，在application.properties中定義如下
spring.rabbitmq.addresses=amqp://zhihao.miao:123456@192.168.1.131:5672
當(dāng)然下面的方式也可以
spring.rabbitmq.host=192.168.1.131
spring.rabbitmq.port=5672
spring.rabbitmq.username=zhihao.miao
spring.rabbitmq.password=123456
還有一些其他的配置,具體的情況可以去設(shè)置，比如：
requestedHeartbeat
publisherConfirms
publisherReturns
connectionTimeout
.....
自動聲明
配置類，
@Configuration
public class MQCOnfiguration {
@Bean
public Queue pay(){
return new Queue("pay",true);
}
@Bean
public Queue order(){
return new Queue("order",true);
}
}
應(yīng)用啟動類，
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class,args);
}
}
啟動應(yīng)用啟動類，發(fā)現(xiàn)隊列沒有自動聲明周霉，原因是自動聲明必須要和rabbitmq服務(wù)進(jìn)行連接。
改造成下面的：
@Configuration
public class MQCOnfiguration {
@Bean
public Queue pay(){
return new Queue("pay",true);
}
@Bean
public Queue order(){
return new Queue("order",true);
}
@Bean
public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory){
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueueNames("zhihao.miao.order");
container.setAcknowledgeMode(AcknowledgeMode.AUTO);
container.setMessageListener((MessageListener) message -> {
System.out.println("====接收到消息=====");
System.out.println(new String(message.getBody()));
});
return container;
}
}
啟動啟動類Application類亚皂，發(fā)現(xiàn)二個隊列自動聲明了俱箱。
總結(jié)
自動聲明的一些條件：
1.不需要在容器中去聲明ConnectionFactory，RabbitAdmin灭必，RabbitTemplate了狞谱，sprngboot自動幫我們管理了。
發(fā)送消息
@RestController
public class SendController {
@Autowired
private RabbitTemplate rabbitTemplate;
@GetMapping("/send/pay")
public String send(){
MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType("text");
rabbitTemplate.send("","pay", MessageBuilder.withBody("支付了1023.00".getBytes()).
andProperties(messageProperties).build());
return "Success";
}
}
應(yīng)用啟動類
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class,args);
}
}
發(fā)送消息：http://localhost:8080/send/pay
從控制臺上發(fā)現(xiàn)消息已經(jīng)發(fā)送成功
從發(fā)送消息的列子我們知道spring已經(jīng)托管了RabbitmqTemplate這個對象
消費消息厂财，使用注解的方式監(jiān)聽隊列
@Component
public class MessageHandle {
@RabbitListener(queues = "pay")
public void handle(String body){
System.out.println("=====handle==========");
System.out.println(body);
}
}
應(yīng)用啟動類
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class,args);
}
}
我們之前學(xué)習(xí)的時候芋簿，使用spring-amqp發(fā)現(xiàn)使用@RabbitListener注解的時候，必須聲明org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory對象璃饱，而如果使用springboot的方式則不需要自己在容器中聲明org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory与斤。
總結(jié)
使用springboot之后，很多前置的Bean都已經(jīng)被裝配好了荚恶，我們直接使用就行了撩穿，之前在spring-amqp中怎么使用的，現(xiàn)在還是怎么用谒撼。
