swoole 第7次课荷塘墨画：io复用与信号模型2

信号模型

4.理解信号

41）查看liinux信号 kill -l

信号列表及意义：https://wiki.swoole.com/#/other/signal?id=linux-信号列表

使用 kill 信号主进程PID 如下，kill -10 11830 ，重启了workers

42）信号函数

pcntl_signal 安装信号https://php.golaravel.com/function.pcntl-signa.html

posix_kill 绑定信号https://php.golaravel.com/function.posix-kill.html

pcntl_signal_dispatch 发送信号https://php.golaravel.com/function.pcntl-signa-dispatch.html

43）程序设置信号的流程

44）客户端Xshell等kill命令信号的流程

45）理解信号函数

小试牛刀

iostarjhy\test\signal\signal.php

<?php

function sig_handler($sig){
    var_dump($sig);
    echo "信号操作\n";
}

//绑定信号及触发方法（处理方法）
pcntl_signal(SIGIO,"sig_handler");
//SIGIO :描述符上可以进行 I/O 操作

//绑定进程和信号
posix_kill(posix_getpid(),SIGIO);

echo "kl\n";

//分发
pcntl_signal_dispatch();

运行

5实现信号模型

基类 iostarjhy\src\WorkerBase.php ,同上,略

信号实现类iostarjhy\src\Signal\Worker.php

<?php
namespace IoStarJhy\Signal;

use IoStarJhy\WorkerBase;

class Worker extends WorkerBase {

public function accept()
    {
//建立并挂起连接，可接受多次信息（而不是一次就关闭服务）
while(true){
//监听是否存在连接
$conn = stream_socket_accept($this->server);
            if(!empty($conn)){
//触发建立连接事件
$this->events['connect']($this,$conn);
}
//绑定信号及触发方法（处理方法）
pcntl_signal(SIGIO,$this->sigHandler($conn));
//绑定进程和信号
posix_kill(posix_getpid(),SIGIO);
//分发
pcntl_signal_dispatch();
}
    }

public function sigHandler($conn)
    {
return function($sig) use($conn){
switch($sig){
case SIGIO;
$this->sendMessage($conn);
                    break;
}
        };
}

public function sendMessage($conn)
    {
//接收服务的信息
$data = fread($conn, 65535);
        if($data === '' || false === $data){
$this->checkConn($data, $conn);
}else{
$this->events['receive']($this, $conn, $data);
}
    }
//检验连接
protected function checkConn($buffer,$conn){
if(strlen($buffer) === 0){
if(! \get_resource_type($conn) == "Unknown"){
//断开连接
$this->close($conn);
}
            call_user_func($this->events['close'],$this,$conn);
            unset($this->sockets[(int) $conn]);
}
    }
}

测试服务端 iostarjhy\test\signal\server.php

<?php
require_once __DIR__."/../../vendor/autoload.php";

use IoStarJhy\Signal\Worker;

$server = new Worker('0.0.0.0',9500);

$server->on('connect',function($server,$client){
  dd($client,"客户端建立连接成功");
});
$server->on('receive',function(Worker $server,$client,$data){
    dd($data,'处理客户端的数据');
$server->send($client,'hello client');
//$server->close($client);
});
$server->on('close',function(Worker $server,$client){
    dd($client,'断开连接');
//$server->close($client);
});

$server->start();

测试客户端iostarjhy\test\signal\client.php

<?php
require_once __DIR__ . "/../../vendor/autoload.php";

//连接服务端
$fp = stream_socket_client("tcp://192.168.204.168:9500");

fwrite($fp, "hello server1");
dd(fread($fp, 65535));

运行结果

至此，信号模型已实现通信了

说明：信号模型主要用于框架中服务的重启，重加载及不同进程间的通讯，而不是用于写模型的。

附：

问题：为什么阻塞模型不能进行两次通信？

receive后，进行下一轮，stream_socket_accept去监听新的连接了，上一个连接再发信息也没用了

完

发表于 2020-12-26 17:40
阅读 ( 750 )

swoole 第7次课荷塘墨画：io复用与信号模型2

你可能感兴趣的文章

相关问题

0 条评论

作家榜 »

swoole 第7次课 荷塘墨画：io复用与信号模型2

你可能感兴趣的文章

相关问题

0 条评论

作家榜 »

swoole 第7次课荷塘墨画：io复用与信号模型2