>PHP 프레임워크 >Swoole >Swoole은 왜 시작했다가 포기하게 되었나요?

Swoole은 왜 시작했다가 포기하게 되었나요?

coldplay.xixi
coldplay.xixi앞으로
2020-12-09 17:37:263669검색

swoole 튜토리얼시작부터 포기까지의 이유

Swoole은 왜 시작했다가 포기하게 되었나요?

추천(무료): swoole 튜토리얼

1 swoole 소스 패키지 설치

  1. 다운로드: git clone https: //gitee.com/swoole/swoole.gitgit clone https://gitee.com/swoole/swoole.git
  2. 通过phpize(扩展php扩展模块,建立php外挂模块):

    • cd swoole
    • 执行:your/phpize/path
    • ./configure --with-php-config=your/php/path/bin/php-config
    • make && make install
  3. 可以看到swoole.so的位置

    • 我的位置是:/opt/soft/php/lib/php/extensions/no-debug-non-zts-20170718/
  4. 配置php.ini

    • 添加extension=swoole.so
  5. 通过php -m命令,可以看到php的扩展模块
  6. 检测swoole安装成功并且php支持swoole

    • cd your/swoole/path/examples/server
    • php echo.php(如果进程被阻塞,则说明成功)
    • netstat -anp | grep 9501
    phpize를 통해(PHP 확장 모듈 확장, PHP 플러그인 모듈 생성):

cd swoole

실행: your/phpize/path
./configure --with-php-config=your/php/path/bin/php-config

make && make install

swoole.so의 위치를 ​​볼 수 있습니다

  • 내 위치는 /opt/soft/php/lib/php/extensions/no-debug-non입니다. -zts-20170718 /
    php.ini 설정
  • extension=swoole.so
  • 추가 php -m 를 통해 보실 수 있습니다 명령 php
  • 의 확장 모듈은 swoole이 성공적으로 설치되었는지 감지하고 php가 swoole
  • cd your/swoole/path/examples/serverphp echo를 지원하는지 감지합니다. .php (프로세스가 차단되면 성공)
netstat -anp | grep 9501 (swoole이 열어놓은 포트번호 확인)
ps aft | grep tcp_server.php

2. 네트워크 통신 엔진

Swoole을 배우려면 설명서를 읽어야 합니다. swoole 문서

1 swoole


tcp 서버(tcp_server.php)

//创建Server对象,监听 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501);

$serv->set([
    'worker_num' => 4, // worker进程数,cpu 1-4倍
    'max_request' => 100,
]);

/**
 * 监听连接进入事件
 * $fd 客户端连接服务端的唯一标识
 * $reactor_id 线程id
 */
$serv->on('connect', function ($serv, $fd, $reactor_id) {
    echo "Client: {$fd} - {$reactor_id} - Connect.\n";
});

//监听数据接收事件
$serv->on('receive', function ($serv, $fd, $reactor_id, $data) {
    $serv->send($fd, "Server: ".$data);
});

//监听连接关闭事件
$serv->on('close', function ($serv, $fd) {
    echo "Client: Close.\n";
});

//启动服务器
$serv->start();

tcp 클라이언트(tcp_client.php)
// 创建tcp客户端
$client = new swoole_client(SWOOLE_SOCK_TCP);

// 连接tcp服务端
if (!$client->connect("127.0.0.1", 9501)) {
    echo '连接失败';
    exit;
}

// php cli
fwrite(STDOUT, '请输入:');
$msg = trim(fgets(STDIN));

// 发送消息给tcp服务端
if (!$client->send($msg)) {
    echo '发送消息失败';
    exit;
}

// 接收
$result = $client->recv();
echo $result;
2를 통해 가장 간단한 tcp 서비스 만들기 2. php의 4가지 콜백

익명 기능


$server->on('Request', function ($req, $resp) {
    echo "hello world";
});

class static method
class A
{
    static function test($req, $resp)
    {
        echo "hello world";
    }
}
$server->on('Request', 'A::Test');
$server->on('Request', array('A', 'Test'));
function🎜🎜🎜
function my_onRequest($req, $resp)
{
    echo "hello world";
}
$server->on('Request', 'my_onRequest');
🎜🎜🎜object method🎜🎜🎜
class A
{
    function test($req, $resp)
    {
        echo "hello world";
    }
}

$object = new A();
$server->on('Request', array($object, 'test'));
🎜🎜작은 팁: 🎜열린 작업자 프로세스를 확인하세요. 🎜🎜🎜 🎜3. UDP 서버 클라이언트는 설명서🎜🎜🎜4. http service🎜
// 监听所有地址和9501端口
$http = new swoole_http_server('0.0.0.0', 9501);

// 动静分离配置
$http->set([
    // 开启静态请求
    'enable_static_handler' => true,
    // 静态资源目录
    'document_root' => '/opt/app/code1/',
]);

$http->on('request', function ($request, $response) {
    // 获取get请求的参数
    $param = json_encode($request->get);
    // 设置cookie
    $response->cookie('name', 'ronaldo', time() + 1800);
    // 输出到页面
    $response->end("<h1>Hello Swoole - {$param}</h1>");
});

// 开启http服务
$http->start();
🎜🎜5에 따라 직접 만들 수 있습니다. swoole🎜🎜websocket 서버(websocket_server.php)🎜
// 监听所有地址和9502端口
$server = new swoole_websocket_server('0.0.0.0', 9502);

// 动静分离配置
$server->set([
    // 开启静态请求
    'enable_static_handler' => true,
    // 静态资源目录
    'document_root' => '/opt/app/swoole/websocket',
]);
$server->on('open', function ($server, $request) {
    echo "server:handshake success with fd - {$request->fd}\n";
});

$server->on('message', function ($server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
    $server->push($frame->fd, "this is server");
});

$server->on('close', function ($server, $fd) {
    echo "client - {$fd} - close\n";
});

$server->start();
🎜websocket 클라이언트(websockt_client.html)🎜
// 创建websocket实例
        var websocketURL = "ws://www.rona1do.top:9502";
        var websocket = new WebSocket(websocketURL);

        // 实例化对象的onopen属性
        websocket.onopen = function (ev) {
            websocket.send("hello-websocket");
            console.log("connect-swoole-success");
        }

        // 实例化对象的onmessage属性,接收服务端返回的数据
        websocket.onmessage = function (ev) {
            console.log("websockect-server-return-data:" + ev.data);
        }

        // close
        websocket.onclose = function (ev) {
            console.log("close");
        }
를 통해 웹소켓 서비스를 만듭니다. 🎜🎜6. 객체 지향을 사용하여 웹소켓 서비스 코드 최적화🎜
class WebSocket {
    const HOST = '0.0.0.0';
    const PORT = 9502;

    private $ws = null;

    function __construct()
    {
        $this->ws = new swoole_websocket_server(self::HOST, self::PORT);
        $this->ws->on('open', [$this, 'onOpen']);
        $this->ws->on('message', [$this, 'onMessage']);
        $this->ws->on('close', [$this, 'onClose']);
        $this->ws->start();
    }

    // 监听websocket连接事件
    function onOpen($server, $request) {
        echo "server: handshake success with fd{$request->fd}\n";
    }

    // 监听websocket消息接收事件
    function onMessage($server, $frame) {
        echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
        $server->push($frame->fd, "this is server");
    }

    // 监听客户端关闭事件
    function onClose($server, $fd) {
        echo "Client:{$fd} closes\n";
    }
}
🎜🎜7. swoole🎜🎜🎜onTask의 작업 소규모 사례: 🎜는 task_worker 프로세스 내에서 호출됩니다. 작업자 프로세스는 swoole_server_task 함수를 사용하여 task_worker 프로세스에 새 작업을 전달할 수 있습니다. 현재 작업 프로세스가 onTask 콜백 함수를 호출하면 프로세스 상태가 사용 중으로 전환되고 더 이상 새 작업을 수신하지 않습니다. onTask 함수가 반환되면 프로세스 상태를 유휴 상태로 전환하고 새 작업을 계속 수신합니다. 🎜🎜🎜onFinish: 🎜작업자 프로세스가 전달한 작업이 task_worker에서 완료되면 작업 프로세스는 swoole_server->finish() 메서드를 통해 작업 처리 결과를 작업자 프로세스로 보냅니다. 🎜아아아아

위 내용은 Swoole은 왜 시작했다가 포기하게 되었나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
이 기사는 csdn.net에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제