如何ping MySQL客户端，编写服务端脚本及Windows Form验证其登录在线状态

MySQL原生协议仅支持客户端主动向服务端发送ping请求校验连接存活，服务端无法主动向MySQL客户端发起内置ping探测。你需要在现有业务逻辑上新增自定义心跳机制，搭配服务端状态记录、WinForm客户端响应逻辑实现在线检测。

• 首先在MySQL中新建客户端心跳状态表，存储客户端登录标识、最后心跳时间和在线状态：

CREATE TABLE client_heartbeat (
  client_id VARCHAR(64) PRIMARY KEY COMMENT '客户端唯一标识，登录时由服务端生成',
  login_account VARCHAR(32) NOT NULL COMMENT '客户端登录账号',
  last_heartbeat DATETIME NOT NULL COMMENT '最后一次心跳上报时间',
  is_online TINYINT(1) DEFAULT 1 COMMENT '在线状态：1在线 0离线'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

• 服务端新增两个基础接口：
  1. 登录校验接口：账号密码验证通过后生成唯一client_id返回给客户端，同时往client_heartbeat表插入初始化记录
  2. 心跳接收接口：接收客户端上报的心跳请求，更新对应client_id的last_heartbeat字段为当前时间
• 编写定时检测脚本，每10秒执行一次批量判定客户端在线状态：

import pymysql
import time

DB_CONFIG = {
  "host": "你的MySQL服务地址",
  "user": "数据库账号",
  "password": "数据库密码",
  "database": "业务库名"
}

def check_client_online_status():
    conn = pymysql.connect(**DB_CONFIG)
    cursor = conn.cursor()
    # 超过30秒未上报心跳判定为离线，可根据业务需要调整超时阈值
    update_sql = "UPDATE client_heartbeat SET is_online = 0 WHERE TIMESTAMPDIFF(SECOND, last_heartbeat, NOW()) > 30"
    cursor.execute(update_sql)
    conn.commit()
    # 此处可扩展离线后续逻辑：比如踢掉登录、记录操作日志等
    cursor.close()
    conn.close()

if __name__ == "__main__":
    # 常驻后台定时检测
    while True:
        check_client_online_status()
        time.sleep(10)

• 登录成功后，保存服务端返回的client_id和MySQL连接对象到全局变量
• 新增后台定时器，每15秒上报一次心跳，同时调用MySQL原生Ping方法校验本地连接存活：

using System;
using System.Windows.Forms;
using MySql.Data.MySqlClient;
using System.Net.Http;

public partial class MainForm : Form
{
    // 登录后服务端返回的客户端唯一标识
    private string _currentClientId;
    // 客户端本地MySQL连接对象
    private MySqlConnection _mysqlConn;
    // 心跳定时器
    private System.Timers.Timer _heartbeatTimer;

    // 登录成功后的初始化逻辑
    private void AfterLoginSuccess(string clientId, MySqlConnection conn)
    {
        _currentClientId = clientId;
        _mysqlConn = conn;
        // 15秒触发一次心跳，间隔要小于服务端的超时阈值
        _heartbeatTimer = new System.Timers.Timer(15000);
        _heartbeatTimer.Elapsed += HeartbeatTask;
        _heartbeatTimer.Start();
    }

    private async void HeartbeatTask(object sender, System.Timers.ElapsedEventArgs e)
    {
        try
        {
            // 校验本地MySQL连接是否存活
            if (_mysqlConn.State != System.Data.ConnectionState.Open)
            {
                _mysqlConn.Open();
            }
            // 调用MySQL原生Ping方法
            _mysqlConn.Ping();

            // 向服务端上报心跳
            using (var httpClient = new HttpClient())
            {
                await httpClient.GetAsync($"http://你的服务端地址/heartbeat?client_id={_currentClientId}");
            }
        }
        catch (Exception ex)
        {
            // 心跳失败处理逻辑
            Invoke(new Action(() =>
            {
                MessageBox.Show("连接已断开，请重新登录");
                // 此处扩展跳转登录页、清空本地缓存等逻辑
            }));
            _heartbeatTimer.Stop();
        }
    }
}

如果确实需要服务端主动发起探测，可以在客户端启动后监听一个闲置TCP端口，服务端记录每个客户端的IP和监听端口，定时向对应地址发送探测包，客户端收到后返回固定响应即可，不需要依赖HTTP心跳上报。

内容的提问来源于stack exchange，提问作者Mr_Tropica