注册 登录
发贴工具
自动发帖软件»群发软件 › 群发软件公告教程 › AIWORK源码分享 › 数据库MySQL用户在线状态管理心跳程序
返回列表 发帖
查看: 7|回复: 0
打印 上一主题 下一主题

[24小时收录超级好的网站] 数据库MySQL用户在线状态管理心跳程序

[复制链接]

2432

主题

2480

帖子

1万

积分

积分
14796
跳转到指定楼层
楼主
发帖软件 发表于 4 小时前 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式


数据库MySQL用户在线状态管理心跳程序


数据库MySQL用户在线状态管理心跳程序 群发软件发帖工具

数据库MySQL用户在线状态管理心跳程序 群发软件发帖工具



  1. // 用户在线状态管理心跳程序
  2. // 用于跟踪和管理用户在线状态的示例程序
  3. //🍎交流QQ群711841924群一，苹果内测群，528816639
  4. print.log("===== 用户在线状态管理心跳程序启动 =====");

  6. // 全局变量
  7. var conn = null;
  8. var heartbeatInterval = null;
  9. var isRunning = false;
  10. var currentUser = null;

  12. /**
  13. * 连接数据库
  14. */
  15. function connectDatabase() {
  16.     try {
  17.         var url = "jdbc:mysql://mysql2.sqlpub.com:3307/chaook";
  18.         var user = "chaook";
  19.         var password = "JAVsRUMHkoJ123xJ";
  20.         var params = "?useSSL=false&characterEncoding=utf8";
  21.         
  22.         print.log("正在连接数据库...");
  23.         conn = mysql.getConnection(url, user, password);
  24.         print.log("✅ 数据库连接成功");
  25.         return true;
  26.     } catch (e) {
  27.         print.log("❌ 数据库连接失败: " + e.message);
  28.         return false;
  29.     }
  30. }

  32. /**
  33. * 初始化数据库表结构
  34. */
  35. function initializeDatabase() {
  36.     try {
  37.         // 创建用户在线状态表
  38.         var userTableSql = "CREATE TABLE IF NOT EXISTS 用户在线状态表 (" +
  39.                           "用户ID VARCHAR(50) PRIMARY KEY," +
  40.                           "用户名 VARCHAR(100)," +
  41.                           "在线状态 TINYINT DEFAULT 0," +  // 0-离线, 1-在线
  42.                           "最后活跃时间 DATETIME," +
  43.                           "会话开始时间 DATETIME," +
  44.                           "在线时长 INT DEFAULT 0" +       // 单位：秒
  45.                           ") ENGINE=InnoDB DEFAULT CHARSET=utf8";
  46.                            
  47.         var stmt = conn.createStatement();
  48.         stmt.executeUpdate(userTableSql);
  49.         stmt.close();
  50.         
  51.         // 创建用户活动日志表
  52.         var logTableSql = "CREATE TABLE IF NOT EXISTS 用户活动日志表 (" +
  53.                          "日志ID INT AUTO_INCREMENT PRIMARY KEY," +
  54.                          "用户ID VARCHAR(50)," +
  55.                          "活动类型 VARCHAR(50)," +
  56.                          "活动详情 TEXT," +
  57.                          "活动时间 DATETIME DEFAULT CURRENT_TIMESTAMP," +
  58.                          "FOREIGN KEY (用户ID) REFERENCES 用户在线状态表(用户ID) ON DELETE CASCADE" +
  59.                          ") ENGINE=InnoDB DEFAULT CHARSET=utf8";
  60.                         
  61.         stmt = conn.createStatement();
  62.         stmt.executeUpdate(logTableSql);
  63.         stmt.close();
  64.         
  65.         print.log("✅ 数据库表结构初始化完成");
  66.         return true;
  67.     } catch (e) {
  68.         print.log("❌ 数据库表结构初始化失败: " + e.message);
  69.         return false;
  70.     }
  71. }

  73. /**
  74. * 用户登录
  75. */
  76. function userLogin(userId, username) {
  77.     try {
  78.         var sql = "INSERT INTO 用户在线状态表 (用户ID, 用户名, 在线状态, 最后活跃时间, 会话开始时间) " +
  79.                   "VALUES (?, ?, 1, NOW(), NOW()) " +
  80.                   "ON DUPLICATE KEY UPDATE 用户名 = VALUES(用户名), 在线状态 = 1, 最后活跃时间 = NOW(), 会话开始时间 = NOW()";
  81.                   
  82.         var pstmt = conn.prepareStatement(sql);
  83.         pstmt.setString(1, userId);
  84.         pstmt.setString(2, username);
  85.         pstmt.executeUpdate();
  86.         pstmt.close();
  87.         
  88.         logUserActivity(userId, "用户登录", "用户 " + username + " 登录系统");
  89.         currentUser = {id: userId, name: username};
  90.         print.log("✅ 用户 " + username + " 登录成功");
  91.         return true;
  92.     } catch (e) {
  93.         print.log("❌ 用户登录失败: " + e.message);
  94.         return false;
  95.     }
  96. }

  98. /**
  99. * 发送用户心跳包
  100. */
  101. function sendUserHeartbeat(userId) {
  102.     try {
  103.         var sql = "UPDATE 用户在线状态表 SET 在线状态 = 1, 最后活跃时间 = NOW() WHERE 用户ID = ?";
  104.                   
  105.         var pstmt = conn.prepareStatement(sql);
  106.         pstmt.setString(1, userId);
  107.         pstmt.executeUpdate();
  108.         pstmt.close();
  109.         
  110.         logUserActivity(userId, "心跳包", "发送心跳包，更新用户活跃时间");
  111.         print.log("✅ 用户 " + userId + " 心跳包发送成功");
  112.         return true;
  113.     } catch (e) {
  114.         print.log("❌ 心跳包发送失败: " + e.message);
  115.         return false;
  116.     }
  117. }

  119. /**
  120. * 记录用户活动日志
  121. */
  122. function logUserActivity(userId, activityType, details) {
  123.     try {
  124.         var sql = "INSERT INTO 用户活动日志表 (用户ID, 活动类型, 活动详情) VALUES (?, ?, ?)";
  125.         var pstmt = conn.prepareStatement(sql);
  126.         pstmt.setString(1, userId);
  127.         pstmt.setString(2, activityType);
  128.         pstmt.setString(3, details);
  129.         pstmt.executeUpdate();
  130.         pstmt.close();
  131.         return true;
  132.     } catch (e) {
  133.         // 日志记录失败不影响主流程
  134.         print.log("⚠️ 用户活动日志记录失败: " + e.message);
  135.         return false;
  136.     }
  137. }

  139. /**
  140. * 检查用户在线状态
  141. */
  142. function checkUserStatus() {
  143.     try {
  144.         var sql = "SELECT 用户ID, 用户名, 在线状态, 最后活跃时间, 会话开始时间 FROM 用户在线状态表";
  145.         var stmt = conn.createStatement();
  146.         var rs = stmt.executeQuery(sql);
  147.         
  148.         print.log("\n=== 用户在线状态监控 ===");
  149.         print.log("用户ID\t\t用户名\t\t在线状态\t最后活跃时间\t\t\t会话开始时间");
  150.         print.log("-----------------------------------------------------------------------------------------------");
  151.         
  152.         var offlineUsers = [];
  153.         var onlineUsers = [];
  154.         
  155.         while (rs.next()) {
  156.             var userId = rs.getString("用户ID");
  157.             var username = rs.getString("用户名");
  158.             var onlineStatus = rs.getInt("在线状态");
  159.             var lastActive = rs.getTimestamp("最后活跃时间");
  160.             var sessionStart = rs.getTimestamp("会话开始时间");
  161.             
  162.             // 格式化输出
  163.             var nameStr = username + "\t\t";
  164.             if (username.length >= 4) nameStr = username + "\t";
  165.             
  166.             var statusStr = onlineStatus === 1 ? "在线" : "离线";
  167.             
  168.             print.log(userId + "\t" + nameStr + statusStr + "\t\t" + lastActive + "\t" + sessionStart);
  169.             
  170.             // 分类用户
  171.             if (onlineStatus === 1) {
  172.                 onlineUsers.push({id: userId, name: username, lastActive: lastActive});
  173.             } else {
  174.                 offlineUsers.push({id: userId, name: username});
  175.             }
  176.         }
  177.         
  178.         rs.close();
  179.         stmt.close();
  180.         
  181.         // 报告统计信息
  182.         print.log("\n📊 统计信息:");
  183.         print.log("  在线用户数: " + onlineUsers.length);
  184.         print.log("  离线用户数: " + offlineUsers.length);
  185.         
  186.         if (onlineUsers.length > 0) {
  187.             print.log("\n🟢 在线用户列表:");
  188.             for (var i = 0; i < onlineUsers.length; i++) {
  189.                 var user = onlineUsers[i];
  190.                 print.log("  - " + user.name + " (" + user.id + ") 最后活跃: " + user.lastActive);
  191.             }
  192.         }
  193.         
  194.         if (offlineUsers.length > 0) {
  195.             print.log("\n&#128308; 离线用户列表:");
  196.             for (var i = 0; i < offlineUsers.length; i++) {
  197.                 var user = offlineUsers[i];
  198.                 print.log("  - " + user.name + " (" + user.id + ")");
  199.             }
  200.         }
  201.         
  202.         print.log("");
  203.         return true;
  204.     } catch (e) {
  205.         print.log("❌ 用户状态检查失败: " + e.message);
  206.         return false;
  207.     }
  208. }

  210. /**
  211. * 用户登出
  212. */
  213. function userLogout(userId) {
  214.     try {
  215.         // 更新在线时长
  216.         var durationSql = "UPDATE 用户在线状态表 SET 在线时长 = TIMESTAMPDIFF(SECOND, 会话开始时间, NOW()) WHERE 用户ID = ?";
  217.         var pstmt = conn.prepareStatement(durationSql);
  218.         pstmt.setString(1, userId);
  219.         pstmt.executeUpdate();
  220.         pstmt.close();
  221.         
  222.         // 设置为离线状态
  223.         var sql = "UPDATE 用户在线状态表 SET 在线状态 = 0 WHERE 用户ID = ?";
  224.         pstmt = conn.prepareStatement(sql);
  225.         pstmt.setString(1, userId);
  226.         pstmt.executeUpdate();
  227.         pstmt.close();
  228.         
  229.         logUserActivity(userId, "用户登出", "用户登出系统");
  230.         print.log("✅ 用户 " + userId + " 登出成功");
  231.         return true;
  232.     } catch (e) {
  233.         print.log("❌ 用户登出失败: " + e.message);
  234.         return false;
  235.     }
  236. }

  238. /**
  239. * 心跳任务执行函数
  240. */
  241. function executeHeartbeatTask() {
  242.     print.log("\n⏰ 执行用户心跳任务 - " + new Date());
  243.    
  244.     try {
  245.         // 检查数据库连接
  246.         if (!conn || conn.isClosed()) {
  247.             print.log("⚠️ 数据库连接已断开，尝试重新连接...");
  248.             if (!connectDatabase()) {
  249.                 print.log("❌ 无法重新连接数据库，跳过本次心跳任务");
  250.                 return;
  251.             }
  252.         }
  253.         
  254.         // 如果有当前用户，发送心跳包
  255.         if (currentUser) {
  256.             sendUserHeartbeat(currentUser.id);
  257.         }
  258.         
  259.         // 检查所有用户状态
  260.         checkUserStatus();
  261.         
  262.         print.log("✅ 用户心跳任务执行完成\n");
  263.     } catch (e) {
  264.         print.log("❌ 用户心跳任务执行失败: " + e.message);
  265.     }
  266. }

  268. /**
  269. * 启动心跳服务
  270. */
  271. function startHeartbeatService(intervalSeconds) {
  272.     if (isRunning) {
  273.         print.log("⚠️ 心跳服务已经在运行中");
  274.         return false;
  275.     }
  276.    
  277.     // 连接数据库
  278.     if (!connectDatabase()) {
  279.         print.log("❌ 无法启动心跳服务：数据库连接失败");
  280.         return false;
  281.     }
  282.    
  283.     // 初始化数据库
  284.     if (!initializeDatabase()) {
  285.         print.log("❌ 无法启动心跳服务：数据库初始化失败");
  286.         return false;
  287.     }
  288.    
  289.     isRunning = true;
  290.     print.log("✅ 心跳服务启动成功，间隔: " + intervalSeconds + "秒");
  291.    
  292.     // 立即执行一次
  293.     executeHeartbeatTask();
  294.    
  295.     // 设置定时任务
  296.     heartbeatInterval = setInterval(function() {
  297.         executeHeartbeatTask();
  298.     }, intervalSeconds * 1000);
  299.    
  300.     return true;
  301. }

  303. /**
  304. * 停止心跳服务
  305. */
  306. function stopHeartbeatService() {
  307.     if (!isRunning) {
  308.         print.log("⚠️ 心跳服务未在运行");
  309.         return false;
  310.     }
  311.    
  312.     if (heartbeatInterval) {
  313.         clearInterval(heartbeatInterval);
  314.         heartbeatInterval = null;
  315.     }
  316.    
  317.     isRunning = false;
  318.     print.log("✅ 心跳服务已停止");
  319.     return true;
  320. }

  322. /**
  323. * 关闭数据库连接
  324. */
  325. function closeConnection() {
  326.     try {
  327.         if (conn != null) {
  328.             conn.close();
  329.         }
  330.         print.log("✅ 数据库连接已关闭");
  331.     } catch (e) {
  332.         print.log("❌ 关闭连接时出错: " + e.message);
  333.     }
  334. }

  336. /**
  337. * 程序退出处理
  338. */
  339. function exitHandler() {
  340.     print.log("正在关闭心跳服务...");
  341.     // 如果有用户登录，执行登出操作
  342.     if (currentUser) {
  343.         userLogout(currentUser.id);
  344.     }
  345.     stopHeartbeatService();
  346.     closeConnection();
  347.     print.log("&#128075; 用户在线状态管理心跳程序已退出");
  348. }

  350. // 主程序
  351. try {
  352.     print.log("&#128640; 启动用户在线状态管理心跳程序");
  353.    
  354.     // 注册退出处理函数
  355.     java.lang.Runtime.getRuntime().addShutdownHook(new java.lang.Thread({
  356.         run: function() {
  357.             exitHandler();
  358.         }
  359.     }));
  360.    
  361.     // 启动心跳服务 (每30秒执行一次)
  362.     if (startHeartbeatService(30)) {
  363.         print.log("✅ 用户在线状态管理心跳程序已启动");
  364.         print.log("&#128161; 按 Ctrl+C 停止程序");
  365.         
  366.         // 模拟用户登录
  367.         print.log("&#128221; 模拟用户登录...");
  368.         userLogin("USER_001", "张三");
  369.         
  370.         // 保持程序运行
  371.         while (isRunning) {
  372.             java.lang.Thread.sleep(1000);
  373.         }
  374.     } else {
  375.         print.log("❌ 用户在线状态管理心跳程序启动失败");
  376.     }
  377.    
  378. } catch (e) {
  379.     print.log("❌ 程序执行过程中发生错误: " + e.message);
  380.     exitHandler();
  381. }

  383. print.log("===== 用户在线状态管理心跳程序结束 =====");
复制代码



AIWROK, AIWROK软件
楼主新帖
楼主热帖
unto数据库MYQ业务流程心跳程序启动nextnocontent

相关帖子
回复

使用道具 举报

返回列表 发帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

相关导读了
    采集亚马逊正版群发工具有没有？
    Apr.20旅行X心语今天来说说YYPOST新功能的一个灵活用法，采集亚马逊商品信息，并且获得排名的软件，亚马逊现在越来越多客户做，淘宝的水是越来越清了，以前做电商的客户，现在都转战到外国，最赚钱的要数一些客户往亚马逊里堆了吧，拿我这个YYPOST的客户，最多的是采集，分析排名，刷价格，刷数量，改价，刷访问量等等技术
    企业发展B2B网站有什么东东软件可以发呢
    标题企业发展网B2B软件，现在虽然B2B网站收录不错，可愁的是心急的人们，他们太想一口吃撑胖子了，发帖宣传虽然不能像佛系那样淡定，但也不能像跑火车那般急躁对待，自己内容不收录，完全是自己操作内容问题，可以参考一下别人的内容是怎么弄的，然后自己要试着转变，而且收录这个内容，常常会变化的，不是一种规则就吃到老
    搜房天下房聊软件哪一个好呢
    本帖最后由 发帖软件 于 2019-5-22 16:15 编辑 2搜房天下群发房聊信息软件，开始本来打算做58同城的，但发一个就要一次点触验证码，这就让人没有感觉到存在的价值了吧，都是卖二手房和新房的搜房天下倒是可以发即时聊天信息，也没有发现他这个网站有啥子限制，登陆一个搜房天下账号，然后采集回来分类列表的网址，然后就一
    大家坛有没有好用的群发工具下载呢
    当你的笑容给我礼貌的招呼，大家坛全自动发帖软件，宣传推广是一场持久战，总是有一些人把软件用了一天，或是几个小时，就觉得自己付出太多了，那加进来的粉丝，或是流量，应该是和宣传多少成正比的，其实没有这么便宜的事，就像很多阅读量超过一百万的视频，或是电影，真正会在屏幕打赏的人不会超过三千，真正大额打赏给主
    群发正版软件中国塑料网
    中国塑料网群发软件YYPOST脚本下载地址，这个网站会有一个很奇怪的问题就是你在首页登陆无半个验证码，但在登陆网址登陆就会有一个验证码，所以我们灵活一些，在首页登陆就不用输入验证码了哈。网站秒收录比较高，但发的都是五金和建筑行业，先前有很多人都是发土建工程的大公司操作的，现在这个网站专为那个行业诞生的吧。
    OpenStreetMap网站正版2019年发帖工具下载
    本帖最后由 发帖软件 于 2019-5-21 11:13 编辑 OpenStreetMap网站全自动群发，OpenStreetMapOpenStreetMap（简称OSM，中文是公开地图）是一个网上地图协作计划，目标是创造一个内容自由且能让所有人编辑的世界地图。有的人编辑地图然后等收录，有的人发日志等收录，我们这里也是利用地图日志做为宣传的目标，简单的脚本理
    搜房天下全自动收短信全自动识别验证码注册账号软件
    房天下自动注册机，这个脚本是前几天发房聊的脚本廷伸品种，这个脚本能做到自动注册账号，自动保存账号，自动发房聊的效果，不过今天我们主要说一说怎么注册账号写脚本吧，这个搜房天天下的账号，可以发提问，可以发房聊，发论坛，发博客，还有发个人中心页都是有秒收的效果的，这样就省去了去买号，去乱花钱的效果了吧，而
    企业邮箱安卓端有什么APP软件可以发的呢
    请输入标题企业邮箱安卓发发送邮箱脚本，这个脚本是利用企业邮箱进行群发的，全程是一种模拟手工操作的过程，所以封号是很少的，而且企业邮箱群发到普通QQ邮箱不容易进垃圾箱中的，所以这个脚本也是这样的原理，不过最好是利用一些多开器，登陆多点的QQ邮箱账号会比较流畅一些，然后用软件一个一个的切换APP进行群发邮件会
    头条留评论软件有没有好用的呢？
    今天整一个今日头条留言软件，对于留言YYPOST是优势是比较大的存在，因为他往往专注一些下拉定位的优点，像今日头条这样，还是需要一些特殊下拉定位的，因为他新闻有长有短，有图有视频的，所以综合起来定位是比较难的，如果用POST也不是很轻松可以破解他的加密参数。这个脚本也是有一个不好的地方就是换号会比较麻烦，您电
    单网页生成神器
    最近新技术，网页生成机占领了整个网络的半壁江山，效果很疯狂，虽然不知道能持续多久，作为开发软件的领头者，一直在找收录的方法，一直在努力创新着，一直被人模仿，却从没有被超越过，这个网页生成机，已经出来有一段时间了，一直没有拿出来分享，醉过醉过，它是利用的一些小小收录漏洞整的，您最好用一些老站域名，进行
关闭
本站开发自动发帖软件是目前效果最好的发贴工具，软件可以兼容所有的论坛，进行群发贴子，可以对各大论坛自主录制操作流程，自动识别 验证码，自动注册账号，自动群发贴子，还可以设置成自动抢沙发，是推广宣传的神级软件，软件可以兼容任何IE能顶贴发贴论坛，完全可以 做成论坛发贴软件，生成脚本，对各大论坛程序完美支持的。软件不但发的贴子收录快，而且只用法简单，使用方便，价格便宜，软件客服16 小时在线全程协助，为您的宣传保驾护航。用最少的投资，实现最大的收益，用最简单的方式，完全最复杂的操作。 QQ

Copyright © 2014 ( 京ICP备09078825号 )

Powered by Discuz! X3.2

群发软件发帖工具
快速回复 返回列表 返回顶部
本站自动发贴软件，是现在最流行的做脚本软件，这种发贴工具，不但发贴收录快，而且抢占好的先机，完全自由编辑，实现针对性群发模拟操作，软件可以顶贴，也可以发贴，可以兼容支持Discuz、PHPWind、Dvbbs三大主流论坛，有手机验证码收件，邮件收发的功能，支持验证码识别，注册问题识别，多线程任务，自动上传头像，自动激活注册邮件，兼容防注册插件，本站软件原创正版，更新效率最快的原创软件。 『网络推广软件』『自动发帖软件』『 自动发帖』