package cn.linkpower.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
import java.util.Map;
@Configuration
public class MQConfiguration {
	// ===========================  Direct 直連模式  ==================================
	//隊(duì)列名稱
	public static final String QUEUQ_NAME = "xiangjiao.queue";
	//交換器名稱
	public static final String EXCHANGE = "xiangjiao.exchange";
	//路由key
	public static final String ROUTING_KEY = "xiangjiao.routingKey";
	// =========================== Direct 普通隊(duì)列申明 和 交換機(jī)綁定  ===================
	//創(chuàng)建隊(duì)列
	@Bean(value = "getQueue")
	public Queue getQueue(){
		//QueueBuilder.durable(QUEUQ_NAME).build();
		return new Queue(QUEUQ_NAME);
	}
	//實(shí)例化交換機(jī)
	@Bean(value = "getDirectExchange")
	public DirectExchange getDirectExchange(){
		//DirectExchange(String name, boolean durable, boolean autoDelete)
		/**
		 * 參數(shù)一：交換機(jī)名稱；<br>
		 * 參數(shù)二：是否永久；<br>
		 * 參數(shù)三：是否自動(dòng)刪除；<br>
		 */
		//ExchangeBuilder.directExchange(EXCHANGE).durable(true).build();
		return new DirectExchange(EXCHANGE, true, false);
	//綁定消息隊(duì)列和交換機(jī)
	@Bean
	public Binding bindExchangeAndQueue(@Qualifier(value = "getDirectExchange")  DirectExchange exchange,
										@Qualifier(value = "getQueue") Queue queue){
		return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
	// ===========================  TTL ================================
	public static final String ttl_queue_name = "xiangjiao.ttl.queue";
	public static final String ttl_exchange_name = "xiangjiao.ttl.exchange";
	public static final String ttl_routing_key = "xiangjiao.ttl.routingKey";
	@Bean(value = "getTtlQueue")
	public Queue getTtlQueue(){
		// 設(shè)置 ttl 隊(duì)列，并設(shè)定 x-message-ttl 參數(shù)，表示 消息存活最大時(shí)間，單位  ms
		//return QueueBuilder.durable(ttl_queue_name).withArgument("x-message-ttl",10000).build();
		Map<String, Object> arguments = new HashMap<>();
		arguments.put("x-message-ttl",10000);
		return new Queue(ttl_queue_name,true,false,false,arguments);
	@Bean(value = "getTTlExchange")
	public DirectExchange getTTlExchange(){
		// 設(shè)置交換機(jī)屬性，并保證交換機(jī)持久化
		return new DirectExchange(ttl_exchange_name, true, false);
	public Binding bindExchangeAndQueueTTL(@Qualifier(value = "getTTlExchange")  DirectExchange getTTlExchange,
										   @Qualifier(value = "getTtlQueue") Queue queue){
		return BindingBuilder.bind(queue).to(getTTlExchange).with(ttl_routing_key);
}

Map<String, Object> arguments = new HashMap<>();
arguments.put("x-message-ttl",10000);
return new Queue(ttl_queue_name,true,false,false,arguments);

/**
 * 發(fā)送消息，指定ttl參數(shù)信息（隊(duì)列）
 * @return
 */
@RequestMapping("/sendQueueTtl")
@ResponseBody
public String sendQueueTtl(){
	//發(fā)送10條消息
	for (int i = 0; i < 10; i++) {
		String msg = "msg"+i;
		System.out.println("發(fā)送消息  msg："+msg);
		rabbitmqService.sendMessage(MQConfiguration.ttl_exchange_name,MQConfiguration.ttl_routing_key,msg);
		//每?jī)擅氚l(fā)送一次
		try {
			Thread.sleep(8000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
	return "send ok";
}

// ===========================  Direct 直連模式  ==================================
//隊(duì)列名稱
public static final String QUEUQ_NAME = "xiangjiao.queue";
//交換器名稱
public static final String EXCHANGE = "xiangjiao.exchange";
//路由key
public static final String ROUTING_KEY = "xiangjiao.routingKey";

// =========================== Direct 普通隊(duì)列申明 和 交換機(jī)綁定  ===================
//創(chuàng)建隊(duì)列
@Bean(value = "getQueue")
public Queue getQueue(){
	//QueueBuilder.durable(QUEUQ_NAME).build();
	return new Queue(QUEUQ_NAME);
}
//實(shí)例化交換機(jī)
@Bean(value = "getDirectExchange")
public DirectExchange getDirectExchange(){
	//DirectExchange(String name, boolean durable, boolean autoDelete)
	/**
	 * 參數(shù)一：交換機(jī)名稱；<br>
	 * 參數(shù)二：是否永久；<br>
	 * 參數(shù)三：是否自動(dòng)刪除；<br>
	 */
	//ExchangeBuilder.directExchange(EXCHANGE).durable(true).build();
	return new DirectExchange(EXCHANGE, true, false);
}
//綁定消息隊(duì)列和交換機(jī)
@Bean
public Binding bindExchangeAndQueue(@Qualifier(value = "getDirectExchange")  DirectExchange exchange,
									@Qualifier(value = "getQueue") Queue queue){

	return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
}

/**
 * 發(fā)送消息，指定ttl參數(shù)信息（單個(gè)消息）;
 * 測(cè)試需要將消息消費(fèi)者關(guān)閉監(jiān)聽(tīng)
 * @return
 */
@RequestMapping("/sendTtl")
@ResponseBody
public String sendTtl(){
	//發(fā)送10條消息
	for (int i = 0; i < 10; i++) {
		String msg = "msg"+i;
		System.out.println("發(fā)送消息  msg："+msg);
		
		MessageProperties messageProperties = new MessageProperties();
		messageProperties.setExpiration("5000"); // 針對(duì)消息設(shè)定時(shí)限
		// 將消息數(shù)據(jù)和設(shè)置屬性進(jìn)行封裝，采取消息發(fā)送模板，將消息數(shù)據(jù)推送至指定的交換機(jī) exchange 中
		Message message = new Message(msg.getBytes(), messageProperties);
		
		rabbitmqService.sendMessage(MQConfiguration.EXCHANGE, MQConfiguration.ROUTING_KEY,message);
		//每?jī)擅氚l(fā)送一次
		try {
			Thread.sleep(3000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
	return "send ok";
}

MessageProperties messageProperties = new MessageProperties();
messageProperties.setExpiration("5000"); // 針對(duì)消息設(shè)定時(shí)限
// 將消息數(shù)據(jù)和設(shè)置屬性進(jìn)行封裝，采取消息發(fā)送模板，將消息數(shù)據(jù)推送至指定的交換機(jī) exchange 中
Message message = new Message(msg.getBytes(), messageProperties);