feat:调整同步任务

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

@@ -17,8 +17,8 @@ import java.util.Iterator;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
-import static com.tzld.piaoquan.recommend.feature.common.enums.Env.PROD_DISK;
 import static com.tzld.piaoquan.recommend.feature.common.enums.Env.PROD;
+import static com.tzld.piaoquan.recommend.feature.common.enums.Env.PROD_DISK;
 
 /**
  * https://help.aliyun.com/zh/maxcompute/user-guide/java-sdk-1/?spm=a2c4g.11174283.0.0.6d0111c1E15lI3
@@ -30,7 +30,6 @@ public class RedisService implements Serializable {
     private int port = 6379;
     private String password = "";
     private String hostName = "";
-    private Jedis jedis;
 
     public RedisService(String env) {
         if (StringUtils.equals(env, PROD.getEnv())) {
@@ -38,18 +37,20 @@ public class RedisService implements Serializable {
             hostName = "r-bp1pi8wyv6lzvgjy5z.redis.rds.aliyuncs.com";
         } else if (StringUtils.equals(env, PROD_DISK.getEnv())) {
             password = "Wqsd@2019";
-            hostName = "r-bp1r5em55k87e2xb1k.tairpdb.rds.aliyuncs.com";
+            hostName = "r-bp1t8fqdubofxntci5.redis.rds.aliyuncs.com";
         } else {
             password = "Wqsd@2019";
             hostName = "r-bp1wwqqkjqwwkxgbup.redis.rds.aliyuncs.com";
         }
 
-        this.jedis = new Jedis(hostName, port);
-        jedis.auth(password);
     }
 
     public void mSetV2(Iterator<Map<String, String>> dataIte, DTSConfig config) {
         log.info("mSetV2 param: {}", config);
+
+        Jedis jedis = new Jedis(hostName, port);
+        jedis.auth(password);
+
         Map<String, String> batch = new HashMap<>();
         long expire = config.getRedis().getExpire();
         while (dataIte.hasNext()) {