<?php
use \GatewayWorker\Lib\Gateway;
use \Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
use \Applications\YourApp\Controller\MyWm;
use \Applications\YourApp\Database\MySql; 
require_once __DIR__.'/../Function/functions.php';  
class Admin extends MyWm{
    public function verify($args,$client_id)
    {
        $id             =       $args;  
        $onlinetime     =       $args;
        $db             =       new MySql();
        $sql            =       "select title,publishtime,content,price,
        img from tbl_order_content where id=$id";
        $info           =       $db->get_one($sql);

             **這里不用一步的話(huà)會(huì)阻塞主干道，怎么使用異步AsyncTcpConnection，在異步里操作數(shù)據(jù)庫(kù)**
    }
}
?>

上面是我的控制器

手冊(cè)里的解析：

use \Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
require_once './Workerman/Autoloader.php';

$task = new Worker();
// 進(jìn)程啟動(dòng)時(shí)異步建立一個(gè)到www.baidu.com連接對(duì)象，并發(fā)送數(shù)據(jù)獲取數(shù)據(jù)
$task->onWorkerStart = function($task)
{
    $connection_to_baidu = new AsyncTcpConnection('tcp://www.baidu.com:80');
    // 當(dāng)連接建立成功時(shí)，發(fā)送http請(qǐng)求數(shù)據(jù)
    $connection_to_baidu->onConnect = function($connection_to_baidu)
    {
        echo "connect success\n";
        $connection_to_baidu->send("GET / HTTP/1.1\r\nHost: www.baidu.com\r\nConnection: keep-alive\r\n\r\n");
    };
    $connection_to_baidu->onMessage = function($connection_to_baidu, $http_buffer)
    {
        echo $http_buffer;
    };
    $connection_to_baidu->onClose = function($connection_to_baidu)
    {
        echo "connection closed\n";
    };
    $connection_to_baidu->onError = function($connection_to_baidu, $code, $msg)
    {
        echo "Error code:$code msg:$msg\n";
    };
    $connection_to_baidu->connect();
};

// 運(yùn)行worker
Worker::runAll();

問(wèn)題：怎么整合起來(lái)，求大大給我一個(gè)案例我參考一下就好了?；蛘吆?jiǎn)單的即行偽代碼也可以。