如何在Codeigniter中为数据库特定字段/表添加eventlistener避免轮询

完全可以实现，无需使用你提到的sleep轮询逻辑，以下是3种适配CodeIgniter框架特性的落地方式：

方案1：使用CI Model原生回调钩子（最简易，无额外依赖） #

适用场景：目标表的所有增改删操作都经过你封装的CI Model层完成

• CI3、CI4的Model都内置了操作前后的回调钩子，无需额外开发即可监听数据变更
• 操作示例（CI4环境）：

// 在你的目标表对应的Model中配置回调
protected $afterUpdate = ['triggerFieldChangeListener'];

protected function triggerFieldChangeListener(array $data)
{
    // 判断你要监听的字段是否发生变更
    if (isset($data['data']['your_target_field']) && $data['data']['your_target_field'] != $data['original']['your_target_field']) {
        // 这里执行你要的指定指令，公共逻辑可以封装为Library、Helper调用
        $notifyService = service('NotifyService');
        $notifyService->runWhenFieldChanged($data['id'], $data['data']['your_target_field']);
    }
    return $data;
}

• 注意：如果直接调用Query Builder的update()、query()方法执行SQL，不会触发Model回调，此类场景需要手动调用对应处理逻辑。

方案2：数据库触发器 + 阻塞式队列监听（适配跨系统变更场景） #

适用场景：目标表可能被其他系统、数据库直连操作修改，不经过CI应用的Model层

1. 先在数据库给目标表创建触发器，字段变更时写入事件数据到Redis或者专用队列表，示例MySQL触发器：

DELIMITER //
CREATE TRIGGER target_field_after_update AFTER UPDATE ON your_target_table
FOR EACH ROW
BEGIN
    IF NEW.your_target_field != OLD.your_target_field THEN
        -- 写入事件到Redis频道（需要数据库安装Redis UDF，也可以写入db_event_queue队列表配合后续监听）
        SELECT redis_publish('db_change_channel', CONCAT('{"table":"your_target_table","field":"your_target_field","id":', OLD.id, ',"new_val":"', NEW.your_target_field, '"}'));
    END IF;
END //
DELIMITER ;

2. 用CI CLI创建常驻消费脚本，使用Redis的阻塞式订阅命令监听事件，完全无轮询空转：

// 定义在app/Commands/ListenDbChange.php （CI4示例）
public function run(array $params)
{
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->subscribe(['db_change_channel'], function ($redis, $channel, $msg) {
        $eventData = json_decode($msg, true);
        // 执行你要的指定指令
        $notifyService = service('NotifyService');
        $notifyService->runWhenFieldChanged($eventData['id'], $eventData['new_val']);
    });
}

• 消费脚本可以用supervisor托管，实现异常自动重启，保证可用性。

方案3：CI事件系统 + 业务埋点（性能最优，耦合度最低） #

适用场景：只需监听特定业务操作触发的字段变更，无需覆盖所有数据库层面的修改

• 直接在对应业务逻辑的处理位置触发CI自定义事件，事件订阅者中执行目标指令即可：

// 业务逻辑中，修改完目标字段后触发事件
event('field_changed', [$orderId, $newStatus]);

// 在app/Config/Events.php中注册事件监听
Events::on('field_changed', function ($orderId, $newStatus) {
    // 执行指定指令
    $notifyService = service('NotifyService');
    $notifyService->runWhenFieldChanged($orderId, $newStatus);
});

注意事项 #

• 不要将耗时的执行逻辑放到HTTP请求流程中，避免拖慢接口响应，建议统一封装为异步任务执行
• 使用Model回调或业务埋点时，注意覆盖所有会修改目标字段的操作路径，避免漏触发
• 常驻消费进程需要做好异常捕获、日志记录，避免进程异常退出导致事件丢失

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