package org.springblade.modules.rabbitmq.config;
|
|
import org.springframework.amqp.core.*;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
|
/**
|
* rabbitmq 配置文件
|
* @author zhongrj
|
* @since 2022-04-08
|
*/
|
@Configuration
|
public class MQConfig {
|
public static final String QUEUE = "queue";
|
public static final String TOPIC_QUEUE1= "topic.queue1";
|
public static final String TOPIC_QUEUE2 = "topic.queue2";
|
public static final String TOPIC_EXCHANGE = "topicExchange";
|
public static final String FANOUT_EXCHANGE = "fanoutxchage";
|
public static final String TASK_QUEUE = "task_queue";
|
|
@Bean
|
public Queue taskQueue(){
|
return new Queue(TASK_QUEUE,true);
|
}
|
|
//Direct模式
|
@Bean
|
public Queue queue(){
|
return new Queue(QUEUE,true);
|
}
|
|
//topic交换机模式
|
@Bean
|
public Queue topicQueue1(){
|
return new Queue(TOPIC_QUEUE1,true);
|
}
|
|
@Bean
|
public Queue topicQueue2(){
|
return new Queue(TOPIC_QUEUE2,true);
|
}
|
|
@Bean
|
public TopicExchange topicExchange(){
|
return new TopicExchange(TOPIC_EXCHANGE);
|
}
|
|
@Bean
|
public Binding topicBinding1(){
|
return BindingBuilder.bind(topicQueue1()).to(topicExchange()).with("topic.key1");
|
}
|
|
@Bean
|
public Binding topicBinding2(){
|
return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with("topic.#");
|
}
|
|
//Fanout模式，广播模式
|
|
@Bean
|
public FanoutExchange fanoutExchange(){
|
return new FanoutExchange(FANOUT_EXCHANGE);
|
}
|
}
|
