Преглед на файлове

feat:添加写入时的限流

zhaohaipeng преди 1 ден
родител
ревизия
397b0f295a
променени са 1 файла, в които са добавени 5 реда и са изтрити 0 реда
  1. 5 0
      recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/RedisService.java

+ 5 - 0
recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/RedisService.java

@@ -49,6 +49,11 @@ public class RedisService implements Serializable {
             if (batch.size() >= 1000) {
                 mSet(jedis, batch, expire, TimeUnit.SECONDS);
                 batch.clear();
+                try {
+                    TimeUnit.MILLISECONDS.sleep(10);
+                } catch (Exception ignore) {
+
+                }
             }
         }
         if (MapUtils.isNotEmpty(batch)) {