添加用户注销事件

src/main/java/cn/meteor/beyondclouds/core/queue/message/UserActionMessage.java

@@ -35,4 +35,13 @@ public class UserActionMessage {
     public static UserActionMessage loginMessage(String userId) {
         return new UserActionMessage(userId, UserAction.LOGIN);
     }
+
+    /**
+     * 用户注销消息
+     * @param userId
+     * @return
+     */
+    public static UserActionMessage logoutMessage(String userId) {
+        return new UserActionMessage(userId, UserAction.LOGOUT);
+    }
 }

src/main/java/cn/meteor/beyondclouds/modules/user/listener/UserLoginAndLogoutListener.java

@@ -81,5 +81,6 @@ public class UserLoginAndLogoutListener implements UserActionListener {
         // 将用户的关注列表和粉丝列表从redis删除
         redisHelper.del(RedisKey.USER_FOLLOWED(userId));
         redisHelper.del(RedisKey.USER_FANS(userId));
+        log.debug("检测到用户注销事件：{}", userId);
     }
 }

src/main/java/cn/meteor/beyondclouds/modules/user/service/impl/UserServiceImpl.java

@@ -7,6 +7,7 @@ import cn.meteor.beyondclouds.common.helper.IOssHelper;
 import cn.meteor.beyondclouds.common.helper.IRedisHelper;
 import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
 import cn.meteor.beyondclouds.core.queue.message.DataItemType;
+import cn.meteor.beyondclouds.core.queue.message.UserActionMessage;
 import cn.meteor.beyondclouds.core.redis.RedisKey;
 import cn.meteor.beyondclouds.core.redis.TokenManager;
 import cn.meteor.beyondclouds.modules.mail.dto.EmailDTO;
@@ -628,6 +629,7 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
         if (SubjectUtils.isAuthenticated()) {
             String userId = (String) SubjectUtils.getSubject().getId();
             tokenManager.removeToken(userId);
+            messageQueueService.sendUserActionMessage(UserActionMessage.logoutMessage(userId));
         }
     }