- 使用Mysql ~~~ $db = new \Workerman\MySQL\Connection('host', 'port', 'user', 'password', 'db_name'); $db->query("SELECT ID,Sex FROM `Persons` WHERE sex='M' AND ID = 1"); $db->row("SELECT ID,Sex FROM `Persons` WHERE sex='M'"); 一行數據 $db->column("SELECT `ID` FROM `Persons` WHERE sex='M'"); 一列數據 $db->single("SELECT ID FROM `Persons` WHERE sex='M'"); 單個值 $db->beginTrans();事務開始 $db->commitTrans(); // or $db->rollBackTrans(); 回滾或提交 其余操作用使用 query即可 use \Workerman\Worker; //use \Workerman\Lib\Timer; require_once __DIR__ . '/Workerman/Autoloader.php'; require_once __DIR__ . '/Workerman/Mysql.php'; $worker = new Worker("http://0.0.0.0:2345"); // 開啟多少個進程運行定時任務，注意業務是否在多進程有并發問題 $worker->count = 1; $worker->onWorkerStart = function($worker) { global $db; $db = new \Workerman\MySQL\Connection('127.0.0.1', '3306', 'root', 'mysql', 'laravel'); }; $worker->onMessage = function($connection, $data) { // 通過全局變量獲得db實例 global $db; // 執行SQL $all_tables = $db->query('select * from users'); $connection->send(dump($all_tables)); }; // 運行worker Worker::runAll(); ~~~ - 定時器加心跳 ~~~ require_once __DIR__ . '/Workerman/Autoloader.php'; use Workerman\Worker; use Workerman\Lib\Timer; // 心跳間隔55秒 define('HEARTBEAT_TIME', 55); $worker = new Worker('text://0.0.0.0:1234'); $worker->onMessage = function($connection, $msg) { // 給connection臨時設置一個lastMessageTime屬性，用來記錄上次收到消息的時間 $connection->lastMessageTime = time(); // 其它業務邏輯... }; // 進程啟動后設置一個每秒運行一次的定時器 $worker->onWorkerStart = function($worker) { Timer::add(1, function()use($worker){ $time_now = time(); foreach($worker->connections as $connection) { // 有可能該connection還沒收到過消息，則lastMessageTime設置為當前時間 if (empty($connection->lastMessageTime)) { $connection->lastMessageTime = $time_now; continue; } // 上次通訊時間間隔大于心跳間隔，則認為客戶端已經下線，關閉連接 if ($time_now - $connection->lastMessageTime > HEARTBEAT_TIME) { $connection->close(); } } }); }; Worker::runAll(); ~~~ - 定時任務處理隊列 ~~~ use \Workerman\Worker; use \Workerman\Lib\Timer; require_once __DIR__ . '/Workerman/Autoloader.php'; require_once __DIR__ . '/Workerman/Mysql.php'; $worker = new Worker(); // 開啟多少個進程運行定時任務，注意業務是否在多進程有并發問題 $worker->count = 4; $worker->onWorkerStart = function($worker) { global $db,$redis; $db = new \Workerman\MySQL\Connection('127.0.0.1', '3306', 'root', 'mysql', 'laravel'); $redis = new Redis(); $redis->connect('127.0.0.1', 6379); if($worker->id == 0)//只在第一個上邊使用定時 { Timer::add(5, function(){ global $redis; while(true) { $res = $redis->rpop("sendsms"); if ($res) { $arr = unserialize($res);//取出隊列 echo '取出成功'.date("Y-m-d H:i:s")."\n"; } else { return; } } }); } }; // 運行worker Worker::runAll(); ~~~