集成springAMQP

xdclass-common/pom.xml

@@ -136,6 +136,11 @@
 <!--            <version>1.3.0</version>-->
 <!--        </dependency>-->
 
+        <!--引入AMQP-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
 
     </dependencies>
 

xdclass-coupon-service/src/main/resources/application.yml

@@ -11,6 +11,18 @@ spring:
       discovery:
         server-addr: 8.134.32.140:8848
 
+  #消息队列
+  rabbitmq:
+    host: 134.175.219.253
+    port: 5672
+    virtual-host: /
+    password: jieyuu
+    username: admin
+    #开启手动确认消息
+    listener:
+      simple:
+        acknowledge-mode: manual
+
   #数据库配置
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver

xdclass-order-service/src/main/resources/application.yml

@@ -10,6 +10,17 @@ spring:
       discovery:
         server-addr: 8.134.32.140:8848
 
+  #消息队列
+  rabbitmq:
+    host: 134.175.219.253
+    port: 5672
+    virtual-host: /
+    password: jieyuu
+    username: admin
+    #开启手动确认消息
+    listener:
+      simple:
+        acknowledge-mode: manual
 
   #数据库配置
   datasource:

xdclass-product-service/src/main/resources/application.yml

@@ -10,6 +10,18 @@ spring:
       discovery:
         server-addr: 8.134.32.140:8848
 
+  #消息队列
+  rabbitmq:
+    host: 134.175.219.253
+    port: 5672
+    virtual-host: /
+    password: jieyuu
+    username: admin
+    #开启手动确认消息
+    listener:
+      simple:
+        acknowledge-mode: manual
+
   #数据库配置
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver

xdclass-user-service/src/main/resources/application.yml

@@ -10,6 +10,17 @@ spring:
       discovery:
         server-addr: 8.134.32.140:8848
 
+  #消息队列
+  rabbitmq:
+    host: 134.175.219.253
+    port: 5672
+    virtual-host: /
+    password: jieyuu
+    username: admin
+    #开启手动确认消息
+    listener:
+      simple:
+        acknowledge-mode: manual
 
   #数据库配置
   datasource: