rocketMQ优化

SLN/%PUBPRJ%-core/src/main/java/%SYS_PKGPATH%/core/util/config/RocketMQConfig.java.ftl

@@ -18,6 +18,22 @@ TARGET=PSSYSTEM
     </#if>
 </#list>
 <#if hasMQProducer || hasMQConsumer>
+    <#comment>服务接口微服务平台配置</#comment>
+    <#assign mqServerAddress="">
+    <#if sys.getAllPSDevSlnMSDepAPIs()??>
+        <#list sys.getAllPSDevSlnMSDepAPIs() as depSysApi>
+            <#if depSysApi.getPSDCMSPlatform()?? >
+                <#if depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")??>
+                    <#assign mqServerAddress = depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")>
+                </#if>
+            </#if>
+        </#list>
+    </#if>
+    <#if mqServerAddress!=''>
+        <#assign mqServer="on">
+    <#else>
+        <#assign mqServer="off">
+    </#if>
 package ${pub.getPKGCodeName()}.core.util.config;
 
 import lombok.extern.slf4j.Slf4j;
@@ -30,9 +46,11 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Lazy;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 
 @Slf4j
 @Configuration
+@ConditionalOnExpression("${r'${ibiz.rocketmq.producer.isOnOff:\''+mqServer+'\'}.equals(\'on\')}'}
 public class RocketMQConfig {
 
     <#if hasMQProducer>

SLN/%PUBPRJ%-core/src/main/java/%SYS_PKGPATH%/core/util/config/RocketMQListenerProcessor.java.ftl

@@ -13,6 +13,22 @@ TARGET=PSSYSTEM
     </#if>
 </#list>
 <#if hasMQConsumer>
+    <#comment>服务接口微服务平台配置</#comment>
+    <#assign mqServerAddress="">
+    <#if sys.getAllPSDevSlnMSDepAPIs()??>
+        <#list sys.getAllPSDevSlnMSDepAPIs() as depSysApi>
+            <#if depSysApi.getPSDCMSPlatform()?? >
+                <#if depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")??>
+                    <#assign mqServerAddress = depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")>
+                </#if>
+            </#if>
+        </#list>
+    </#if>
+    <#if mqServerAddress!=''>
+        <#assign mqServer="on">
+    <#else>
+        <#assign mqServer="off">
+    </#if>
 package ${pub.getPKGCodeName()}.core.util.config;
 
 import lombok.extern.slf4j.Slf4j;
@@ -20,6 +36,7 @@ import com.alibaba.fastjson.JSON;
 import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
 import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
 import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
@@ -32,6 +49,7 @@ import java.util.List;
  */
 @Slf4j
 @Component
+@ConditionalOnExpression("${r'${ibiz.rocketmq.producer.isOnOff:\''+mqServer+'\'}.equals(\'on\')}'}
 public class RocketMQListenerProcessor implements MessageListenerOrderly {
 
     <#list sys.getAllPSDataEntities() as dataEntity>

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/aspect/RocketMQAspect.java.ftl

@@ -13,6 +13,22 @@ TARGET=PSSYSTEM
 </#if>
 </#list>
 <#if hasMQProducer>
+    <#comment>服务接口微服务平台配置</#comment>
+    <#assign mqServerAddress="">
+    <#if sys.getAllPSDevSlnMSDepAPIs()??>
+        <#list sys.getAllPSDevSlnMSDepAPIs() as depSysApi>
+            <#if depSysApi.getPSDCMSPlatform()?? >
+                <#if depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")??>
+                    <#assign mqServerAddress = depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")>
+                </#if>
+            </#if>
+        </#list>
+    </#if>
+    <#if mqServerAddress!=''>
+        <#assign mqServer="on">
+    <#else>
+        <#assign mqServer="off">
+    </#if>
 package ${pub.getPKGCodeName()}.util.aspect;
 
 import lombok.extern.slf4j.Slf4j;
@@ -32,6 +48,7 @@ import org.springframework.expression.Expression;
 import org.springframework.expression.ExpressionParser;
 import org.springframework.expression.spel.standard.SpelExpressionParser;
 import org.springframework.expression.spel.support.StandardEvaluationContext;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
@@ -41,9 +58,10 @@ import java.util.List;
 /**
  * rocketMQ消息切面
  */
+@Slf4j
 @Aspect
 @Component
-@Slf4j
+@ConditionalOnExpression("${r'${ibiz.rocketmq.producer.isOnOff:\''+mqServer+'\'}.equals(\'on\')}'}
 public class RocketMQAspect
 {
     private final ExpressionParser parser = new SpelExpressionParser();