当前位置：首页 > news >正文

实时在线状态

news 来源：原创 2025/7/13 6:57:41

以下是一个完整的 OnlineUsers 类实现，包含线程安全的在线用户管理功能：

import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors;/*** 在线用户管理器（线程安全）* 功能：* 1. 用户登录/下线状态管理* 2. 重复登录强制下线* 3. 在线用户查询* 4. 实时消息推送支持*/
public class OnlineUsers {// 存储 <用户ID, 客户端连接处理器>private static final ConcurrentHashMap<Long, ClientHandler> onlineUsers = new ConcurrentHashMap<>();// 防止实例化private OnlineUsers() {}/*** 添加在线用户（如果已登录会强制下线旧连接）* @param userId 用户ID* @param handler 客户端处理器*/public static void addUser(Long userId, ClientHandler handler) {synchronized (onlineUsers) {// 处理重复登录ClientHandler existingHandler = onlineUsers.get(userId);if (existingHandler != null) {forceDisconnect(existingHandler);}onlineUsers.put(userId, handler);}}/*** 移除在线用户* @param userId 用户ID*/public static void removeUser(Long userId) {onlineUsers.remove(userId);}/*** 检查用户是否在线* @param userId 用户ID* @return 是否在线*/public static boolean isUserOnline(Long userId) {return onlineUsers.containsKey(userId);}/*** 获取在线用户ID列表* @return 不可修改的ID集合*/public static Set<Long> getOnlineUserIds() {return Collections.unmodifiableSet(onlineUsers.keySet());}/*** 获取在线用户详细信息列表* @return 用户信息列表（按登录时间排序）*/public static List<User> getOnlineUsers() {return onlineUsers.values().stream().filter(handler -> handler.getUser() != null).map(ClientHandler::getUser).sorted(Comparator.comparing(User::getLoginTime)).collect(Collectors.toList());}/*** 获取用户连接处理器* @param userId 用户ID* @return 处理器实例（可能为null）*/public static ClientHandler getHandler(Long userId) {return onlineUsers.get(userId);}/*** 获取当前在线人数* @return 在线用户数量*/public static int getOnlineCount() {return onlineUsers.size();}/*** 强制下线用户* @param userId 用户ID*/public static void forceDisconnect(Long userId) {ClientHandler handler = onlineUsers.get(userId);if (handler != null) {forceDisconnect(handler);removeUser(userId);}}// 内部断开连接方法private static void forceDisconnect(ClientHandler handler) {try {handler.forceDisconnect();System.out.println("强制断开用户连接: " + handler.getUser().getId());} catch (Exception e) {System.err.println("强制断开连接失败: " + e.getMessage());}}/*** 清除所有在线用户（测试用）*/static void clearAll() {onlineUsers.values().forEach(OnlineUsers::forceDisconnect);onlineUsers.clear();}
}

需要配合的 ClientHandler 部分修改：

public class ClientHandler implements Runnable {private User loggedInUser;// 获取关联的用户信息public User getUser() {return loggedInUser;}// 强制断开连接public void forceDisconnect() {try {if (!clientsocket.isClosed()) {clientsocket.close();}} catch (IOException e) {System.err.println("强制断开连接异常: " + e.getMessage());}}// 在登录成功后调用private void handleSuccessfulLogin(User user) {this.loggedInUser = user;OnlineUsers.addUser(user.getId(), this);}
}

User 类需要扩展的字段：

public class User {private Long id;private String username;private Date loginTime; // 登录时间// Getters/Setters...
}

主要功能说明

方法	功能说明
`addUser()`	添加在线用户，自动处理重复登录
`removeUser()`	移除指定在线用户
`isUserOnline()`	检查指定用户是否在线
`getOnlineUserIds()`	获取所有在线用户ID（不可修改集合）
`getOnlineUsers()`	获取详细在线用户列表（按登录时间排序）
`getHandler()`	获取用户连接处理器（用于消息推送）
`getOnlineCount()`	获取当前在线人数
`forceDisconnect()`	强制断开指定用户连接
`clearAll()`	清空所有在线用户（测试用）

使用示例

// 用户登录成功
User user = new User(123L, "张三");
ClientHandler handler = new ClientHandler(socket);
OnlineUsers.addUser(user.getId(), handler);// 检查用户状态
boolean isOnline = OnlineUsers.isUserOnline(123L);// 发送实时消息
ClientHandler targetHandler = OnlineUsers.getHandler(456L);
if (targetHandler != null) {targetHandler.sendMessage(new ChatMessage(...));
}// 获取在线用户统计
System.out.println("当前在线人数: " + OnlineUsers.getOnlineCount());

设计特点

线程安全：使用 **ConcurrentHashMap** 和同步块保证线程安全
自动清理：连接断开时自动移除用户（需在 **ClientHandler** 的 finally 块调用 **removeUser()**）
强制下线：处理重复登录时自动断开旧连接
可扩展性：支持按需获取用户ID列表或详细用户信息
状态跟踪：记录用户登录时间用于排序和分析

建议配合心跳检测机制（如每30秒检测一次连接活性）来维护在线状态的准确性。

实时在线状态

以下是一个完整的 OnlineUsers 类实现，包含线程安全的在线用户管理功能： import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors;/*** 在线用户管理器（线程安全）* 功能&#…...

编程日记 2025/7/13 6:57:41

《算法导论(第4版)》阅读笔记：p6-p6

《算法导论(第4版)》学习第 4 天，p6-p6 总结，总计 1 页。一、技术总结无。二、英语总结(生词：1) 1. disposal (1)dispose: dis-(“aprt”) ponere(“to put, place”) vt. dispose literally means “to put apart(to separate sth…...

编程日记 2025/7/13 6:41:51

录播课制作技术指南

1.技术版本选择策略优先采用长期支持版本作为课程开发基础，此类版本在企业级应用中普及度高且稳定性强。技术选型直接影响课程生命周期，稳定的底层框架可降低后续维护成本，避免因技术迭代导致教学内容快速过时。建议定期查看技术社区官方公告…...

编程日记 2025/7/12 11:43:47

【2025软考高级架构师】——知识脑图总结

摘要本文是一份关于 2025 年软考高级架构师的知识脑图总结。整体涵盖系统工程与信息系统基础、软件工程、项目管理等众多板块，每个板块又细分诸多知识点，如系统工程部分提及系统工程方法、信息系统生命周期等内容，旨在为备考人员提供系统全…...

编程日记 2025/7/10 5:01:57

Allegro23.1新功能之如何设置高压爬电间距规则操作指导

Allegro23.1新功能之如何设置高压爬电间距规则操作指导 Allegro23.1升级到了23.1之后，新增了一个设置高压爬电间距的规则如下图，不满足爬电间距要求，以DRC的形式报出来了...

编程日记 2025/7/11 8:45:51

电商推荐系统设计思路

互联网大厂Java面试实录：马小帅的生死时速第一轮提问面试官（严肃地）：马小帅，请你先简单介绍一下你过往的项目经验，特别是你在项目中使用的技术栈。马小帅（紧张地搓手）&#xff…...

编程日记 2025/6/29 5:09:52

BC19 反向输出一个四位数

题目：BC19 反向输出一个四位数描述将一个四位数，反向输出。（有前导零的时候保留前导零） 输入描述： 一行，输入一个整数n（1000 < n < 9999）。输出描述： 针对每组…...

编程日记 2025/7/13 6:27:51

【前端】【面试】在 Vue-React 的迁移重构工作中，从状态管理角度来看，Vuex 迁移到 Redux 最大的挑战是什么，你是怎么应对的？

在从 Vue（Vuex）迁移到 React（Redux）时，状态管理无疑是重构中最具挑战性的部分之一。两者虽本质上都实现了全局状态集中式管理，但在思想、结构与实现方式上存在显著差异。 Vuex 到 Redux 状态管理迁移的挑战…...

编程日记 2025/7/13 6:44:56

ActiveMQ 与其他 MQ 的对比分析：Kafka/RocketMQ 的选型参考（一）

消息队列简介在当今的分布式系统架构中，消息队列（Message Queue，MQ）扮演着举足轻重的角色，已然成为构建高可用、高性能系统不可或缺的组件。消息队列本质上是一种异步通信的中间件，它允许不同的应用程序或…...

编程日记 2025/7/13 6:24:27

OPENGLPG第九版学习 -视口变换、裁减、剪切与反馈

文章目录 5.1 观察视图5.1.1 视图模型—相机模型OpenGL的整个处理过程中所用到的坐标系统：视锥体视锥体的剪切 5.1.2 视图模型--正交视图模型 5.2 用户变换5.2.1 矩阵乘法的回顾5.2.2 齐次坐标5.2.3 线性变换与矩阵SRT透视投影正交投影 5.2.4 法线变换逐像素计算法向…...

编程日记 2025/7/13 6:11:37

大连理工大学选修课——图形学：第一章图形学概述

第一章图形学概述计算机图形学及其研究内容计算机图形学：用数学算法将二维或三维图形转化为计算机显示器的格栅形式的科学。图形计算机图形学的研究对象为图形广义来说，能在人的视觉系统形成视觉印象的客观对象都可称为图形。既包括了各种几何…...

编程日记 2025/7/13 6:34:14

文章目录 1. in + 一段时间2. struggle with + doing sth.3. due to + n. / doing sth.4. all kinds of + n.5. supply6. get sb. down7. sth. be a hit8. ups and downs1. in + 一段时间 “in ten minutes”表示“10分钟内”，“in + 一段时间”表示“在一段时间之内”。 You…...

编程日记 2025/6/29 5:19:27

dubbo 参数校验-ValidationFilter

org.apache.dubbo.rpc.Filter 核心功能拦截RPC调用流程 Filter是Dubbo框架中实现拦截逻辑的核心接口，作用于服务消费者和提供者的作业链路，支持在方法调用前后插入自定义逻辑。如参数校验、异常处理、日志记录等。扩展性机制 Dubbo通过SPI扩展机制动态…...

编程日记 2025/7/6 11:30:50

Fine Structure-Aware Sampling（AAAI 2024）论文笔记和启发

文章目录本文解决的问题本文提出的方法以及启发本文解决的问题传统的基于Pifu的人体三维重建一般通过采样来进行学习。一般选择的采样方法是空间采样，具体是在surface的表面随机位移进行样本的生成。这里的采样是同时要在XYZ三个方向上进行。所以这导致了一个问…...

编程日记 2025/6/29 7:27:59

股票单因子的检验方法有哪些？

股票单因子的检验方法主要包括以下四类方法及相关指标： 一、统计指标检验 IC值分析法定义：IC值（信息系数）衡量因子值与股票未来收益的相关性，包括两种计算方式： Normal IC：基于Pearson相关系数…...

编程日记 2025/6/29 7:17:52

Android第三次面试总结之activity和线程池篇（补充）

一、线程池高频面试题 1. 为什么 Android 中推荐使用线程池而非手动创建线程？（字节跳动 / 腾讯真题） 核心考点：线程池的优势、资源管理、性能优化答案要点： 复用线程：避免重复创建 / 销毁线程的开销&…...

编程日记 2025/7/13 6:25:54

【Trae+LucidCoder】三分钟编写专业Dashboard页面

AI辅助编码作为一项革命性技术，正在改变开发者的工作方式。本文将深入探讨如何利用Trae的AI Coding功能构建专业的Dashboard页面，同时向您推荐一个极具价值的工具——Lucids.top，它能够将页面截图转换为AI IDE的prompt，从而生成精…...

编程日记 2025/7/13 6:21:51

CUDA Toolkit 12.9 与 cuDNN 9.9.0 发布，带来全新特性与优化

NVIDIA 近日发布了 CUDA Toolkit 12.9，为开发者提供了一系列新功能和改进，旨在进一步提升 GPU 加速应用的性能和开发效率。CUDA Toolkit 是创建高性能 GPU 加速应用的关键开发环境，广泛应用于从嵌入式系统到超级计算机的各种计算平台。新特…...

编程日记 2025/7/13 6:41:09

chrome 浏览器怎么不自动提示是否翻译网站

每次访问外国语网页都会弹出这个对话框，很是麻烦，每次都得手动关闭一下。不让他弹出来方法： 设置》语言》首选语言》添加语言，搜索英语添加上如果需要使用翻译，就点击三个点，然后选择翻译...

编程日记 2025/7/13 6:43:16

编程速递-RAD Studio 12.3 Athens四月补丁：关注软件性能的开发者，安装此补丁十分必要

2025年4月22日，Embarcadero发布了针对RAD Studio 12.3、Delphi 12.3以及CBuilder 12.3的四月补丁。此更新旨在提升这些产品的质量，特别关注于Delphi编译器、C 64位现代工具链、RAD Studio 64位IDE及其调试器、VCL库和其他RAD Studio特性。强烈建议所有使…...

编程日记 2025/6/29 6:45:29

Linux54 源码包的安装、修改环境变量解决 axel命令找不到；getfacl；测试

始终报错 . 补充链接 tinfo 库时报错软件包 ncurses-devel-5.9-14.20130511.el7_4.x86_64 已安装并且是最新版本没有可用软件包 tinfo-devel。无须任何处理 make LDLIBS“-lncurses"报错编译时报错make LDLIBS”-lncurses" ？ /opt/rh/devtoolset-11/roo…...

编程日记 2025/6/29 6:38:54

驱动开发硬核特训 · Day 27（上篇）：Linux 内核子系统的特性全解析

在过去数日的练习中，我们已经深入了解了字符设备驱动、设备模型与总线驱动模型、regulator 电源子系统、I2C 驱动模型、of_platform_populate 自动注册机制等关键模块。今天进入 Day 27，我们将正式梳理 Linux 内核子系统的核心特性与通用结构&#xff0c…...

编程日记 2025/7/9 23:49:11

【学习笔记】深度学习：典型应用

作者选择了由 Ian Goodfellow、Yoshua Bengio 和 Aaron Courville 三位大佬撰写的《Deep Learning》(人工智能领域的经典教程，深度学习领域研究生必读教材),开始深度学习领域学习，深入全面的理解深度学习的理论知识。之前的文章参考下面的链接&#xf…...

编程日记 2025/7/13 6:32:33

万字详解ADC药物Payload

抗体药物偶联物（ADC）是一种有前景的癌症治疗方式，能够选择性地将有效载荷（Payload）细胞毒性分子递送至肿瘤，降低副作用的严重程度。通常ADC由3个关键成分组成：抗体，连接子和有效载荷…...

编程日记 2025/6/29 5:10:02

算法笔记.求约数

代码实现： #include<iostream> using namespace std; #include<vector> void check(int x) {vector<int> v;for(int i 1;i< x/i;i){if(x%i 0) {cout << i<<" ";v.push_back(i);}}for(int i v.size()-1;i>0;i--){…...

编程日记 2025/6/29 6:17:20

Assetto Corsa 神力科莎 [DLC 解锁] [Steam] [Windows]

Assetto Corsa 神力科莎 [DLC 解锁] [Steam] [Windows] 需要有游戏正版基础本体，安装路径不能带有中文，或其它非常规拉丁字符； DLC 版本至最新全部 DLC 后续可能无法及时更新文章，具体最新版本见下载文件说明 DLC 解锁列表&…...

编程日记 2025/7/13 6:31:55

启发式算法-遗传算法

遗传算法是一种受达尔文生物进化论和孟德尔遗传学说启发的启发式优化算法，通过模拟生物进化过程，在复杂搜索空间中寻找最优解或近似最优解。遗传算法的核心是将问题的解编码为染色体，每个染色体代表一个候选解，通过模拟生物进化中…...

编程日记 2025/6/29 5:09:49

生成式AI将重塑的未来工作

在人类文明的长河中，技术革命始终是推动社会进步的核心动力。从蒸汽机的轰鸣到互联网的浪潮，每一次技术跃迁都在重塑着人类的工作方式与生存形态。而今，生成式人工智能（Generative AI）的崛起，正以超越以往任何时代的速度与深度，叩响未来工作范式变革的大门。这场变革并非…...

编程日记 2025/6/29 5:09:47

【操作系统】吸烟者问题

问题描述吸烟者问题是一个经典的同步问题，涉及三个抽烟者进程和一个供应者进程。每个抽烟者需要三种材料（烟草、纸和胶水）来卷烟，但每个抽烟者只有一种材料。供应者每次提供两种材料，拥有剩下那种材料的抽烟者可以卷烟…...

编程日记 2025/7/13 6:25:08

mysql-内置函数，复合查询和内外连接

一日期函数函数名称描述示例current_date()返回当前日期（格式：yyyy-mm-dd）select current_date(); → 2017-11-19current_time()返回当前时间（格式：hh:mm:ss）select current_time(); → 13:51:21current…...

编程日记 2025/7/13 6:45:39

软件架构之旅（6）：浅析ATAM 在软件技术架构评估中的应用

文章目录一、引言1.1 研究背景1.2 研究目的与意义二、ATAM 的理论基础2.1 ATAM 的定义与核心思想2.2 ATAM 涉及的质量属性2.3 ATAM 与其他架构评估方法的关系三、ATAM 的评估流程3.1 准备阶段3.2 场景和需求收集阶段3.3 架构描述阶段3.4 评估阶段3.5 结果报告阶段四、ATAM …...

编程日记 2025/6/29 5:09:46

【SQL触发器、事务、锁的概念和应用】

【SQL触发器、事务、锁的概念和应用】 1.触发器（一）触发器概述 1．触发器的定义触发器（Trigger）是一种特殊的存储过程，它与表紧密相连，可以是表定义的一部分。当预定义的事件（如用户修改指定表或者视图中的数据）发生时，触发器会自动执行。触发器基于一个表创建，…...

编程日记 2025/7/13 6:22:49

5.4学习记录

今天的目标是复习刷过往的提高课的DP题目：重点是数位DP，状态压缩DP，然后去做一些新的DP题目然后明天的任务就是把DP的题目汇总，复习一些疑难的问题方格取数： 题目背景 NOIP 2000 提高组 T4 题目描述设有 NN 的方…...

编程日记 2025/6/29 5:32:28

Hadoop 1.x设计理念解析

一、背景有人可能会好奇，为什么要学一个二十年前的东西呢？ Hadoop 1.x虽然是二十年前的，但hadoop生态系统中的一些组件如今还在广泛使用，如hdfs和yarn，当今流行spark和flink都依赖这些组件通过学习它们的历史设计…...

编程日记 2025/6/29 5:42:15

缓存与数据库的高效读写流程解析

目录前言1 读取数据的流程1.1 检查缓存是否命中1.2 从数据库读取数据1.3 更新缓存1.4 返回数据 2 写入数据的流程2.1 更新数据库2.2 更新或删除缓存2.3 缓存失效 3 缓存与数据库的一致性问题3.1 写穿（Write-through）策略3.2 写回（Write-back…...

编程日记 2025/7/13 6:27:53

Linux中的粘滞位和开发工具和文本编辑器vim

1.粘滞位的使用的背景： 当几个普通用户需要文件共享操作时，他们就需要在同一个目录下进行操作，那么就诞生一个问题，由谁来创建这个公共的目录文件？假设是由其中的一个普通用户来创建一个默认的目录文件，这就…...

编程日记 2025/7/13 6:25:54

冯诺依曼结构与哈佛架构深度解析

一、冯诺依曼结构（Von Neumann Architecture） 1.1 核心定义由约翰冯诺依曼提出，程序指令与数据共享同一存储空间和总线，通过分时复用实现存取。存储器总带宽指令带宽数据带宽即：B_mem f_clk W_data f_…...

编程日记 2025/6/29 8:21:01

如何提升个人情商？

引言提升个人情商（EQ）是一个持续的自我修炼过程，涉及自我认知、情绪管理、人际沟通等多个方面。以下是一些具体且可实践的方法，帮助你逐步提升情商： 一、提升自我觉察能力 1. 记录情绪日记每天回顾自己的情绪…...

编程日记 2025/7/13 6:55:49

JSON Web Token 默认密钥身份验证安全性分析 dubbo-admin JWT硬编码身份验证绕过

引言在web开发中，对于用户认证的问题，有很多的解决方案。其中传统的认证方式：基于session的用户身份验证便是可采用的一种。基于session的用户身份验证验证过程： 用户在用进行验证之后，服务器保存用户信息返回sess…...

编程日记 2025/7/13 6:12:59

K230的ISP（图像信号处理器）通常支持多通道输出，常见配置为3个独立通道

也就是一个摄像头可以拍摄三种配置的图片，这样就可以调用三种： img_try sensor.snapshot(chnCAM_CHN_ID_0) img_try2 sensor.snapshot(chnCAM_CHN_ID_1) img_try3 sensor.snapshot(chnCAM_CHN_ID_2) 这样可以一图多用 eg： # 初始化并配…...

编程日记 2025/7/13 6:44:17

工程师 - 小米汽车尾部主动扩散器

关于小米SU7 Ultra的主动尾部扩散器，其设计初衷是为了平衡日常驾驶的节能需求与运动驾驶的操控性能。这一装置位于车辆尾部下方，具备自动调节功能，能够根据车速在0和32之间切换，同时也支持手动调整。 32度打开状态： 0度…...

编程日记 2025/7/13 6:13:53

Linux watch 命令使用详解

简介 watch 命令会以固定间隔（默认每 2 秒）重复运行给定命令，并在终端上显示其输出。它非常适合监控不断变化的输出，例如磁盘使用情况、内存使用情况、文件更改、服务状态等。基础语法 watch [options] command常用选项 -n, -…...

编程日记 2025/7/13 6:09:17

RabbitMQ-基础

RabbitMQ-基础文章目录 RabbitMQ-基础1.同步调用2.异步调用3.技术选型4.安装RabbitMQ(官方网址)https://www.rabbitmq.com/5.快速入门5.1收发消息5.1.1交换机5.1.2队列5.1.3绑定关系5.1.4发送消息 5.2数据隔离5.2.1用户管理5.2.2virtual host 6.Java客户端操作RabbitMQ6.1快速…...

编程日记 2025/7/13 6:14:31

第九周作业

安全专题笔记 1、文件上传 (1) 服务端白名单绕过 %00截断绕过要求虚拟机中搭建实验环境，分别实现GET、POST方法的绕过前提条件： 1 php的版本需要在5.4以下 2 magic_quotes_gpc需要设置为off 启动phpstudy，前往php-ini将magic_quotes_gpc…...

编程日记 2025/7/13 6:19:48

AtCoder Beginner Contest 404 C-G（无F）题解

C. Cycle Graph? 题意给你一个 N N N 个顶点 M M M 条边的简单（无重边、自环）无向图，第 i i i 条边连接节点 A i A_i Ai 和 B i B_i Bi，判断这个图是不是一个环。思路首先一个图是环，要满足点数等于边…...

编程日记 2025/7/8 14:59:55

Python----机器学习（模型评估：准确率、损失函数值、精确度、召回率、F1分数、混淆矩阵、ROC曲线和AUC值、Top-k精度）

一、模型评估 1. 准确率（Accuracy）：这是最基本的评估指标之一，表示模型在测试集上正确分类样本的比例。对于分类任务而言，准确率是衡量模型性能的直观标准。 2. 损失函数值（Loss）&#xff1…...

编程日记 2025/6/29 6:44:41

开上“Python跑的车”——自动驾驶数据可视化的落地之道

开上“Python跑的车”——自动驾驶数据可视化的落地之道一、自动驾驶离不开“看得见”的智能在智能汽车时代，自动驾驶已然不是“炫技”标签，而是一场技术实力的全面拉锯战。而在这场战役中，有一个极其关键但常被忽略的领域，叫做：数据可视化（Data Visualization）。为…...

编程日记 2025/6/29 6:28:53

Linux内核gcov修改为模块

Linux内核gcov修改为模块 Gcov 是 GNU 项目开发的代码覆盖率分析工具，与 GCC 编译器深度集成，用于统计程序运行时代码的执行情况，帮助开发者评估测试用例的完整性和代码质量。 Gcov工作原理 1. 编译插桩编译时需添加 -fprofile-arcs -…...

编程日记 2025/6/29 5:10:16

【安装配置教程】linux部署AList记录

之前朋友安利给自己AList，这个工具可以很方便的管理个人的网盘内容，可以随时上传下载拉取，于是心血来潮自己部署并记录一下。一、拉取下载脚本在AList官网，找到安装下面的一键脚本 curl -fsSL "https://alist.nn.ci/v3.sh…...

编程日记 2025/7/12 6:23:36

题解：AT_abc245_e [ABC245E] Wrapping Chocolate

我绝对不会告诉你我打比赛时没做出来这道题。题目简化：给定每个巧克力和盒子的长宽，已知每个盒子只能放一块巧克力，并且必须保证巧克力能放下，求是否所有巧克力都能放入。思路：贪心、二分、排序、STL。首先看到这…...

编程日记 2025/7/3 13:02:12

相关文章：