
本文详解如何从 Telnet 命令(如 show ont info)获取结构化文本,精准提取字段位置、健壮处理空格/换行/截断问题,并使用 PDO 预处理语句安全插入 MySQL 数据库。
本文详解如何从 telnet 命令(如 `show ont info`)获取结构化文本,精准提取字段位置、健壮处理空格/换行/截断问题,并使用 pdo 预处理语句安全插入 mysql 数据库。
在对接 OLT(光线路终端)等网络设备时,常需通过 Telnet 获取 show ont info 类命令的 ASCII 表格输出,并将其解析后持久化到 MySQL 数据库。但原始输出存在列对齐不严格、描述字段含空格、行尾可能被截断(如 "ALESSANDRO ")、以及多行混杂非数据内容(如提示符、错误信息、分隔线)等问题,导致基于固定偏移或正则的简单解析极易失败。
核心难点在于:表头与数据行并非严格等宽对齐,且字段间以变长空格分隔,不能依赖 explode(' ', $line) 或硬编码索引。正确方案是:先定位表头各字段起始列号,再按列范围切分每行数据——即“列位置驱动解析法”。
以下为经过生产验证的完整实现:
✅ 步骤一:预处理原始响应,提取有效数据块
// 移除 Telnet 控制字符(如 \x1B[?25h 等 ANSI 转义序列)
$cleaned = preg_replace('/\x1B\[([0-9]{1,2}(;[0-9]{1,2})?)?[mGK]/', '', $poninfo_resposta);
// 提取从第一个分隔线到下一个命令提示符之间的纯数据区域
if (preg_match('/-{3,}\s*(?:F\/S\s+P\s+ONT\s+MAC.*?Desc|F\/S\s+P\s+ONT\s+ID.*?Match\s+state).*?-{3,}(.*?)(?=\r?\n(?:OLT\(config|Error:|^\s*$)|$)/is', $cleaned, $matches)) {
$dataBlock = trim($matches[1]);
} else {
throw new Exception("Failed to extract data block from telnet output");
}
$rows = array_filter(array_map('trim', explode("\n", $dataBlock)));
✅ 步骤二:动态识别表头列位置(关键!)
$headers = ['F/S', 'P', 'ONT ID', 'MAC', 'Control flag', 'Run state', 'Config state', 'Match state', 'Desc'];
$colPositions = [];
// 查找第一行含完整表头的行(跳过空行和分隔线)
foreach ($rows as $row) {
if (stripos($row, 'F/S') !== false && stripos($row, 'Desc') !== false) {
foreach ($headers as $header) {
// 使用 strpos 定位每个字段最左出现位置(注意:表头中 "ONT ID" 可能被写作 "ONT MAC" 或 "ONT ID",需适配)
$pos = stripos($row, $header);
if ($pos !== false) {
$colPositions[$header] = $pos;
}
}
ksort($colPositions); // 按列位置排序,确保顺序一致
break;
}
}
if (empty($colPositions)) {
throw new Exception("Header row not found or unrecognized");
}
✅ 步骤三:逐行解析数据,严格按列切片
$pdo_dbh = new PDO('mysql:host=localhost;dbname=mydb;charset=utf8mb4', 'myusername', 'mypassword');
$pdo_dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$stmt = $pdo_dbh->prepare(
"INSERT INTO ont_onu (
frame_slot, pon, ont_id, mac_address,
control_flag, run_state, config_state, match_state, description
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"
);
foreach ($rows as $row) {
// 过滤掉空行、分隔线、总计行、提示符行
if (empty($row) || preg_match('/^-+|Total:|OLT\(config|Error:/i', $row)) {
continue;
}
// 仅处理以 "0/0" 开头的有效数据行(可扩展为正则匹配 F/S 格式)
if (!preg_match('/^\s*0\/\d+\s+\d+\s+\d+\s+[0-9A-Fa-f:]+/', $row)) {
continue;
}
$fields = [];
$keys = array_keys($colPositions);
$values = array_values($colPositions);
// 按列位置切片:第 i 列 = substr($row, $start, $end - $start)
for ($i = 0; $i execute($fields);
} catch (PDOException $e) {
error_log("SQL insert failed for row '{$row}': " . $e->getMessage());
// 记录失败行用于调试,但不中断流程
}
}
⚠️ 关键注意事项:
- 字符编码:Telnet 输出常为 ISO-8859-1 或 UTF-8,务必在 PDO DSN 中显式指定 charset=utf8mb4,并在 file_put_contents() 时用 mb_convert_encoding() 统一。
- 字段长度限制:MySQL VARCHAR 需预留足够长度(如 mac_address 至少 17 字符,description 建议 255)。
- 空值与截断处理:部分设备返回 " " 或 "" 表示空,应映射为 NULL;描述字段超长时建议 substr($desc, 0, 255) 截断。
- 幂等性与去重:建议在表上添加唯一索引(如 UNIQUE(frame_slot, pon, ont_id)),配合 INSERT ... ON DUPLICATE KEY UPDATE 避免重复。
- 性能优化:大批量插入时,改用事务包裹(beginTransaction() / commit())并批量执行,可提升 10 倍以上吞吐。
通过此方法,无论 show ont info 输出中字段对齐如何微调(如 ONT ID 和 MAC 列宽变化),只要表头文字不变,解析逻辑即可自适应 —— 彻底解决原文中 $fields1 全为空、字段错位的根本问题。
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











