Wie man Workerman mit tp zusammenbringt

Laden Sie workerman herunter und fügen Sie es in thinkphp ein. Beachten Sie, dass es sich auf der gleichen Ebene wie Home befindet und workerman als Modul behandelt. Geben Sie das Verzeichnis Home/Controller ein und erstellen Sie eine neue WorkermanController.class.php. (Empfohlene Studie: Workerman-Tutorial )

Hier führe ich ihn als Daemon-Prozess aus, Sie können die Zeile daemonize = entfernen WAHR.

<?php
namespace Home\Controller;
use Workerman\Worker;
/**
 * 用户信息查询
 */
class WorkermanController{
    /**
    * 用户信息查询
    */
    public function index(){
        if(!IS_CLI){
            die("access illegal");
        }
        require_once APP_PATH.&#39;Workerman/Autoloader.php&#39;;
        define(&#39;MAX_REQUEST&#39;, 1000);// 每个进程最多执行1000个请求
        Worker::$daemonize = true;//以守护进程运行
        Worker::$pidFile = &#39;/data/wwwlogs/Worker/workerman.pid&#39;;//方便监控WorkerMan进程状态
        Worker::$stdoutFile = &#39;/data/wwwlogs/Worker/stdout.log&#39;;//输出日志, 如echo，var_dump等
        Worker::$logFile = &#39;/data/wwwlogs/Worker/workerman.log&#39;;//workerman自身相关的日志，包括启动、停止等,不包含任何业务日志
        $worker = new Worker(&#39;text://172.16.0.10:10024&#39;);//此处我使用内网ip
        $worker->name = &#39;Worker&#39;;
        $worker->count = 2;
        //$worker->transport = &#39;udp&#39;;// 使用udp协议，默认TCP
        $worker->onWorkerStart = function($worker){
            echo "Worker starting...\n";
        };
        $worker->onMessage = function($connection, $data){
            static $request_count = 0;// 已经处理请求数
            //$_rs=D("Article")->gettest();
            $_articleObj=A("article");
            $_rs=$_articleObj->gettest();
            var_dump($_rs);
            $connection->send("hello");
            /*
             * 退出当前进程，主进程会立刻重新启动一个全新进程补充上来，从而完成进程重启
             */
            if(++$request_count >= MAX_REQUEST){// 如果请求数达到1000
                Worker::stopAll();
            }
        };
        $worker->onBufferFull = function($connection){
            echo "bufferFull and do not send again\n";
        };
        $worker->onBufferDrain = function($connection){
            echo "buffer drain and continue send\n";
        };
        $worker->onWorkerStop = function($worker){
            echo "Worker stopping...\n";
        };
        $worker->onError = function($connection, $code, $msg){
            echo "error $code $msg\n";
        };
        // 运行worker
        Worker::runAll();
    }
}

Ändern Sie den Workerman/Worker.php-Quellcode und suchen Sie die parseCommand()-Methode. Für workererman Version 3.3.2 ändern Sie in Zeile 586 die Befehlszeilenerkennungssyntax:

<?php
protected static function parseCommand()
{
    global $argv;
    // Check argv;
    $start_file = $argv[0];
    if (!isset($argv[2])) { //修改了此处
       exit("Usage: php yourfile.php Controller/Action {start|stop|restart|reload|status|kill}\n");//修改了此处提示
    }
    // Get command.
    $command  = trim($argv[2]);//修改了此处
    $command2 = isset($argv[3]) ? $argv[3] : &#39;&#39;;//修改了此处
   ....
}

OK, jetzt bist du fertig.

Unter der Linux-Befehlszeile ausführen. Beachten Sie, dass Sie hier zum Thinkphp-Stammverzeichnis wechseln müssen

Das obige ist der detaillierte Inhalt vonWie man Workerman mit tp zusammenbringt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!