From 8cb6142d88d979369c5379d8293579fe825979a1 Mon Sep 17 00:00:00 2001 From: yanshikui Date: Wed, 15 Jan 2025 16:37:13 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E6=B7=BB=E5=8A=A0rabbitmq=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=EF=BC=88=E6=98=AF=E5=90=A6=E5=90=AF=E7=94=A8RabbitMQ?= =?UTF-8?q?=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ktg-admin/src/main/resources/application.yml | 7 ++++--- .../main/java/com/ktg/mes/rabbitmq/DirectQueueHandler.java | 2 ++ 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/ktg-admin/src/main/resources/application.yml b/ktg-admin/src/main/resources/application.yml index 50848e4..b7b5420 100644 --- a/ktg-admin/src/main/resources/application.yml +++ b/ktg-admin/src/main/resources/application.yml @@ -43,7 +43,8 @@ logging: # Spring配置 spring: rabbitmq: - host: 192.168.1.194 # RabbitMQ 服务的地址 + enabled: false # 是否启用RabbitMQ + host: localhost # RabbitMQ 服务的地址 port: 5672 # RabbitMQ 服务的端口 username: mes # RabbitMQ 服务的账号 password: mes # RabbitMQ 服务的密码 @@ -71,13 +72,13 @@ spring: # redis 配置 redis: # 地址 - host: 192.168.1.254 + host: localhost # 端口,默认为6379 port: 6379 # 数据库索引 database: 0 # 密码 - password: + password: 123456 # 连接超时时间 timeout: 10s lettuce: diff --git a/ktg-mes/src/main/java/com/ktg/mes/rabbitmq/DirectQueueHandler.java b/ktg-mes/src/main/java/com/ktg/mes/rabbitmq/DirectQueueHandler.java index bdb6972..852d2f6 100644 --- a/ktg-mes/src/main/java/com/ktg/mes/rabbitmq/DirectQueueHandler.java +++ b/ktg-mes/src/main/java/com/ktg/mes/rabbitmq/DirectQueueHandler.java @@ -3,6 +3,7 @@ package com.ktg.mes.rabbitmq; import com.ktg.mes.websocket.MesWebSocket; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.stereotype.Component; /** @@ -12,6 +13,7 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component +@ConditionalOnProperty(prefix = "spring.rabbitmq", name = "enabled", havingValue = "true") public class DirectQueueHandler { @RabbitListener(queues = "iot.original.mes")