update

edu-user/edu-user-server/src/main/java/com/keao/edu/user/config/RabbitConfig.java

@@ -0,0 +1,34 @@
+package com.keao.edu.user.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;
+
+@Configuration
+public class RabbitConfig {
+    //交换机名称
+    public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
+    //队列名称
+    public static final String ITEM_QUEUE = "item_queue";
+
+    //声明交换机
+    @Bean("itemTopicExchange")
+    public Exchange topicExchange(){
+        return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
+    }
+
+    //声明队列
+    @Bean("itemQueue")
+    public Queue itemQueue(){
+        return QueueBuilder.durable(ITEM_QUEUE).build();
+    }
+
+    //绑定队列和交换机
+    @Bean
+    public Binding itemQueueExchange(@Qualifier("itemQueue") Queue queue,
+                                     @Qualifier("itemTopicExchange") Exchange exchange){
+        return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
+    }
+}