Workerman里能用ORM吗？整合ThinkORM或Eloquent的方法是什么

Workerman作为高性能的PHP socket框架，本身不提供数据库ORM功能，但完全支持引入第三方ORM组件，其中ThinkORM和Eloquent是最常用的两个选择，整合过程并不复杂，只需要做好依赖管理和初始化配置即可。

一、Workerman整合ThinkORM的方法

1. 安装依赖

首先需要在Workerman项目根目录下通过Composer安装ThinkORM依赖，执行以下命令：

composer require topthink/think-orm

2. 初始化配置

在Workerman的启动文件中，或者自定义的初始化脚本里，配置ThinkORM的数据库连接参数，示例如下：

<?php
use thinkfacadeDb;

// 配置数据库连接
Db::setConfig([
    // 默认数据库连接配置
    'default' => 'mysql',
    'connections' => [
        'mysql' => [
            // 数据库类型
            'type' => 'mysql',
            // 服务器地址
            'hostname' => '127.0.0.1',
            // 数据库名
            'database' => 'test_db',
            // 用户名
            'username' => 'root',
            // 密码
            'password' => 'root123',
            // 端口
            'hostport' => '3306',
            // 数据库编码默认采用utf8mb4
            'charset' => 'utf8mb4',
            // 数据库表前缀
            'prefix' => '',
            // 数据库调试模式
            'debug' => true,
        ],
    ],
]);

3. 使用示例

配置完成后，就可以在Workerman的业务逻辑中直接使用ThinkORM进行数据库操作，比如在消息回调中使用：

<?php
use WorkermanWorker;
use thinkfacadeDb;

$worker = new Worker('websocket://0.0.0.0:2346');

$worker->onMessage = function($connection, $data) {
    // 查询用户表数据
    $user = Db::table('user')->where('id', 1)->find();
    // 插入数据
    $insertId = Db::table('log')->insert(['content' => $data, 'create_time' => time()]);
    $connection->send(json_encode(['user' => $user, 'log_id' => $insertId]));
};

Worker::runAll();

二、Workerman整合Eloquent的方法

1. 安装依赖

Eloquent是Laravel的ORM组件，同样可以通过Composer安装到Workerman项目中：

composer require illuminate/database

2. 初始化配置

在启动脚本中初始化Eloquent的数据库连接，示例如下：

<?php
use IlluminateDatabaseCapsuleManager as Capsule;

$capsule = new Capsule;

// 添加数据库连接配置
$capsule->addConnection([
    'driver' => 'mysql',
    'host' => '127.0.0.1',
    'database' => 'test_db',
    'username' => 'root',
    'password' => 'root123',
    'charset' => 'utf8mb4',
    'collation' => 'utf8mb4_unicode_ci',
    'prefix' => '',
    'port' => '3306',
]);

// 设置全局静态可访问
$capsule->setAsGlobal();
// 启动Eloquent
$capsule->bootEloquent();

3. 定义模型与使用

可以先定义对应的Eloquent模型，也可以直接使用查询构造器操作，示例如下：

<?php
use WorkermanWorker;
use IlluminateDatabaseCapsuleManager as Capsule;

// 定义User模型
class User extends IlluminateDatabaseEloquentModel {
    protected $table = 'user';
    public $timestamps = false;
}

$worker = new Worker('websocket://0.0.0.0:2346');

$worker->onMessage = function($connection, $data) {
    // 使用模型查询
    $user = User::where('id', 1)->first();
    // 使用查询构造器插入
    $id = Capsule::table('log')->insertGetId([
        'content' => $data,
        'create_time' => time()
    ]);
    $connection->send(json_encode(['user' => $user, 'log_id' => $id]));
};

Worker::runAll();

三、注意事项

• Workerman是常驻内存框架，数据库连接会在进程启动时建立，需要注意数据库连接的断线重连问题，可以在配置中开启断线重连选项，或者在操作前检查连接状态。
• 不要在Worker的onMessage等回调中重复执行ORM的初始化配置，初始化操作只需要执行一次即可。
• 如果项目中有多个Worker进程，每个进程都会独立维护自己的数据库连接，不需要额外做连接池处理，ORM本身会管理好连接生命周期。

通过以上步骤，就可以在Workerman中顺利使用ThinkORM或者Eloquent进行数据库操作，既保留了Workerman的高性能特性，又能享受ORM带来的开发便利性。

WorkermanThinkORMEloquentORM_integration修改时间：2026-07-15 12:48:30