rtu_linux_modules/sshd

借助MQTT实现远程控制Linux设备的SSH服务端和客户端
作者：niujiuru 日期：2026-01-20

1, 整体使用JSONRPC2.0 OVER MQTT的技术方案来架构

2，服务端使用：
- 在具体的项目代码中调用该模块的: “ModuleInit()” 函数启动初始化、安装和运行
- 在具体的项目代码中调用该模块的: “ModuleExit()” 函数完成退出、停止服务运行

3，服务端原理：
- 服务端启动时，会连接到MQTT Broker，订阅主题：/yfkj/device/rpc/imei/cmd，接收来自客户端的指令
- 服务端启动时，会连接到MQTT Broker，发布主题：/yfkj/device/rpc/imei/ack，向客户端发送指令结果

4，客户端使用：
- 会编译生成可执行程序“yfkj_ssh_client”，目前支持Linux64和Windows64上位机
- 通过配置文件配置MQTT Broker的地址、用户名、密码以及一些耗时命令的超时时间

5，客户端原理：
- 客户端启动时，会连接到MQTT Broker，发布主题：/yfkj/device/rpc/imei/cmd，向服务端发送指令请求
- 客户端启动时，会连接到MQTT Broker，订阅主题：/yfkj/device/rpc/imei/ack，接收服务端的指令结果

6，总体架构图：
┌────────────────────────────┐
│ Shell Client │
│ │
│ stdin ──> JSON-RPC call │
│ Ctrl+C ─> JSON-RPC notify │
│ │
│ prompt 显示 cwd │
└──────────────┬─────────────┘
│
JSON-RPC 2.0 over MQTT
│
┌──────────────▼─────────────┐
│ Shell Server │
│ │
│ Executor (session级) │
│ ├─ cwd │
│ ├─ Exec(cmd) │
│ ├─ Interrupt() │
│ │
│ process group (pgid) │
│ └─ kill(-pgid, SIGINT) │
└────────────────────────────┘

6，执行流程图：
┌──────────────────────────────────────────┐
│ Remote Client │
│ (Web / App / CLI 运维平台) │
└───────────────┬──────────────────────────┘
│ JSON-RPC 2.0
| - executor.ping
│ - executor.exec
│ - executor.interrupt
│ - executor.close
v
┌──────────────────────────────────────────┐
│ MQTT Broker │
│ (QoS1 / KeepAlive / Reconnect) │
└───────────────┬──────────────────────────┘
│ MQTT Message
│ Topic: /yfkj/device/rpc/{imei}/cmd
v
┌──────────────────────────────────────────┐
│ sshd / MQTTCoupler │
│ │
│ Transport & RPC Adapter Layer │
│ --------------------------------------- │
│ - MQTT 连接管理 │
│ - JSON-RPC 解析 / 校验 │
│ - 方法分发 (Method Dispatch) │
│ │
└───────────────┬──────────────────────────┘
│ 串行 / 单 Session
v
┌──────────────────────────────────────────┐
│ shell.Executor │
│ │
│ Session State Layer (≈ SSH Session) │
│ --------------------------------------- │
│ State: │
│ - cwd : 当前工作目录 │
│ - pg : 当前前台进程组 │
│ │
│ Built-in Commands │
│ --------------------------------------- │
│ - cd │
│ - pwd │
│ │
│ Control Interface │
│ --------------------------------------- │
│ Exec() : 启动命令 │
│ Interrupt() : Ctrl+C (SIGINT) │
│ │
└───────────────┬──────────────────────────┘
│ 单次命令执行
v
┌──────────────────────────────────────────┐
│ executeInternal │
│ │
│ Process Lifecycle Layer │
│ --------------------------------------- │
│ - fork/exec │
│ - 新进程组 (setpgid) │
│ - stdout / stderr 限流 │
│ - 超时控制 (context timeout) │
│ - SIGTERM → SIGKILL │
│ │
└───────────────┬──────────────────────────┘
│ MQTT Message
| Topic: /yfkj/device/rpc/{imei}/ack
v
┌──────────────────────────────────────────┐
│ Linux Kernel │
│ │
│ - Process Group │
│ - Signal Delivery │
│ - Exit Status │
└──────────────────────────────────────────┘

8, 取消流程图：Ctrl+C

Remote Client
│
│ shell.execute
v
┌───────────────┐
│ sshd │
└──────┬────────┘
│
v
┌───────────────────────────┐
│ shell.Executor │
│ │
│ Exec(): │
│ - 设置 p.Dir = cwd │
│ - 注册前台进程组 pg │
│ │
└──────┬────────────────────┘
│
v
┌───────────────────────────┐
│ executeInternal │
│ │
│ - Start cmd │
│ - setpgid │
│ - onStart(pg) │◄──────┐
│ │ │
│ - wait / timeout │ │
└──────┬────────────────────┘ │
│ │
v │
Command Running │
│
Remote Client Ctrl+C │
│ │
│ shell.interrupt │
v │
┌───────────────┐ │
│ sshd │ │
└──────┬────────┘ │
│ │
v │
┌───────────────────────────┐ │
│ Executor.Interrupt() │ │
│ → SIGINT to -pgid │───────┘
└───────────────────────────┘