package com.xzx.log.config;
|
|
import com.xzx.log.constants.MqConstants;
|
import lombok.Data;
|
import org.springframework.amqp.core.*;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.stereotype.Component;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Configuration
|
public class LogQueueConfig {
|
|
|
|
//直连交换机
|
private String LOG_EXCHANGE = "log_exchange";
|
|
/**
|
* 定义死信队列相关信息
|
*/
|
|
public final static String deadRoutingKey = "dead_routing_key";
|
public final static String deadExchange = "dead_exchange";
|
/**
|
* 死信队列 交换机标识符
|
*/
|
public static final String DEAD_EXCHANGE = "x-dead-letter-exchange";
|
/**
|
* 死信队列交换机绑定键标识符
|
*/
|
public static final String DEAD_ROUTING_KEY = "x-dead-letter-routing-key";
|
|
// 定义队列
|
// @Bean
|
// public Queue accountLogQueue() {
|
// return new Queue(MqConstants.ACCOUNT_LOG_QUEUE);
|
// }
|
|
@Bean
|
public Queue intefaceAdminLogQueue() {
|
Map<String, Object> args = new HashMap<>(2);
|
args.put(DEAD_EXCHANGE, deadExchange);
|
args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
return new Queue(MqConstants.INTEFACE_ADMIN_LOG_QUEUE,true,false,false,args);
|
}
|
@Bean
|
public Queue operationAppLogQueue() {
|
Map<String, Object> args = new HashMap<>(2);
|
args.put(DEAD_EXCHANGE, deadExchange);
|
args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
return new Queue(MqConstants.OPERATION_APP_LOG_QUEUE,true,false,false,args);
|
}
|
// @Bean
|
// public Queue operationLogQueue() { Map<String, Object> args = new HashMap<>(2);
|
// args.put(DEAD_EXCHANGE, deadExchange);
|
// args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
// return new Queue(MqConstants.OPERATION_LOG_QUEUE,true,false,false,args);
|
// }
|
// @Bean
|
// public Queue orderOperationLogQueue() {
|
// Map<String, Object> args = new HashMap<>(2);
|
// args.put(DEAD_EXCHANGE, deadExchange);
|
// args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
// return new Queue(MqConstants.ORDER_OPERATION_LOG_QUEUE,true,false,false,args);
|
// }
|
// @Bean
|
// public Queue payInfoLogQueue() {
|
// Map<String, Object> args = new HashMap<>(2);
|
// args.put(DEAD_EXCHANGE, deadExchange);
|
// args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
// return new Queue(MqConstants.PAY_INFO_LOG_QUEUE,true,false,false,args);
|
// }
|
@Bean
|
public Queue sysProgramLogQueue() {
|
Map<String, Object> args = new HashMap<>(2);
|
args.put(DEAD_EXCHANGE, deadExchange);
|
args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
return new Queue(MqConstants.SYS_PROGRAM_LOG_QUEUE,true,false,false,args);
|
}
|
|
// @Bean
|
// public Queue tradeAccountQueue() {
|
// Map<String, Object> args = new HashMap<>(2);
|
// args.put(DEAD_EXCHANGE, deadExchange);
|
// args.put(DEAD_ROUTING_KEY, deadRoutingKey);
|
// return new Queue(MqConstants.TRADE_ACCOUNT_LOG_QUEUE,true,false,false,args);
|
// }
|
|
|
//定义交换机
|
@Bean
|
public DirectExchange logExchange() {
|
return new DirectExchange(LOG_EXCHANGE);
|
}
|
|
//绑定交换机
|
// @Bean
|
// Binding bindingaccountLogQueue(Queue accountLogQueue, DirectExchange logExchange) {
|
// return BindingBuilder.bind(accountLogQueue).to(logExchange).with(MqConstants.ACCOUNT_LOG_QUEUE);
|
// }
|
// @Bean
|
// Binding bindingtradeAccountQueue(Queue tradeAccountQueue, DirectExchange logExchange) {
|
// return BindingBuilder.bind(tradeAccountQueue).to(logExchange).with(MqConstants.TRADE_ACCOUNT_LOG_QUEUE);
|
// }
|
|
@Bean
|
Binding bindingintefaceAdminLogQueue(Queue intefaceAdminLogQueue, DirectExchange logExchange) {
|
return BindingBuilder.bind(intefaceAdminLogQueue).to(logExchange).with(MqConstants.INTEFACE_ADMIN_LOG_QUEUE);
|
}
|
@Bean
|
Binding bindingoperationAppLogQueue(Queue operationAppLogQueue, DirectExchange logExchange) {
|
return BindingBuilder.bind(operationAppLogQueue).to(logExchange).with(MqConstants.OPERATION_APP_LOG_QUEUE);
|
}
|
// @Bean
|
// Binding bindingoperationLogQueue(Queue operationLogQueue, DirectExchange logExchange) {
|
// return BindingBuilder.bind(operationLogQueue).to(logExchange).with(MqConstants.OPERATION_LOG_QUEUE);
|
// }
|
// @Bean
|
// Binding bindingorderOperationLogQueue(Queue orderOperationLogQueue, DirectExchange logExchange) {
|
// return BindingBuilder.bind(orderOperationLogQueue).to(logExchange).with(MqConstants.ORDER_OPERATION_LOG_QUEUE);
|
// }
|
// @Bean
|
// Binding bindingpayRequestInfoQueue(Queue payInfoLogQueue, DirectExchange logExchange) {
|
// return BindingBuilder.bind(payInfoLogQueue).to(logExchange).with(MqConstants.PAY_INFO_LOG_QUEUE);
|
// }
|
@Bean
|
Binding bindingsysProgramLogQueue(Queue sysProgramLogQueue, DirectExchange logExchange) {
|
return BindingBuilder.bind(sysProgramLogQueue).to(logExchange).with(MqConstants.SYS_PROGRAM_LOG_QUEUE);
|
}
|
|
|
/**
|
* 创建配置死信队列
|
*
|
* @return
|
*/
|
@Bean
|
public Queue deadQueue() {
|
Queue queue = new Queue(MqConstants.DEAD_QUEUE, true);
|
return queue;
|
}
|
/*
|
* 创建死信交换机
|
*/
|
@Bean
|
public DirectExchange deadExchange() {
|
return new DirectExchange(deadExchange);
|
}
|
/*
|
* 死信队列与死信交换机绑定
|
*/
|
@Bean
|
public Binding bindingDeadExchange(Queue deadQueue, DirectExchange deadExchange) {
|
return BindingBuilder.bind(deadQueue).to(deadExchange).with(deadRoutingKey);
|
}
|
|
}
|
