配置 MQ

.gitignore

@@ -1,5 +1,5 @@
 HELP.md
-target/
+target
 !.mvn/wrapper/maven-wrapper.jar
 !**/src/main/**/target/
 !**/src/test/**/target/

a-rabbitMQ/placeOrder/pom.xml

@@ -23,5 +23,10 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-loadbalancer</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
     </dependencies>
 </project>

a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitMQConfig.java

@@ -0,0 +1,56 @@
+package com.shun.placeOrder.config;
+
+import org.springframework.amqp.core.*;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author 夜灬瞬
+ * @since 2023/6/21 21:08
+ */
+@Configuration
+public class RabbitMQConfig {
+
+    /**
+     * 下单服务的交换机
+     */
+    public static final String PLACE_ORDER_EXCHANGE = "place_order_exchange";
+
+    /**
+     * 三个服务的Queue
+     */
+    public static final String COUPON_QUEUE = "coupon_queue";
+    public static final String USER_POINTS_QUEUE = "user_points_queue";
+    public static final String BUSINESS_QUEUE = "business_queue";
+
+    @Bean
+    public Exchange placeOrderExchange(){
+        return ExchangeBuilder.fanoutExchange(PLACE_ORDER_EXCHANGE).build();
+    }
+
+    @Bean
+    public Queue couponQueue(){
+        return QueueBuilder.durable(COUPON_QUEUE).build();
+    }
+    @Bean
+    public Queue userPointsQueue(){
+        return QueueBuilder.durable(USER_POINTS_QUEUE).build();
+    }
+    @Bean
+    public Queue businessQueue(){
+        return QueueBuilder.durable(BUSINESS_QUEUE).build();
+    }
+
+    @Bean
+    public Binding couponBinding(Exchange placeOrderExchange,Queue couponQueue){
+        return BindingBuilder.bind(couponQueue).to(placeOrderExchange).with("").noargs();
+    }
+    @Bean
+    public Binding userPointsBinding(Exchange placeOrderExchange,Queue userPointsQueue){
+        return BindingBuilder.bind(userPointsQueue).to(placeOrderExchange).with("").noargs();
+    }
+    @Bean
+    public Binding businessBinding(Exchange placeOrderExchange,Queue businessQueue){
+        return BindingBuilder.bind(businessQueue).to(placeOrderExchange).with("").noargs();
+    }
+}

a-rabbitMQ/placeOrder/src/main/resources/application.yml

@@ -7,3 +7,9 @@ spring:
     nacos:
       discovery:
         server-addr: 127.0.0.1:8848
+  rabbitmq:
+    host: 192.168.48.128
+    port: 5672
+    username: admin
+    password: admin
+    virtual-host: /

a-rabbitMQ/pom.xml

@@ -28,10 +28,6 @@
         <spring-cloud.version>2022.0.2</spring-cloud.version>
     </properties>
     <dependencies>
-<!--        <dependency>-->
-<!--            <groupId>org.springframework.boot</groupId>-->
-<!--            <artifactId>spring-boot-starter-amqp</artifactId>-->
-<!--        </dependency>-->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>

a-rabbitMQ/说明

@@ -1 +1,3 @@
  RabbitMQ 模拟电商
+ 支付 订单 商家 积分 库存 优惠券
+ 基本逻辑

tianji-master/.gitignore

@@ -1,19 +0,0 @@
-# Created by .ignore support plugin (hsz.mobi)
-### Example user template template
-### Example user template
-
-# IntelliJ project files
-.idea
-*.iml
-out
-gen
-target
-*.class
-
-*.log
-.settings
-.project
-logs
-job
-
-templates

tianji-master/tj-common/pom.xml

@@ -81,6 +81,7 @@
             <groupId>io.github.openfeign</groupId>
             <artifactId>feign-core</artifactId>
         </dependency>
+
         <!--xxl-job-->
         <dependency>
             <groupId>com.xuxueli</groupId>

tianji-master/tj-common/src/main/java/com/tianji/common/autoconfigure/redisson/annotations/Lock.java

@@ -8,8 +8,7 @@ import java.util.concurrent.TimeUnit;
 
 /**
  * 分布式锁
- *
- * @ClassName Lock
+ * Lock
  * @author wusongsong
  * <p>
  * 加锁操作,

tianji-master/tj-course/pom.xml

@@ -22,6 +22,7 @@
             <artifactId>tj-api</artifactId>
             <version>1.0.0</version>
         </dependency>
+
         <!--auth-->
         <dependency>
             <groupId>com.tianji</groupId>