@Async注解实现延时发送

周峰
1 parent a3c7c285
Showing 1 changed file with 16 additions and 8 deletions
src/main/java/com/huaheng/pc/stompwebsocket/service/StompWebSocketServiceImpl.java
@@ -76,21 +76,29 @@ public class StompWebSocketServiceImpl extends ServiceImpl&lt;StompMessageMapper, S
         messaging.convertAndSendToUser(user, topic, payload.getData(), headers);
     }
-    public void confirmMsg(String msg_id){
+    public void confirmMsg(String msg_id) {
         removeById(msg_id);
     }
     /**
      * 将离线后的消息发送给用户
+     *
      * @param user
      */
-    public void sendOfflineMessageToUser(String user){
-        LambdaQueryWrapper<StompMessage> queryWrapper = Wrappers.lambdaQuery();
-        queryWrapper.eq(StompMessage::getUser, user);
-        List<StompMessage> msgList = list(queryWrapper);
-        for(StompMessage msg : msgList){
-            messaging.convertAndSendToUser(user, msg.getTopic(), msg.getMsg());
-            removeById(msg.getId());
+    @Async
+    public void sendOfflineMessageToUser(String user) {
+        try {
+            Thread.sleep(2000);
+            LambdaQueryWrapper<StompMessage> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.eq(StompMessage::getUser, user);
+            List<StompMessage> msgList = list(queryWrapper);
+            for (StompMessage msg : msgList) {
+                messaging.convertAndSendToUser(user, msg.getTopic(), msg.getMsg());
+                removeById(msg.getId());
+            }
+        } catch (Exception e) {
+            System.out.println("===========================================================【end】===\n\n\n");
+            System.out.println(" ======>  e.getMessage() = " + e.getMessage());
         }
     }
 }