删除日志

mall-search/src/main/java/com/uas/search/jms/JmsListener.java

@@ -180,7 +180,7 @@ public class JmsListener {
 
                 if (!CollectionUtils.isEmpty(updateMessage)) {
                     failedIds = process(updateMessage);
-                    logger.info("update索引" + updateMessage.size() + "条,失败" + failedIds.size() + "耗时" + (System.currentTimeMillis() - indexTime));
+                    logger.info("update索引" + updateMessage.size() + "条,失败" + failedIds.size() + "耗时：" + (System.currentTimeMillis() - indexTime));
                 }
 
                 if (!CollectionUtils.isEmpty(deleteMessage)) {
@@ -191,7 +191,7 @@ public class JmsListener {
                 if (!CollectionUtils.isEmpty(failedIds)) {
                     long retryTime = System.currentTimeMillis();
                     luceneMessageDao.updateReTryCount(failedIds);
-                    logger.info("处理失败：update retrycount" + failedIds.size() + "条，耗时" + (System.currentTimeMillis() - retryTime));
+                    logger.info("处理失败：" + failedIds.size() + "条，update retrycount耗时" + (System.currentTimeMillis() - retryTime));
                 }
 
                 logger.info("处理luceneMessages" + luceneMessages.size() + "条,耗时：" + (System.currentTimeMillis() - startTime));
@@ -246,14 +246,13 @@ public class JmsListener {
      * @param luceneMessages 消息
      */
     private List<Long> process(List<LuceneMessage> luceneMessages) {
-        long startTime = System.currentTimeMillis();
         List<Long> successIds = new ArrayList<>();
         List<Long> failedIds = new ArrayList<>();
         for (LuceneMessage luceneMessage : luceneMessages) {
             try {
                 ParsedQueueMessage parsedQueueMessage = queueMessageParser.parse(luceneMessage.getTableName(), luceneMessage.getDataId(), luceneMessage.getMethodType(), luceneMessage.getData());
                 List<Object> maintainedObjects = indexService.maintainIndexes(parsedQueueMessage);
-                logger.info("单条耗时" + (System.currentTimeMillis() - startTime) + ",Maintained... " + maintainedObjects);
+                logger.info("Maintained... " + maintainedObjects);
                 successIds.add(luceneMessage.getId());
             } catch (Exception e) {
                 failedIds.add(luceneMessage.getId());

mall-search/src/main/java/com/uas/search/jms/LuceneMessageDao.java

@@ -38,7 +38,7 @@ public interface LuceneMessageDao
      * @param tableNames 表名
      * @return 数据
      */
-    @Query(value = "select * from lucene$message where me_retry_count < 10 and me_table_name in :tableNames order by me_priority desc, me_id limit :start, :size", nativeQuery = true)
+    @Query(value = "select * from lucene$message where me_retry_count < 5 and me_table_name in :tableNames order by me_priority desc, me_id limit :start, :size", nativeQuery = true)
     List<LuceneMessage> findListByTableNames(@Param("start") Integer start, @Param("size") Integer size, @Param("tableNames") String[] tableNames);
 
     /**