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

当然下面的方式也可以

spring.rabbitmq.host=192.168.1.131
spring.rabbitmq.port=5672
spring.rabbitmq.username=zhihao.miao
spring.rabbitmq.password=123456

还有一些其他的配置,具体的情况可以去设置，比如：

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);
    }

 }

应用启动类，

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class,args);
    }
}

启动应用启动类，发现队列没有自动声明，原因是自动声明必须要和rabbitmq服务进行连接。

改造成下面的：

 @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类，发现二个队列自动声明了。

总结
自动声明的一些条件：
1.不需要在容器中去声明ConnectionFactory，RabbitAdmin，RabbitTemplate了，sprngboot自动帮我们管理了。

发送消息

@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";
    }
}

应用启动类

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class,args);
    }
}

发送消息：http://localhost:8080/send/pay

从控制台上发现消息已经发送成功

从发送消息的列子我们知道spring已经托管了RabbitmqTemplate这个对象

消费消息，使用注解的方式监听队列

@Component
public class MessageHandle {

    @RabbitListener(queues = "pay")
    public void handle(String body){
        System.out.println("=====handle==========");
        System.out.println(body);
    }
}

应用启动类

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class,args);
    }
}

我们之前学习的时候，使用spring-amqp发现使用@RabbitListener注解的时候，必须声明org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory对象，而如果使用springboot的方式则不需要自己在容器中声明org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory。

总结
使用springboot之后，很多前置的Bean都已经被装配好了，我们直接使用就行了，之前在spring-amqp中怎么使用的，现在还是怎么用。