[大数据]RabbitMQ

	1.添加依赖
	<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    2.相关配置
	spring.rabbitmq.host=192.168.0.1
	spring.rabbitmq.port=5672
	spring.rabbitmq.virtual-host=/
	
	#开启发送端确认
	spring.rabbitmq.publisher-confirm-type=correlated
	#开启发送端消息抵达队列的确认
	spring.rabbitmq.publisher-returns=true
	#只要抵达队列 以异步方式优先回调returnconfirm
	spring.rabbitmq.template.mandatory=true
	#手动ack消息
	spring.rabbitmq.listener.simple.acknowledge-mode=manual
	
	3.主启动类注解 @EnableRabbit
	
	4.操作
		4.1 使用AmqpAdmin 
		@Autowired
		AmqpAdmin amqpAdmin;
		4.2 @Bean 创建

@Configuration
public class MyRabbitMQConfig {
	   @Bean
	   public Queue orderReleaseQueue() {
	      /*
            Queue(String name,  队列名字
            boolean durable,  是否持久化
            boolean exclusive,  是否排他
            boolean autoDelete, 是否自动删除
            Map<String, Object> arguments) 属性
         */
	        Queue queue = new Queue("order.release.order.queue",true, false, false);
	        return queue;
    }
      @Bean
    public Exchange orderEventExchange() {
        /*
         *   String name,
         *   boolean durable,
         *   boolean autoDelete,
         *   Map<String, Object> arguments
         * */
        return new TopicExchange("order-event-exchange", true, false);

    }
       @Bean
    public Binding orderReleaseBinding() {

        return new Binding("order.release.order.queue",
                Binding.DestinationType.QUEUE,
                "order-event-exchange",
                "order.release.order",
                null);
    }
    }