您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

workerman-mysql组件-其它数据库类使用-thinkphp(think-orm)

发布时间：2021-12-23 21:30:41编辑：雪饮阅读（）

 首先是安装

安装：
composer require topthink/think-orm
然后是使用

<?php

use Workerman\Connection\TcpConnection;
use Workerman\Worker;
use think\facade\Db;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onWorkerStart = function($worker)
{
    // 数据库配置信息设置（全局有效）
    Db::setConfig([
        // 默认数据连接标识
        'default'     => 'mysql',
        // 数据库连接信息
        'connections' => [
            'mysql' => [
                // 数据库类型
                'type'     => 'mysql',
                // 主机地址
                'hostname' => '127.0.0.1',
                // 用户名
                'username' => 'workerman',
                // 数据库名
                'database' => 'workerman',
                //密码
                'password'=>'workerman',
                // 数据库编码默认采用utf8
                'charset' => 'utf8',
                // 数据库表前缀
                'prefix'   => 'ci_',
                // 数据库调试模式
                'debug'    => true,
            ],
        ],
    ]);

};
$worker->onMessage = function(TcpConnection $connection, $data)
{
    $account=Db::name('account')->where('id', 3)->find();
    /*
     *这里也可以使用table，但是用table会发现表前缀prefix不会自动追加在表名前面
     * $account=Db::table('account')->where('id', 3)->find();
     * */
    $connection->send(json_encode($account));
};
// 运行worker
Worker::runAll();

这里需要注意要在回调中初始化数据库连接，详见（https://www.workerman.net/doc/workerman/components/workerman-mysql.html）

服务启动
[root@localhost workerman]# php index.php start
Workerman[index.php] start in DEBUG mode
------------------------------------------- WORKERMAN --------------------------------------------
Workerman version:4.0.26          PHP version:7.3.31
-------------------------------------------- WORKERS ---------------------------------------------
proto   user            worker          listen                      processes    status
tcp     root            none            websocket://0.0.0.0:8484    1             [OK]
--------------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
有websocket触发了上面服务脚本的onMessage回调时：