✨ 小优化

Author: disaster1-tesk

fast-mq-core/src/main/java/io/github/fastmq/domain/consumer/instantaneous/FastMQListener.java

@@ -1,14 +1,20 @@
 package io.github.fastmq.domain.consumer.instantaneous;
 
 
-
 /**
  * The interface Fast mq listener.
  *
+ * @param <T> the type parameter
  * @author disaster
  * @version 1.0
  */
 public interface FastMQListener<T> {
 
+    /**
+     * On message.
+     *
+     * @param t the t
+     * @throws Throwable the throwable
+     */
     void onMessage(T t) throws Throwable;
 }

fast-mq-core/src/main/java/io/github/fastmq/domain/producer/delay/FastMQDelayTemplate.java

@@ -2,10 +2,34 @@
 
 import java.util.concurrent.TimeUnit;
 
+/**
+ * The interface Fast mq delay template.
+ */
 public interface FastMQDelayTemplate {
+    /**
+     * Send msg.
+     *
+     * @param data       the data
+     * @param delayTime  the delay time
+     * @param delayQueue the delay queue
+     * @param timeUnit   the time unit
+     */
     void sendMsg(Object data, long delayTime, String delayQueue, TimeUnit timeUnit);
 
+    /**
+     * Send msg.
+     *
+     * @param data      the data
+     * @param delayTime the delay time
+     * @param timeUnit  the time unit
+     */
     void sendMsg(Object data, long delayTime, TimeUnit timeUnit);
 
+    /**
+     * Send msg.
+     *
+     * @param data      the data
+     * @param delayTime the delay time
+     */
     void sendMsg(Object data, long delayTime);
 }

fast-mq-core/src/main/java/io/github/fastmq/domain/producer/instantaneous/FastMQTemplate.java

@@ -4,12 +4,41 @@
 import org.springframework.lang.NonNull;
 import java.util.Map;
 
+/**
+ * The interface Fast mq template.
+ */
 public interface FastMQTemplate {
+    /**
+     * Send msg async.
+     *
+     * @param topic the topic
+     * @param msg   the msg
+     */
     void sendMsgAsync(@NonNull String topic, Map<String, Object> msg);
 
+    /**
+     * Send msg async.
+     *
+     * @param id    the id
+     * @param topic the topic
+     * @param msg   the msg
+     */
     void sendMsgAsync(@NonNull Long id, @NonNull String topic, Map<String, Object> msg);
 
+    /**
+     * Send msg async.
+     *
+     * @param topic the topic
+     * @param msg   the msg
+     */
     void sendMsgAsync(@NonNull String topic, Object msg);
 
+    /**
+     * Send msg async.
+     *
+     * @param id    the id
+     * @param topic the topic
+     * @param msg   the msg
+     */
     void sendMsgAsync(@NonNull Long id, @NonNull String topic, Object msg);
 }

fast-mq-core/src/main/java/io/github/fastmq/domain/share/MQCenter.java

@@ -57,30 +57,37 @@ public class MQCenter implements ApplicationRunner, ApplicationContextAware, Dis
      */
     private Set<FastMQDelayListener> fastMQListeners2;
 
-
     /**
      * redissonClient对象
      */
-    @Autowired
-    private RedissonClient client;
+    private final RedissonClient client;
 
     /**
      * fastmq配置属性
      */
-    @Autowired
-    private FastMQProperties fastMQProperties;
+    private final FastMQProperties fastMQProperties;
 
     /**
      * 领域服务对象-异步
      */
-    @Autowired
-    private FastMQAsyncService fastMQAsyncService;
+    private final FastMQAsyncService fastMQAsyncService;
 
     /**
      * 领域服务对象-同步
      */
+    private final FastMQService fastMQService;
+
+
     @Autowired
-    private FastMQService fastMQService;
+    public MQCenter(RedissonClient client, FastMQProperties fastMQProperties, FastMQAsyncService fastMQAsyncService, FastMQService fastMQService) {
+        this.client = client;
+        this.fastMQProperties = fastMQProperties;
+        this.fastMQAsyncService = fastMQAsyncService;
+        this.fastMQService = fastMQService;
+        fastMQListeners0 = new HashSet<>();
+        fastMQListeners1 = new HashSet<>();
+        fastMQListeners2 = new HashSet<>();
+    }
 
     /**
      * spring上下文对象，用于获取fastmq的bean实例
@@ -111,15 +118,6 @@ public class MQCenter implements ApplicationRunner, ApplicationContextAware, Dis
         luaStr = sb.toString();
     }
 
-    /**
-     * Instantiates a new Mq center.
-     */
-    public MQCenter() {
-        fastMQListeners0 = new HashSet<>();
-        fastMQListeners1 = new HashSet<>();
-        fastMQListeners2 = new HashSet<>();
-    }
-
 
     private void initThreadPool() {
         service = Executors.newScheduledThreadPool(

fast-mq-core/src/main/java/io/github/fastmq/infrastructure/utils/BeanMapUtils.java

@@ -17,7 +17,7 @@
 import java.util.*;
 
 /**
- * Bean和Map类型转换工具类,参考自Barry
+ * Bean和Map类型转换工具类
  *
  * @author disaster
  * @version 1.0
@@ -48,6 +48,13 @@ public static final Object toBean(Class<?> type, Map<Object, ? extends Object> m
         return isEquals(parse0, parse1) ? BeanUtil.mapToBean(map, aClass, true, CopyOptions.create()) : null;
     }
 
+    /**
+     * To bean object.
+     *
+     * @param type the type
+     * @param msg  the msg
+     * @return the object
+     */
     @SneakyThrows
     public static final Object toBean(Class<?> type, String msg) {
         Type generic = getType(type, FastMQDelayListenerInfo);
@@ -59,13 +66,27 @@ public static final Object toBean(Class<?> type, String msg) {
     }
 
 
+    /**
+     * Is equals boolean.
+     *
+     * @param source the source
+     * @param target the target
+     * @return the boolean
+     */
     public static Boolean isEquals(Object source, Object target) {
         Class<?> aClass0 = source.getClass();
         Class<?> aClass1 = target.getClass();
         return aClass0.equals(aClass1);
     }
 
 
+    /**
+     * Gets type.
+     *
+     * @param type     the type
+     * @param typeName the type name
+     * @return the type
+     */
     public static Type getType(Class<?> type, String typeName) {
         Type[] genericInterfaces = type.getGenericInterfaces();
         Type generic = null;

fast-mq-core/src/main/java/io/github/fastmq/infrastructure/utils/SystemClock.java

@@ -8,7 +8,7 @@
 
 /**
  * <p>
- * 高并发场景下System.currentTimeMillis()的性能问题的优化
+ * 高并发场景下System.currentTimeMillis()的性能问题的优化、redis中的LRU链表中的时间戳就是通过这种方式去实现（很高效也很有用）
  * </p>
  * <p>
  * System.currentTimeMillis()的调用比new一个普通对象要耗时的多<br>

fast-mq-core/src/main/resources/application.yml

@@ -31,7 +31,7 @@ fastmq:
     executor:
       #拉取默认主题信息的周期
       pullDefaultTopicMessagesPeriod: 10
-      #检查PendingList周期
+      #拉取自定义主题信息的周期
       pullTopicMessagesPeriod: 1
       time-unit: seconds
       #第一次延迟执行的时间