fix(rocketmq): 修正ACL配置位置到producer/consumer节点下

rocketmq-spring-boot-starter的access-key/secret-key需配置在
producer和consumer节点下而非rocketmq根节点，同时为所有
@RocketMQMessageListener注解添加accessKey/secretKey属性。

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/BadgeDeviceStatusEventHandler.java

@@ -42,10 +42,14 @@ import java.util.concurrent.TimeUnit;
  */
 @Slf4j
 @Component
-@RocketMQMessageListener(topic = "integration-device-status",
+@RocketMQMessageListener(
+        topic = "integration-device-status",
         consumerGroup = "ops-badge-status-consumer",
         consumeMode = ConsumeMode.CONCURRENTLY,
-        selectorExpression = "*")
+        selectorExpression = "*",
+        accessKey = "${rocketmq.consumer.access-key:}",
+        secretKey = "${rocketmq.consumer.secret-key:}"
+)
 public class BadgeDeviceStatusEventHandler implements RocketMQListener<String> {
 
     /**

viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderArriveEventHandler.java

@@ -58,7 +58,9 @@ import java.util.concurrent.TimeUnit;
         topic = "ops-order-arrive",
         consumerGroup = "ops-clean-order-arrive-group",
         consumeMode = ConsumeMode.CONCURRENTLY,
-        selectorExpression = "*"
+        selectorExpression = "*",
+        accessKey = "${rocketmq.consumer.access-key:}",
+        secretKey = "${rocketmq.consumer.secret-key:}"
 )
 public class CleanOrderArriveEventHandler implements RocketMQListener<String> {
 

viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderAuditEventHandler.java

@@ -37,7 +37,14 @@ import java.util.concurrent.TimeUnit;
  */
 @Slf4j
 @Component
-@RocketMQMessageListener(topic = "ops-order-audit", consumerGroup = "ops-clean-order-audit-group", consumeMode = ConsumeMode.CONCURRENTLY, selectorExpression = "*")
+@RocketMQMessageListener(
+        topic = "ops-order-audit",
+        consumerGroup = "ops-clean-order-audit-group",
+        consumeMode = ConsumeMode.CONCURRENTLY,
+        selectorExpression = "*",
+        accessKey = "${rocketmq.consumer.access-key:}",
+        secretKey = "${rocketmq.consumer.secret-key:}"
+)
 public class CleanOrderAuditEventHandler implements RocketMQListener<String> {
 
     /**

viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCompleteEventHandler.java

@@ -61,7 +61,14 @@ import java.util.concurrent.TimeUnit;
  */
 @Slf4j
 @Component
-@RocketMQMessageListener(topic = "ops-order-complete", consumerGroup = "ops-clean-order-complete-group", consumeMode = ConsumeMode.CONCURRENTLY, selectorExpression = "*")
+@RocketMQMessageListener(
+        topic = "ops-order-complete",
+        consumerGroup = "ops-clean-order-complete-group",
+        consumeMode = ConsumeMode.CONCURRENTLY,
+        selectorExpression = "*",
+        accessKey = "${rocketmq.consumer.access-key:}",
+        secretKey = "${rocketmq.consumer.secret-key:}"
+)
 public class CleanOrderCompleteEventHandler implements RocketMQListener<String> {
 
     /**

viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderConfirmEventHandler.java

@@ -54,7 +54,9 @@ import java.util.concurrent.TimeUnit;
 @RocketMQMessageListener(
         topic = "ops-order-confirm",
         consumerGroup = "ops-clean-order-confirm-group",
-        consumeMode = ConsumeMode.CONCURRENTLY
+        consumeMode = ConsumeMode.CONCURRENTLY,
+        accessKey = "${rocketmq.consumer.access-key:}",
+        secretKey = "${rocketmq.consumer.secret-key:}"
 )
 public class CleanOrderConfirmEventHandler implements RocketMQListener<String> {
 

viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCreateEventHandler.java

@@ -48,7 +48,14 @@ import java.util.concurrent.TimeUnit;
  */
 @Slf4j
 @Component
-@RocketMQMessageListener(topic = "ops-order-create", consumerGroup = "ops-clean-order-create-group", consumeMode = ConsumeMode.CONCURRENTLY, selectorExpression = "*")
+@RocketMQMessageListener(
+        topic = "ops-order-create",
+        consumerGroup = "ops-clean-order-create-group",
+        consumeMode = ConsumeMode.CONCURRENTLY,
+        selectorExpression = "*",
+        accessKey = "${rocketmq.consumer.access-key:}",
+        secretKey = "${rocketmq.consumer.secret-key:}"
+)
 public class CleanOrderCreateEventHandler implements RocketMQListener<String> {
 
     /**

viewsh-module-ops/viewsh-module-ops-server/src/main/resources/application-prod.yaml

@@ -80,9 +80,13 @@ spring:
 # rocketmq 配置项，对应 RocketMQProperties 配置类
 rocketmq:
   name-server: ${ROCKETMQ_NAMESRV_ADDR:rmq-4wd73bxpv.rocketmq.sh.qcloud.tencenttdmq.com:8080} # RocketMQ Namesrv
-  # 腾讯云 TDMQ ACL 认证
-  access-key: ${ROCKETMQ_ACCESS_KEY:}
-  secret-key: ${ROCKETMQ_SECRET_KEY:}
+  producer:
+    group: ${spring.application.name}_PRODUCER
+    access-key: ${ROCKETMQ_ACCESS_KEY:}
+    secret-key: ${ROCKETMQ_SECRET_KEY:}
+  consumer:
+    access-key: ${ROCKETMQ_ACCESS_KEY:}
+    secret-key: ${ROCKETMQ_SECRET_KEY:}
 
 spring:
   # RabbitMQ 配置项，对应 RabbitProperties 配置类