From cf1c61f5a79ca452fb658906fe9167dc90882e43 Mon Sep 17 00:00:00 2001 From: quyixiao <2621048238@qq.com> Date: Thu, 23 Oct 2025 23:14:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../heyu/api/data/config/RabbitConfig.java | 4 +-- .../src/main/resources/bootstrap-online.yml | 25 ++++++++++++++++--- 2 files changed, 24 insertions(+), 5 deletions(-) diff --git a/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java b/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java index ab33d62..ced3764 100644 --- a/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java +++ b/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java @@ -74,7 +74,7 @@ public class RabbitConfig { // ---------------------------- 定义exchange --------------------------------- // 定义广播模式的延时交换机 无需绑定路由 - @Bean + //@Bean FanoutExchange delayExchange(@Value("${eb.config.rabbitQueue.delayExchangeName}") String delay_exchange_name) { Map args = new HashMap(); args.put("x-delayed-type", "direct"); @@ -84,7 +84,7 @@ public class RabbitConfig { } // 绑定延时队列与交换机 - @Bean + //@Bean public Binding delayPayBind(@Value("${eb.config.rabbitQueue.delayQueue}") String delay_queue_name, @Value("${eb.config.rabbitQueue.delayExchangeName}") String delay_exchange_name) { return BindingBuilder diff --git a/api-web/api-interface/src/main/resources/bootstrap-online.yml b/api-web/api-interface/src/main/resources/bootstrap-online.yml index e011c01..021929a 100644 --- a/api-web/api-interface/src/main/resources/bootstrap-online.yml +++ b/api-web/api-interface/src/main/resources/bootstrap-online.yml @@ -49,7 +49,26 @@ spring: host: 172.16.5.230 timeout: 5000 rabbitmq: - host: 121.40.41.240 + host: 172.16.5.230 port: 5672 - username: admin - password: XiIg37HKfQg2 \ No newline at end of file + username: user + password: dk_eP^#fkLf30 + listener: + simple: + # 设置手动ack回复 + acknowledge-mode: manual + retry: + # 开启重试机制 + enabled: true + # 重试次数 + max-attempts: 3 + # 重试最大间隔时间 + max-interval: 100000 + # 重试初始间隔时间 + initial-interval: 100 + # 间隔时间因子 + multiplier: 20 + #设置消息发送回调 + publisher-returns: true + publisher-confirm-type: simple + virtual-host: / \ No newline at end of file