From a14aa010851dfc7d9957cabda474f32a58be6e82 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Wed, 21 Jan 2026 13:20:50 +0800
Subject: [PATCH] 退出增加事件监听
---
ard-framework/src/main/java/com/ard/framework/security/handle/LogoutSuccessHandlerImpl.java | 10 +++++++++-
ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java | 30 +++++++++++++++++++++++++-----
2 files changed, 34 insertions(+), 6 deletions(-)
diff --git a/ard-framework/src/main/java/com/ard/framework/security/handle/LogoutSuccessHandlerImpl.java b/ard-framework/src/main/java/com/ard/framework/security/handle/LogoutSuccessHandlerImpl.java
index 6b304be..68ed32e 100644
--- a/ard-framework/src/main/java/com/ard/framework/security/handle/LogoutSuccessHandlerImpl.java
+++ b/ard-framework/src/main/java/com/ard/framework/security/handle/LogoutSuccessHandlerImpl.java
@@ -5,7 +5,10 @@
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.annotation.Configuration;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.authentication.event.LogoutSuccessEvent;
import org.springframework.security.core.Authentication;
import org.springframework.security.web.authentication.logout.LogoutSuccessHandler;
import com.alibaba.fastjson2.JSON;
@@ -29,7 +32,8 @@
{
@Autowired
private TokenService tokenService;
-
+ @Autowired
+ private ApplicationEventPublisher publisher;
/**
* 退出处理
*
@@ -47,6 +51,10 @@
tokenService.delLoginUser(loginUser.getToken(), loginUser.getUser().getUserId());
// 记录用户退出日志
AsyncManager.me().execute(AsyncFactory.recordLogininfor(userName, Constants.LOGOUT, MessageUtils.message("user.logout.success")));
+ // ✅ 手动发布注销事件
+ // 构造一个 Authentication
+ Authentication auth = new UsernamePasswordAuthenticationToken(loginUser, null, loginUser.getAuthorities());
+ publisher.publishEvent(new LogoutSuccessEvent(auth));
}
ServletUtils.renderString(response, JSON.toJSONString(AjaxResult.success(MessageUtils.message("user.logout.success"))));
}
diff --git a/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java b/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java
index f144994..62f3855 100644
--- a/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java
+++ b/ard-vtdu/src/main/java/com/ard/vtdu/service/impl/ArdVtduServiceImpl.java
@@ -13,6 +13,8 @@
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.security.authentication.event.AuthenticationSuccessEvent;
import com.ard.common.core.domain.model.LoginUser;
+import org.springframework.security.authentication.event.LogoutSuccessEvent;
+import org.springframework.security.core.Authentication;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
@@ -140,6 +142,9 @@
public void clearAllArdVtdu() {
ardVtduMapper.clearAllArdVtdu();
}
+
+
+
//需要更新的（流媒体和vtdu相同）
@Override
@@ -270,16 +275,31 @@
if (principal instanceof LoginUser) {
LoginUser loginUser = (LoginUser) principal; // 传统强制类型转换
Long userId = loginUser.getUser().getUserId();
- String username = loginUser.getUsername();
+ String name="user_" + userId;
+ // 1️⃣ 判断数据库是否已存在
+ ArdVtdu existing = ardVtduMapper.selectArdVtduByName(name);
+ if (existing != null) {
+ log.info("流媒体【{}】已存在，跳过插入", name);
+ return;
+ }
ArdVtdu ardVtdu = ArdVtdu.builder()
- .name("user_" + userId) // 用 userId 作为流名称
+ .name(name) // 用 userId 作为流名称
.rtspSource("publisher") // 或 "publisher"，按业务区分
.build();
// 本地库插入
insertArdVtdu(ardVtdu);
- log.info("用户【{}】登录，立即加入流媒体", username);
- } else {
- log.warn("登录事件 principal 不是 LoginUser，无法获取 userId");
+ log.info("用户【{}】登录，立即加入流媒体", name);
+ }
+ }
+ @EventListener
+ public void handleLogout(LogoutSuccessEvent event) {
+ Object principal = event.getAuthentication().getPrincipal();
+ if (principal instanceof LoginUser) {
+ LoginUser loginUser = (LoginUser) principal; // 传统强制类型转换
+ Long userId = loginUser.getUser().getUserId();
+ String name="user_" + userId;
+ deleteArdVtduByName(name);
+ log.info("用户【{}】注销，立即移除流媒体", name);
}
}
}
--
Gitblit v1.9.3