remoce flowpool abtest logic

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/Application.java

@@ -1,6 +1,5 @@
 package com.tzld.piaoquan.recommend.server;
 
-// import com.tzld.piaoquan.recommend.feature.client.FeatureClient;
 
 import com.tzld.piaoquan.abtest.client.ABTestClient;
 import com.tzld.piaoquan.recommend.feature.client.FeatureClient;
@@ -42,21 +41,11 @@ public class Application {
     }
 
 
-    @Bean
-    public FeatureClient featureClient() {
-        return new FeatureClient();
-    }
-
     @Bean
     public FeatureV2Client featureV2Client() {
         return new FeatureV2Client();
     }
 
-    @Bean
-    public ABTestClient abTestClient() {
-        return new ABTestClient();
-    }
-
     @Bean
     public ProtobufHttpMessageConverter protobufHttpMessageConverter() {
         return new ProtobufHttpMessageConverter();

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score/model/FMModel.java

@@ -104,7 +104,7 @@ public class FMModel extends Model {
         String line = null;
         int cnt = 0;
 
-        Integer curTime = new Long(System.currentTimeMillis() / 1000).intValue();
+        long curTime = System.currentTimeMillis() / 1000;
         LOGGER.info("[MODELLOAD] before model load, key size: {}, current time: {}", model.size(), curTime);
         //first stage
         while ((line = input.readLine()) != null) {

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score/model/LRModel.java

@@ -130,7 +130,7 @@ public class LRModel extends Model {
         String line = null;
         int cnt = 0;
 
-        Integer curTime = new Long(System.currentTimeMillis() / 1000).intValue();
+        long curTime = System.currentTimeMillis() / 1000;
         LOGGER.info("[MODELLOAD] before model load, key size: {}, current time: {}", lrModel.size(), curTime);
         //first stage
         while ((line = input.readLine()) != null) {

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/score/model/ModelManager.java

@@ -22,7 +22,7 @@ import java.util.concurrent.TimeUnit;
 public class ModelManager {
     private static final int SCHEDULE_PERIOD = 10;
     private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
-    private static ModelManager instance;
+    private static ModelManager instance = new ModelManager();
     Map<String, ModelLoadTask> loadTasks = new HashMap<>();
     Map<String, String> modelPathMap = new HashMap<>();
     private OSS client;
@@ -65,13 +65,6 @@ public class ModelManager {
     }
 
     public static ModelManager getInstance() {
-        if (instance == null) {
-            synchronized (ModelManager.class) {
-                if (instance == null) {
-                    instance = new ModelManager();
-                }
-            }
-        }
         return instance;
     }