PHP 스울을 사용하는 방법

프로젝트에서는 PHP를 사용했지만 시간이 오래 걸리고 작업이 오래 걸리기 때문에 프런트 엔드가 제출된 후 서버가 비동기적으로 응답해야 합니다.

MQ, fsocket, Swoole 등을 포함하여 서버 비동기를 위한 많은 솔루션이 있습니다. (추천 학습: swoole 비디오 튜토리얼 )

Swoole은 순수 C 언어로 작성되었으며 PHP 언어로 비동기 멀티 스레드 서버, 비동기 TCP/UDP 네트워크 클라이언트, 비동기 MySQL, 비동기 Redis, 데이터베이스 연결 풀, AsyncTask, 메시지 큐, 밀리초 타이머, 비동기 파일 읽기 및 쓰기, 비동기 DNS 쿼리. Swoole에는 Http/WebSocket 서버/클라이언트 및 Http2.0 서버가 내장되어 있습니다.

가장 중요한 것은 PHP 언어를 완벽하게 지원한다는 점입니다. 그래서 저는 Swoole을 사용하여 비동기 응답, 푸시, 예약 작업과 같은 일련의 작업을 제공하는 비동기 서버를 구축했습니다.

Swoole은 C언어로 작성되어 컴파일되어 설치됩니다.

설치 종속성은:

php-5.3.10 或更高版本
gcc-4.4 或更高版本

make
autoconf
pcre (centos系统可以执行命令：yum install pcre-devel)

설치 방법:

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

컴파일이 완료된 후 php.ini

extension=swoole.so

server

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

클라이언트에 확장을 추가해야 합니다.

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

위 내용은 PHP 스울을 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!