From 179c4d64313c9b7572778da4aaaf6c6584fe457d Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期二, 20 五月 2025 23:48:08 +0800 Subject: [PATCH] 修改文件上传类型限制 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java | 25 ++++++++++++++++++++++++- 1 files changed, 24 insertions(+), 1 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java index 0c8cfd1..e512def 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/config/RabbitmqConfig.java @@ -9,7 +9,7 @@ import java.util.HashMap; import java.util.Map; -@Configuration +//@Configuration public class RabbitmqConfig { @@ -44,6 +44,13 @@ public static final String ACID_MESSAGE_QUEUE="huacheng.acid.message.queue"; public static final String ACID_MESSAGE_ROUTING_KEY = "huacheng.acid.message.key"; public static final String ACID_MESSAGE_EXCHANGE = "huacheng.acid.message.exchange"; + + /** + * 服务商城订单 + */ + public static final String SHOP_ORDER_QUEUE="huacheng.shop.order.queue"; + public static final String SHOP_ORDER_ROUTING_KEY = "huacheng.shop.order.key"; + public static final String SHOP_ORDER_EXCHANGE = "huacheng.shop.order.exchange"; @Bean public Queue preOrderQueue(){ @@ -236,5 +243,21 @@ } + @Bean + public Queue shopOrderQueue(){ + return new Queue(SHOP_ORDER_QUEUE,true,false,false,null); + } + + @Bean + public Exchange shopOrderExchange(){ + Map<String, Object> arguments = new HashMap<>(); + arguments.put("x-delayed-type", ExchangeTypes.DIRECT); + return new CustomExchange(SHOP_ORDER_EXCHANGE,"x-delayed-message",true,false,arguments); + } + + @Bean + public Binding shopOrderBinding(){ + return BindingBuilder.bind(shopOrderQueue()).to(shopOrderExchange()).with(SHOP_ORDER_ROUTING_KEY).noargs(); + } } -- Gitblit v1.7.1