From 93e38dde45a29facf24a332e5e1b584027c7b8b3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=A4=9C=E7=81=AC=E7=9E=AC?= <2431038086@qq.com> Date: Wed, 21 Jun 2023 21:10:52 +0800 Subject: [PATCH] =?UTF-8?q?=E9=85=8D=E7=BD=AE=20MQ?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .gitignore | 2 +- a-rabbitMQ/placeOrder/pom.xml | 5 ++ .../placeOrder/config/RabbitMQConfig.java | 56 +++++++++++++++++++ .../src/main/resources/application.yml | 8 ++- a-rabbitMQ/pom.xml | 4 -- a-rabbitMQ/说明 | 4 +- tianji-master/.gitignore | 19 ------- tianji-master/tj-common/pom.xml | 1 + .../redisson/annotations/Lock.java | 3 +- tianji-master/tj-course/pom.xml | 1 + 10 files changed, 75 insertions(+), 28 deletions(-) create mode 100644 a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitMQConfig.java delete mode 100644 tianji-master/.gitignore diff --git a/.gitignore b/.gitignore index 549e00a..38083e8 100644 --- a/.gitignore +++ b/.gitignore @@ -1,5 +1,5 @@ HELP.md -target/ +target !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ diff --git a/a-rabbitMQ/placeOrder/pom.xml b/a-rabbitMQ/placeOrder/pom.xml index b18b11f..b87c3e9 100644 --- a/a-rabbitMQ/placeOrder/pom.xml +++ b/a-rabbitMQ/placeOrder/pom.xml @@ -23,5 +23,10 @@ org.springframework.cloud spring-cloud-starter-loadbalancer + + + org.springframework.boot + spring-boot-starter-amqp + \ No newline at end of file diff --git a/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitMQConfig.java b/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitMQConfig.java new file mode 100644 index 0000000..ef801fa --- /dev/null +++ b/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(); + } +} diff --git a/a-rabbitMQ/placeOrder/src/main/resources/application.yml b/a-rabbitMQ/placeOrder/src/main/resources/application.yml index ba41442..cfde772 100644 --- a/a-rabbitMQ/placeOrder/src/main/resources/application.yml +++ b/a-rabbitMQ/placeOrder/src/main/resources/application.yml @@ -6,4 +6,10 @@ spring: cloud: nacos: discovery: - server-addr: 127.0.0.1:8848 \ No newline at end of file + server-addr: 127.0.0.1:8848 + rabbitmq: + host: 192.168.48.128 + port: 5672 + username: admin + password: admin + virtual-host: / \ No newline at end of file diff --git a/a-rabbitMQ/pom.xml b/a-rabbitMQ/pom.xml index 99b3b07..3930cb7 100644 --- a/a-rabbitMQ/pom.xml +++ b/a-rabbitMQ/pom.xml @@ -28,10 +28,6 @@ 2022.0.2 - - - - org.springframework.boot spring-boot-starter-web diff --git a/a-rabbitMQ/说明 b/a-rabbitMQ/说明 index aad86cc..d4b902a 100644 --- a/a-rabbitMQ/说明 +++ b/a-rabbitMQ/说明 @@ -1 +1,3 @@ - RabbitMQ 模拟电商 \ No newline at end of file + RabbitMQ 模拟电商 + 支付 订单 商家 积分 库存 优惠券 + 基本逻辑 \ No newline at end of file diff --git a/tianji-master/.gitignore b/tianji-master/.gitignore deleted file mode 100644 index 00f8976..0000000 --- a/tianji-master/.gitignore +++ /dev/null @@ -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 \ No newline at end of file diff --git a/tianji-master/tj-common/pom.xml b/tianji-master/tj-common/pom.xml index 3dbf7d0..f5ddcc0 100644 --- a/tianji-master/tj-common/pom.xml +++ b/tianji-master/tj-common/pom.xml @@ -81,6 +81,7 @@ io.github.openfeign feign-core + com.xuxueli diff --git a/tianji-master/tj-common/src/main/java/com/tianji/common/autoconfigure/redisson/annotations/Lock.java b/tianji-master/tj-common/src/main/java/com/tianji/common/autoconfigure/redisson/annotations/Lock.java index 1d7ee16..1295c0f 100644 --- a/tianji-master/tj-common/src/main/java/com/tianji/common/autoconfigure/redisson/annotations/Lock.java +++ b/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 *

* 加锁操作, diff --git a/tianji-master/tj-course/pom.xml b/tianji-master/tj-course/pom.xml index 83439bd..38c970e 100644 --- a/tianji-master/tj-course/pom.xml +++ b/tianji-master/tj-course/pom.xml @@ -22,6 +22,7 @@ tj-api 1.0.0 + com.tianji