zhouweidong 发布系统代码 [ibiz-uaa，UAA鉴权]

ibzuaa-boot/src/main/resources/logback-spring.xml

@@ -20,18 +20,17 @@
     <appender name="file"  class="ch.qos.logback.core.rolling.RollingFileAppender">
         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
             <!--日志文件输出的文件名-->
-            <FileNamePattern>${LOG_PATH}/ibzuaa.%d{yyyy-MM-dd}.log</FileNamePattern>
+            <FileNamePattern>${LOG_PATH}/ibzuaa.%d{yyyy-MM-dd}.%i.log</FileNamePattern>
+            <!--日志文件最大的大小-->
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>100MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
             <!--日志文件保留天数-->
             <MaxHistory>30</MaxHistory>
         </rollingPolicy>
         <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
             <pattern>${LOG_PATTERN}</pattern>
         </encoder>
-
-        <!--日志文件最大的大小-->
-        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
-            <MaxFileSize>100MB</MaxFileSize>
-        </triggeringPolicy>
     </appender>
     <!-- 日志输出级别 -->
     <root level="INFO">

ibzuaa-core/src/main/java/cn/ibizlab/core/util/config/RocketMQConsumer.java

+package cn.ibizlab.core.util.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.client.exception.MQClientException;
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
+import org.springframework.beans.factory.annotation.Autowired;
+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("${rocketmq.isOnOff:'off'}.equals('on')")
+public class RocketMQConsumer {
+
+    @Value("${rocketmq.producer.groupName:default}")
+    private String groupName;
+
+    @Value("${rocketmq.producer.namesrvAddr:127.0.0.1:9876}")
+    private String namesrvAddr;
+
+    // 消费者线程数据量
+    @Value("${rocketmq.consumer.consumeThreadMin:1}")
+    private Integer consumeThreadMin;
+
+    @Value("${rocketmq.consumer.consumeThreadMax:1}")
+    private Integer consumeThreadMax;
+
+    @Value("${rocketmq.consumer.consumeMessageBatchMaxSize:1}")
+    private Integer consumeMessageBatchMaxSize;
+
+    @Value("${rocketmq.topic:default}")
+    private String topic;
+
+    @Autowired
+    @Lazy
+    private RocketMQListenerProcessor listenerProcessor;
+
+    /**
+     * mq 消费者配置
+     *
+     * @return
+     * @throws MQClientException
+     */
+    @Bean
+    public DefaultMQPushConsumer defaultConsumer() {
+        log.info("defaultConsumer 正在创建---------------------------------------");
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(groupName);
+        consumer.setNamesrvAddr(namesrvAddr);
+        consumer.setConsumeThreadMin(consumeThreadMin);
+        consumer.setConsumeThreadMax(consumeThreadMax);
+        consumer.setConsumeMessageBatchMaxSize(consumeMessageBatchMaxSize);
+        // 设置监听
+        consumer.registerMessageListener(listenerProcessor);
+        /**
+         * 设置consumer第一次启动是从队列头部开始还是队列尾部开始
+         * 如果不是第一次启动，那么按照上次消费的位置继续消费
+         */
+        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
+        /**
+         * 设置消费模型，集群还是广播，默认为集群
+         */
+//        consumer.setMessageModel(MessageModel.CLUSTERING);
+        try {
+            consumer.subscribe(topic, "deletesysuser || savesysuser");
+            consumer.start();
+            log.info("rocketmq consumer 创建成功 groupName={}, topics={}, namesrvAddr={}", groupName, topic, namesrvAddr);
+        } catch (MQClientException e) {
+            log.error("rocketmq consumer 创建失败!" + e);
+        }
+        return consumer;
+    }
+}
+

ibzuaa-core/src/main/java/cn/ibizlab/core/util/config/RocketMQListenerProcessor.java

@@ -18,7 +18,7 @@ import java.util.List;
  */
 @Slf4j
 @Component
-@ConditionalOnExpression("${ibiz.rocketmq.producer.isOnOff:'off'}.equals('on')")
+@ConditionalOnExpression("${rocketmq.producer.isOnOff:'off'}.equals('on')")
 public class RocketMQListenerProcessor implements MessageListenerOrderly {
 
     @Autowired