feat:调整同步任务

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

@@ -7,6 +7,7 @@ import com.tzld.piaoquan.recommend.feature.common.util.RedisUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.MapUtils;
 import org.apache.commons.lang3.StringUtils;
+import redis.clients.jedis.DefaultJedisClientConfig;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.Pipeline;
 
@@ -48,7 +49,12 @@ public class RedisService implements Serializable {
     public void mSetV2(Iterator<Map<String, String>> dataIte, DTSConfig config) {
         log.info("mSetV2 param: {}", config);
 
-        Jedis jedis = new Jedis(hostName, port);
+        DefaultJedisClientConfig clientConfig = DefaultJedisClientConfig.builder()
+                .timeoutMillis((int) TimeUnit.SECONDS.toMillis(30))
+                .password(password)
+                .build();
+
+        Jedis jedis = new Jedis(hostName, port, clientConfig);
         jedis.auth(password);
 
         Map<String, String> batch = new HashMap<>();