Workerman?? ??? ??? ?? MySQL? ???? ??

Workerman? ??? ???? PHP ?? ?????? ???? ?? ?? ??? ?? ?????. ?? ?? ?????? ??? ?? ? ??? ?? MySQL? ???? ?? ??? ????. ????? Workerman?? ??? ??? ?? MySQL? ???? ??? ???? ???? ?? ??? ?????.

1. MySQL ?? ??

???? ?? MySQL ??? ???? ??? ???? ???. MySQL ??? ?? ??? ?? ??? ? ????:

$ pecl install mysql

MySQL ??? ?? ???? ?? ?? ? ??? ??? ? ????.

2. MySQL ?? ??

MySQL? ??? ????? ???? ?? ?? MySQL? ??? ???? ???. Workerman??? ?? ??? ?? MySQL ??? ??? ? ????.

<?php
require_once __DIR__ . '/Workerman/Autoloader.php';

use WorkermanWorker;
use WorkermanMySQLConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $GLOBALS['db'] = new Connection('host', 'username', 'password', 'database');
};

Worker::runAll();

? ????? ?? Workerman ?????? Autoloader? ???? Worker ??? ??????. Worker ??? onWorkerStart ?? ???? ??? ???, ??? ??, ???? ? ?????? ??? ???? MySQL ??? ?????. ?? ???? ???? ?? ?? ?? $GLOBALS['db']? ?? ??? ?????. $GLOBALS['db']中，以便在后續(xù)的代碼中使用。

三、執(zhí)行SQL查詢語句

在建立了MySQL連接之后，我們就可以使用MySQL連接對(duì)象來執(zhí)行SQL查詢語句了。下面是一個(gè)簡(jiǎn)單的例子：

<?php
use WorkermanWorker;
use WorkermanMySQLConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $GLOBALS['db'] = new Connection('host', 'username', 'password', 'database');
};

$worker->onMessage = function($connection, $data) {
    $res = $GLOBALS['db']->query('SELECT * FROM users');
    if (!$res) {
        $connection->send('查詢失敗');
    } else {
        $connection->send(json_encode($res));
    }
};

Worker::runAll();

在上述代碼中，我們?cè)赪orker對(duì)象的onMessage回調(diào)函數(shù)中執(zhí)行了一個(gè)查詢語句，查詢了名為users的表中的所有數(shù)據(jù)。如果查詢失敗，則返回"查詢失敗"；否則將查詢結(jié)果使用json_encode函數(shù)進(jìn)行序列化，并發(fā)送給客戶端。

這只是一個(gè)簡(jiǎn)單的例子，實(shí)際應(yīng)用中，我們可以根據(jù)具體的需求，執(zhí)行各種SQL語句，如插入、更新、刪除等操作。

四、連接池優(yōu)化

在高并發(fā)的網(wǎng)絡(luò)應(yīng)用中，經(jīng)常需要用到連接池來優(yōu)化數(shù)據(jù)庫(kù)連接。Workerman框架提供了MySQL連接池的支持，可以有效地管理和復(fù)用MySQL連接。

以下是一個(gè)使用連接池的示例代碼：

<?php
use WorkermanWorker;
use WorkermanMySQLConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $GLOBALS['db'] = new WorkermanMySQLPool('host', 'username', 'password', 'database');
};

$worker->onMessage = function($connection, $data) {
    $GLOBALS['db']->pop(function($db) use ($connection) {
        $res = $db->query('SELECT * FROM users');
        if (!$res) {
            $connection->send('查詢失敗');
        } else {
            $connection->send(json_encode($res));
        }
        $db->push($db);
    });
};

Worker::runAll();

在上述代碼中，我們使用Workerman框架提供的連接池類WorkermanMySQLPool來創(chuàng)建連接池對(duì)象。在onMessage回調(diào)函數(shù)中，使用$GLOBALS['db']->pop方法從連接池中獲取一個(gè)連接，然后執(zhí)行查詢操作。最后使用$db->push

3. SQL ??? ??

MySQL ??? ??? ? MySQL ?? ??? ???? SQL ???? ??? ? ????. ??? ??? ????.

rrreee

? ????? Worker ??? onMessage ?? ???? ?? ?? ???? users?? ???? ?? ???? ??????. ??? ???? "Query failed"? ????, ??? ??? ?? ??? json_encode ??? ???? ????? ?????? ?????. ??????? ??? ?? ????. ?? ?? ??????? ??, ????, ?? ? ?? ??? ?? ?? ??? ?? ??? SQL ?? ??? ? ????. ????4. ?? ? ?????????? ???? ???????? ?? ?? ?????? ??? ????? ? ?? ?????. Workerman ?????? MySQL ??? ????? ???? ???? ? ?? MySQL ?? ??? ?????. ??????? ?? ??? ??? ?? ?????. ??rrreee??? ????? Workerman ??????? ???? ?? ? ??? WorkermanMySQLPool? ???? ?? ? ??? ??????. onMessage ?? ???? $GLOBALS['db']->pop ???? ???? ?? ??? ??? ?? ? ?? ??? ?????. ????? $db->push ???? ???? ?? ???? ??? ? ??? ?? ?? ??? ?????. ????5. ?????? ?? ?? ?? Workerman?? ??? ??? ?? MySQL? ???? ??? ???????. ?? pecl install mysql ??? ?? MySQL ??? ??? ?? MySQL? ??? ???? SQL ?? ?? ???? ???. ???? ?? ?? ?? ?? ???? ?????? ??? ???? ?? ????. ? ?? ????? ??? ??? ???, Workerman? ???? ???? ??????? ??? ? ??? ??? ??? ?????. ??

? ??? Workerman?? ??? ??? ?? MySQL? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!