swoole 第6次课-2 含毫命简：阻塞与非阻塞
阻塞与非阻塞
1.回顾阻塞模型
11)手写网络模型，实现的目录结构
12）当前目录网络结构
根据以上，建立对应文件
13）六个用到的函数
实质，服务端与客户端，是通过 stream_socket_accept连接的，即stream_socket_client---->stream_socket_accept--->stream_socket_server
14)回顾阻塞模型
客户请求服务获取信息的本质过程,对于服务来说：
(1). 连接 ( 2). 响应请求(就是执行相应的代码)
2构建基础 worker结构（工程结构）
21）补充：上节服务端即 iostarjhy\test\swoole\tcpserver2.php中，为什么要while循环？我们改成如下
<?php
//建立协议服务
$socket = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr);
//创建服务和客户和客户连接的socket stream_socket_accept
if (!$socket) {
echo "$errstr ($errno)<br />\n";
} else {
//while 循环，可多次连接
/*while ($conn = stream_socket_accept($socket)) {
fwrite($conn, 'The local time is ' . date('n/j/Y g:i a') . "\n");
fclose($conn);
}
fclose($socket);*/
//while改成以下，无法做到多次连接
$conn = stream_socket_accept($socket);
fwrite($conn, 'The local time is ' . date('n/j/Y g:i a') . "\n");
fclose($conn);
//网络上的通常做法，while(ture)
/* while(true){ //始终监测 是否有信息发过来
$conn = stream_socket_accept($socket);
var_dump(fread($conn,65535));
fwrite($conn, 'The local time is ' . date('n/j/Y g:i a') . "\n");
fclose($conn);
}*/
}
客户端：iostarjhy\test\swoole\clinet2.php同上节，如下
<?php
//连接服务端
$client = new Swoole\Client(SWOOLE_SOCK_TCP );
if (!$client->connect('127.0.0.1', 8000, -1)) {
exit("connect failed. Error: {$client->errCode}\n");
}
$client->send("hello world\n");
/*$client->send("hello world\n");
$client->send("hello world\n");
$client->send("hello world\n");*/
echo $client->recv();
$client->close();
运行如下
可见，$conn = stream_socket_accept($socket);可连接一次，服务端就关闭了，再次运行客户端，提示说服务端关闭了。
通常，网络上还有while（true）的做法（见iostarjhy\test\swoole\tcpserver2.php中最下面注释），就是实现多次连接，切换注释，运行结果如下：
22）思路分析
221）基于客户请求服务获取信息的本质过程，服务具备的功能及方法
222）构建基础服务结构，基础类workbase,实现的基本功能
整个IoStar,基于这个workBase,最终结构如下：
23）创建基类 iostarjhy\src\WorkerBase.php
<?php
namespace IoStarJhy;
abstract class WorkerBase
{
protected $server;
protected $events=[];
protected $config;
protected $typc="tcp";
public function __construct($host,$port){
$this->server = stream_socket_server("tcp://".$host.":".$port);
echo "tcp://".$host.":".$port."\n";
}
/**
* 不同的模型实现不一样
* @var [type]
*/
protected abstract function accept();
/**
* 添加事件
* @method on
* @param [type] $event [description]
* @param [type] $call [description]
* @return [type] [description]
*/
public function on($event,$call){
$this->events[strtolower($event)] = $call;
}
public function set(){}
/**
* 发送信息
* @method send
* @param [type] $client [description]
* @param [type] $data [description]
* @return [type] [description]
*/
public function send($client,$data)
{
}
public function start()
{
var_dump($this->events);
$this->accept();
}
public function close()
{
}
}
iostarjhy\src\Blocking\Worker.php
<?php
namespace IoStarJhy\Blocking;
use IoStarJhy\WorkerBase;
class Worker extends WorkerBase {
public function accept()
{
}
}
测试iostarjhy\test\Blocking\server.php
<?php
require_once __DIR__."/../../vendor/autoload.php";
use IoStarJhy\Blocking\Worker;
$server = new Worker('0.0.0.0',9500);
$server->on('connect',function($server,$client){
});
$server->on('receive',function($server,$client,$data){
});
$server->on('close',function($server,$client){
});
$server->start();
运行，可以看到各事件已注册了
24）为方便测试，增加个调试的助手函数 dd($message, $description)
241）iostarjhy\src\Support\Helper.php
<?php
function dd($message, $description = null)
{
echo "======>>> ".$description." start\n";
if (\is_array($message)) {
echo \var_export($message, true);
} else if (\is_string($message)) {
echo $message."\n";
} else {
var_dump($message);
}
echo "======>>> ".$description." end\n";
}
242)修改 iostarjhy\composer.json 就是在autoload的属性对象中增加 files属性，指示助手函数地址
{
"name": "jhy/iostarjhy",
"type": "library",
"authors": [
{
"name": "jhy",
"email": "1195863294@qq.com"
}
],
"autoload": {
"psr-4": {
"IoStarJhy\\": "src"
},
"files":[
"src/Support/Helper.php"
]
},
"require": {}
}243)命令更新，但最好用 composer dumpautoload
D:\phpstudy_pro\WWW\swoole_2006\iostarjhy>composer update
244)上传代码到服务器
245）使用测试
iostarjhy\src\WorkerBase.php的 __construct()及start()方法，改造如下：
public function __construct($host,$port){
$this->server = stream_socket_server("tcp://".$host.":".$port);
//echo "tcp://".$host.":".$port."\n";
dd("tcp://".swoole_get_local_ip()['ens33'].":".$port,"创建手写的worker服务");
}
public function start()
{
//var_dump($this->events);
dd($this->events,"启动后，输出服务的注册事件");
$this->accept();
}
运行
未完，见swoole 第6次课-2 含毫命简：阻塞与非阻塞2
- 发表于 2020-12-15 10:37
- 阅读 ( 1051 )
- 分类：swoole
