在php中使用swoole扩展时，server端的回调函数中如何使用thinkphp框架的方法？-php教程-PHP中文網

首頁

後端開發

php教程

在php中使用swoole扩展时，server端的回调函数中如何使用thinkphp框架的方法？

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 06, 2016 pm 08:40 PM

phpswoolethinkphp

<code><?php class MySQLPool
{
    private $serv;
    private $pdo;

    public function __construct() {
        $this->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();
</code>

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

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

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

回复内容：

<code><?php class MySQLPool
{
    private $serv;
    private $pdo;

    public function __construct() {
        $this->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();
</code>

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

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

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

可以用ThinkPHP。Swoole就是一个标准的PHP扩展，只要符合PHP的语法都可以执行。

陳述

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

workerman和swoole性能谁更好？如何选择？Dec 01, 2022 am 10:00 AM

workerman 对比 swoole 实际开发项目中，你会选择哪个？对于新手学哪个较好，有什么建议吗？

swoole和go选哪个？优缺点分析Mar 27, 2023 pm 03:29 PM

在现代的应用开发中，异步编程在高并发场景下变得越来越重要。Swoole和Go是两个非常流行的异步编程框架，它们都具有高效的异步能力，但是很多人在选择使用哪个框架时会陷入困境。本文将探讨如何选择Swoole和Go，以及它们的优缺点。

swoole怎么学？学会要多久？Mar 27, 2023 pm 03:29 PM

你学会 Swoole 需要多久呢？这个问题其实非常难回答，因为它涉及到很多因素，比如你的编程基础、学习动力、时间安排等等。不过，在这篇文章中，我将分享一些我自己学习 Swoole 的经验和建议，希望能够对你有所帮助。

探讨一下web服务器为什么不用swooleMar 27, 2023 pm 03:29 PM

Swoole是一个基于PHP的开源高性能网络通信框架，它提供了TCP/UDP服务器和客户端的实现，以及多种异步IO、协程等高级特性。随着Swoole日益流行，许多人开始关心Web服务器使用Swoole的问题。为什么当前的Web服务器（如Apache、Nginx、OpenLiteSpeed等）不使用Swoole呢？让我们探讨一下这个问题。

聊聊怎么在docker中搭建swoole环境Jun 28, 2022 pm 09:02 PM

怎么在docker中搭建swoole环境？下面本篇文章给大家介绍一下用docker搭建swoole环境的方法，希望对大家有所帮助！

php如何让Swoole/Pool进程池实现Redis持久连接May 27, 2023 pm 05:55 PM

php让Swoole|Pool进程池实现Redis持久连接进程池，基于Swoole\Server的Manager管理进程模块实现。可管理多个工作进程，相比Process实现多进程，Process\Pool更加简单，封装层次更高，开发者无需编写过多代码即可实现进程管理功能，配合Co\Server可以创建纯协程风格的，能利用多核CPU的服务端程序。Swoole进程池实现redis数据读取如下案例，通过WorkerStart启动Redis进程池，并持久读取Redis列表数据；当WorkerStop断开