tags

src/main/java/com/smcic/api/tags/job/UserTagsConsumer.java

@@ -36,6 +36,7 @@ public class UserTagsConsumer {
     public void run(){
 
         System.out.println("启动队列消费");
+        RestTemplate restTemplate = new RestTemplate();
         ConcurrentLinkedDeque<UserTagsDTO> userTagsQueue = TagsQueue.getInstance().getUserTags();
         long time = System.currentTimeMillis();
         int count = 0;
@@ -82,12 +83,16 @@ public class UserTagsConsumer {
                     userTagsList.clear();
                     count = 0;
                     time = curr;
+
                     this.threadPoolExecutor.execute(() -> {
-                        RestTemplate restTemplate = new RestTemplate();
-                        recommend.setTableContent(tableContent);
-                        ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver.sxtvs.net/user/qmtssp", recommend, Object.class);
-                        log.info("发送数据{}, 推荐系统响应{}", recommend, mapResponseEntity.getBody());
-                        tableContent.clear();
+                        try {
+                            recommend.setTableContent(tableContent);
+                            ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver.sxtvs.net/user/qmtssp", recommend, Object.class);
+                            log.info("发送数据{}, 推荐系统响应{}", recommend, mapResponseEntity.getBody());
+                            tableContent.clear();
+                        }catch (Exception e){
+                            log.info("推荐系统异常", e);
+                        }
                     });
 
                 }