Comment utiliser Swoole en PHP-Swoole-php.cn

Comment utiliser Swoole en PHP

藏色散人

Libérer： 2020-04-09 10:04:28

original

4921 Les gens l'ont consulté

Comment utiliser swoole en php ?

php Swoole est essentiellement utilisé dans

PHP utilisé dans le projet, mais en raison de tâches longues et fastidieuses, après la soumission du front-end, le serveur doit répondre de manière asynchrone.

Il existe de nombreuses solutions pour les serveurs asynchrones, notamment MQ, fsocket, Swoole, etc.

Swoole est écrit en langage C pur et fournit un serveur multithread asynchrone en langage PHP, un client réseau TCP/UDP asynchrone, MySQL asynchrone, Redis asynchrone, un pool de connexions à la base de données, AsyncTask, une file d'attente de messages, un minuteur en millisecondes, asynchrone. lecture et écriture de fichiers, requête DNS asynchrone. Swoole a un serveur/client Http/WebSocket intégré et un serveur Http2.0.

Le plus important est qu'il supporte parfaitement le langage PHP. J'ai donc utilisé Swoole pour créer un serveur asynchrone afin de fournir une série de tâches telles que des réponses asynchrones, des tâches push et planifiées.

Installation

Swoole est écrit en langage C et utilise la compilation et l'installation.

Les dépendances d'installation sont :

php-5.3.10 ou version supérieure

gcc-4.4 ou version supérieure

make
autoconf

Copier après la connexion

pcre (système centos Vous pouvez exécutez la commande : yum install pcre-devel)

Méthode d'installation :

phpize #如果命令不存在 请在前面加上php的实际路径
./configure
make 
sudo make install

Copier après la connexion

Une fois la compilation terminée, vous devez ajouter l'extension

extension=swoole.so

Copier après la connexion

dans php.ini en utilisant

Serveur

class Server{
    private $serv;
    public function __construct() {
        $this->serv = new swoole_server("0.0.0.0", 9501);
        $this->serv->set(array(
 
            //&#39;worker_num&#39; => 1,  //一般设置为服务器CPU数的1-4倍
 
            &#39;daemonize&#39; => 1,  //以守护进程执行
            &#39;max_request&#39; => 10000,
            &#39;task_worker_num&#39; => 1,  //task进程的数量
 
            "task_ipc_mode " => 3 ,  //使用消息队列通信，并设置为争抢模式
            &#39;open_length_check&#39;    => true,
            &#39;dispatch_mode&#39;        => 1,
 
            &#39;package_length_type&#39;  => &#39;N&#39;,  //这个很关键，定位包头的
            &#39;package_length_offset&#39; => 0,      //第N个字节是包长度的值
            &#39;package_body_offset&#39;  => 4,      //第几个字节开始计算长度
 
            &#39;package_max_length&#39;    => 2000000,  //协议最大长度
            "log_file" => "/tmp/swoole_test.log"  //日志
 
        ));
 
        $this->serv->on(&#39;Receive&#39;, array($this, &#39;onReceive&#39;));
        $this->serv->on(&#39;Task&#39;, array($this, &#39;onTask&#39;));
        $this->serv->on(&#39;Finish&#39;, array($this, &#39;onFinish&#39;));
        $this->serv->start();
 
    }
 
    public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {
 
        //放入任务队列，开始执行
        $task_id = $serv->task( $data );
 
    }
 
    public function onTask($serv,$task_id,$from_id, $data) {
      //做一些事情
 
    }

Copier après la connexion

Client

class Client{
 
    private $client, $ip, $port, $params;
 
    public function __construct($ip, $port, $params)
    {
 
        $this->ip = $ip;
        $this->port = $port;
        $this->params = $params;
 
        $this->client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
        $this->client->set(array(
            &#39;open_length_check&#39;    => true,
            &#39;package_length_type&#39;  => &#39;N&#39;,
            &#39;package_length_offset&#39; => 0,      //第N个字节是包长度的值
            &#39;package_body_offset&#39;  => 4,      //第几个字节开始计算长度
            &#39;package_max_length&#39;    => 2000000,  //协议最大长度
 
        ));
 
        //设置事件回调函数
 
        $this->client->on(&#39;Connect&#39;, array($this, &#39;onConnect&#39;));
        $this->client->on(&#39;Receive&#39;, array($this, &#39;onReceive&#39;));
        $this->client->on(&#39;Close&#39;, array($this, &#39;onClose&#39;));
        $this->client->on(&#39;Error&#39;, array($this, &#39;onError&#39;));
 
        //发起网络连接
        $this->client->connect($ip, $port, 3);
    }
 
    public function onReceive( $cli, $data ) {
        echo "Received: " . $data . "\n";
 
    }
 
    public function onConnect($cli) {
 
        $data = pack(&#39;N&#39;, strlen($data)) . $data;
        $cli->send($data);
        $cli->close();
 
    }
 
    public function onClose( $cli)
    {
        echo "Connection close\n";
    }
 
    public function onError()
    {
        echo "Connect failed\n";
    }
 
}

Copier après la connexion

Problèmes d'attention

&#39;open_length_check&#39;    => true,
&#39;package_length_type&#39;  => &#39;N&#39;,
&#39;package_length_offset&#39; => 0,      //第N个字节是包长度的值
&#39;package_body_offset&#39;  => 4,      //第几个字节开始计算长度
&#39;package_max_length&#39;    => 2000000,  //协长度

Copier après la connexion

Ceux-ci définissent la délimitation des trames, car la communication entre le client et le serveur de Swoole se fait via une connexion TCP, donc les délimiteurs de trame doivent être indiqués. Il existe plusieurs méthodes de délimitation de trame. Pour plus de détails, veuillez vous référer à la documentation officielle de Swoole. Voici une façon d’ajouter de la longueur avec la tête.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!