serv = new swoole_server("0.0.0.0", 9501); $this->serv->set(array( 'worker_num' => 8, 'daemonize' => false, 'max_request' => 10000, 'dispatch_mode' => 3, 'debug_mode'=> 1 , 'task_worker_num' => 8 )); $this->serv->on('WorkerStart', array($this, 'onWorkerStart')); $this->serv->on('Connect', array($this, 'onConnect')); $this->serv->on('Receive', array($this, 'onReceive')); $this->serv->on('Close', array($this, 'onClose')); // bind callback $this->serv->on('Task', array($this, 'onTask')); $this->serv->on('Finish', array($this, 'onFinish')); $this->serv->start(); } public function onWorkerStart( $serv , $worker_id) { echo "onWorkerStart\n"; // 判定是否为Task Worker进程 if( $worker_id >= $serv->setting['worker_num'] ) { $this->pdo = new PDO( "mysql:host=localhost;port=3306;dbname=Test", "root", "123456", array( PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'UTF8';", PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, PDO::ATTR_PERSISTENT => true ) ); } } public function onConnect( $serv, $fd, $from_id ) { echo "Client {$fd} connect\n"; } public function onReceive( swoole_server $serv, $fd, $from_id, $data ) { $sql = array( 'sql'=>'Insert into Test values( pid = ?, name = ?)', 'param' => array( 0 , "'name'" ), 'fd' => $fd ); $serv->task( json_encode($sql) ); } public function onClose( $serv, $fd, $from_id ) { echo "Client {$fd} close connection\n"; } public function onTask($serv,$task_id,$from_id, $data) { try{ $sql = json_decode( $data , true ); $statement = $this->pdo->prepare($sql['sql']); $statement->execute($sql['param']); $serv->send( $sql['fd'],"Insert"); return true; } catch( PDOException $e ) { var_dump( $e ); return false; } } public function onFinish($serv,$task_id, $data) { } } new MySQLPool();

这里mysql链接什么的如果使用thinkphp中的数据该怎么来？

如何引用？include_once 'core/ThinkPHP.php';这样的方式能否使用？

另外一点就是server 必须使用命令行方式 当宕机的时候在windows中如何开启他？