mes/mes-lqqt
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:添加rabbitmq配置（是否启用RabbitMQ）

Browse Source
This commit is contained in:
yanshikui 2025-01-15 16:37:13 +08:00
parent 1936ede088
commit 8cb6142d88
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ktg-admin/src/main/resources/application.yml
View File

@ -43,7 +43,8 @@ logging:
# Spring配置 # Spring配置
spring: spring:
rabbitmq: rabbitmq:
host: 192.168.1.194 # RabbitMQ 服务的地址 enabled: false # 是否启用RabbitMQ
host: localhost # RabbitMQ 服务的地址
port: 5672 # RabbitMQ 服务的端口 port: 5672 # RabbitMQ 服务的端口
username: mes # RabbitMQ 服务的账号 username: mes # RabbitMQ 服务的账号
password: mes # RabbitMQ 服务的密码 password: mes # RabbitMQ 服务的密码
@ -71,13 +72,13 @@ spring:
# redis 配置 # redis 配置
redis: redis:
# 地址 # 地址
host: 192.168.1.254 host: localhost
# 端口，默认为6379 # 端口，默认为6379
port: 6379 port: 6379
# 数据库索引 # 数据库索引
database: 0 database: 0
# 密码 # 密码
password: password: 123456
# 连接超时时间 # 连接超时时间
timeout: 10s timeout: 10s
lettuce: lettuce:

2
ktg-mes/src/main/java/com/ktg/mes/rabbitmq/DirectQueueHandler.java
View File

@ -3,6 +3,7 @@ package com.ktg.mes.rabbitmq;
import com.ktg.mes.websocket.MesWebSocket; import com.ktg.mes.websocket.MesWebSocket;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
@ -12,6 +13,7 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
@ConditionalOnProperty(prefix = "spring.rabbitmq", name = "enabled", havingValue = "true")
public class DirectQueueHandler { public class DirectQueueHandler {
@RabbitListener(queues = "iot.original.mes") @RabbitListener(queues = "iot.original.mes")