PHP에서 Swoole을 사용하는 방법

php에서 swoole을 어떻게 사용하나요?

php Swoole의 기본 사용법

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

MQ, fsocket, Swoole 등을 포함하여 서버 비동기를 위한 다양한 솔루션이 있습니다.

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

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

Installation

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

Use

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) {
      //做一些事情
 
    }

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(
            '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";
    }
 
}

문제에 주의하세요

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

이것은 프레임 구분을 정의하는 것입니다. 왜냐하면 Swoole의 클라이언트 클라이언트와 서버 간의 통신은 TCP 연결이므로 프레임 구분 기호가 제공되어야 합니다. 자세한 내용은 Swoole 공식 문서를 참조하세요. 머리로 길이를 추가하는 방법은 다음과 같습니다.

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