退出增加事件监听

liusuyi

2026-01-21 a14aa010851dfc7d9957cabda474f32a58be6e82

退出增加事件监听

 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"))));
    }

 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);
        }
    }
}