swoole使用4种服务器【tcp/udp/web/websocket】

TCP服务器

//创建Server对象，监听 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501);
//监听连接进入事件
$serv->on('connect', function ($serv, $fd) {
    echo "Client: Connect.\n";
});
//监听数据接收事件
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
    $serv->send($fd, "Server: ".$data);
});

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

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

UDP服务器

//创建Server对象，监听 127.0.0.1:9502端口，类型为SWOOLE_SOCK_UDP
$serv = new swoole_server("127.0.0.1", 9502, SWOOLE_PROCESS, SWOOLE_SOCK_UDP);

//监听数据接收事件
$serv->on('Packet', function ($serv, $data, $clientInfo) {
    $serv->sendto($clientInfo['address'], $clientInfo['port'], "Server ".$data);
    var_dump($clientInfo);
});

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

http服务器

$http = new swoole_http_server("0.0.0.0", 9501);
$http->on('request', function ($request, $response) {
    var_dump($request->get, $request->post);
    $response->header("Content-Type", "text/html; charset=utf-8");
    $response->end("<h1>Hello Swoole. #".rand(1000, 9999)."</h1>");
});
$http->start();

websocket服务器

服务器端：
//创建websocket服务器对象，监听0.0.0.0:9502端口 
$ws = new swoole_websocket_server(“0.0.0.0”, 9502);
//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
    $ws->push($request->fd, "hello, welcome\n");
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    $ws->push($frame->fd, "server: {$frame->data}");
});

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();
客户端JS：
var wsServer = 'ws://192.168.50.151:9502';
var websocket = new WebSocket(wsServer);
websocket.onopen = function (evt) {
    console.log("Connected to WebSocket server.");
};

websocket.onclose = function (evt) {
    console.log("Disconnected");
};

websocket.onmessage = function (evt) {
    console.log('Retrieved data from server: ' + evt.data);
};

websocket.onerror = function (evt, e) {
    console.log('Error occured: ' + evt.data);
};

辅助

定时器

//每隔2000ms触发一次

swoole_timer_tick(2000, function ($timer_id) {
    echo "tick-2000ms\n";
});

//3000ms后执行此函数
swoole_timer_after(3000, function () {
    echo "after 3000ms.\n";
});

异步tcp服务器处理任务

$serv = new swoole_server("127.0.0.1", 9501);
//设置异步任务的工作进程数量
$serv->set(array('task_worker_num' => 4));
$serv->on('receive', function($serv, $fd, $from_id, $data) {
//投递异步任务

    $task_id = $serv->task($data);
    echo "Dispath AsyncTask: id=$task_id\n";
});

//处理异步任务
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
    echo "New AsyncTask[id=$task_id]".PHP_EOL;

    //返回任务执行的结果
    $serv->finish("$data -> OK");
});

//处理异步任务的结果
    $serv->on('finish', function ($serv, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
});
$serv->start();

tcp同步客户端

$client = new swoole_client(SWOOLE_SOCK_TCP);
//连接到服务器
if (!$client->connect('127.0.0.1', 9501, 0.5))
{
die("connect failed.");
}

//向服务器发送数据
if (!$client->send("hello world"))
{
die("send failed.");
}

//从服务器接收数据
$data = $client->recv();
if (!$data)
{
die("recv failed.");
}
echo $data;

//关闭连接
$client->close();

tcp异步客户端

$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
//注册连接成功回调
$client->on("connect", function($cli) {
$cli->send("hello world\n");
});

//注册数据接收回调
$client->on("receive", function($cli, $data){
echo "Received: ".$data."\n";
});

//注册连接失败回调
$client->on("error", function($cli){
echo "Connect failed\n";
});

//注册连接关闭回调
$client->on("close", function($cli){
echo "Connection close\n";
});

//发起连接

$client->connect('127.0.0.1', 9501, 0.5);

自定义通讯协议设计

进程/协程管理
进程

单独进程
$process = new swoole_process('callback_function', true);
$pid = $process->start();
function callback_function(swoole_process $worker){
$worker->exec('/usr/bin/php', array(__DIR__.'/write_file.php'));
}// 启用本地的命令，加上绝对路径
swoole_process::wait();

【子进程】管道缓冲区读写及事件监听？

$workers = [];
$worker_num = 3;//创建的进程数

for($i=0;$i<$worker_num; $i++){
$process = new swoole_process('process');// 创建子进程 启动函数为 process
$pid = $process->start();// 子进程启动
$workers[$pid] = $process;// 存入字符数组
}

foreach($workers as $process){
//子进程会包含此事件,加入到子进程中 异步IO
swoole_event_add($process->pipe, function ($pipe) use($process){
$data = $process->read();
echo "RECV: " . $data.PHP_EOL;// 接收数据
});//函数调用的神奇情况
}

function process(swoole_process $process){// 第一个处理
$process->write("processId:".$process->pid);// 子进程写入信息到管道。
echo "echo:".$process->pid."\t".$process->callback .PHP_EOL;// 打印提示信息结果 及制表符
}
// 两次等待子进程结束
for($i=0; $i<$worker_num; $i++){// 回收子进程 否则出现僵尸进程
$ret = swoole_process::wait();// 回收结束运行的子进程,如果子进程结束。类似于 join
$pid = $ret['pid'];
unset($workers[$pid]);
echo "子进程退出, PID=".$pid.PHP_EOL;
}
队列读写
// 进程通信
$workers = [];// 进程仓库
$worker_num = 2;// 最大进程数
// 循环创建子进程
for($i = 0; $i < $worker_num; $i++){
$process = new swoole_process('callback_function', false, false);
$process->useQueue();// 开启队列使用，类似于全局队列
$pid = $process->start();//开启进程
$workers[$pid] = $process;// 存入句柄仓库
}

// 子进程执行函数

function callback_function(swoole_process $worker){
sleep(2);//睡觉2秒
$recv = $worker->pop();// 获取队列数据
echo "从主进程获取数据: $recv\n";
$worker->exit(0);// 当前子进程结束
}
// 主进程内，新增队列数据
foreach($workers as $pid => $process){
$process->push("Hello 子进程[$pid]\n");
}
// 两次等待子进程结束
for($i = 0; $i < $worker_num; $i++){
// 回收子进程 否则出现僵尸进程

$ret = swoole_process::wait();// 回收结束运行的子进程,如果子进程结束。类似于 join
$pid = $ret['pid'];
unset($workers[$pid]);
echo "子进程退出, PID=".$pid.PHP_EOL;
}
循环触发进程
// 循环定时执行
// 定时器触发函数
swoole_process::signal(SIGALRM, function () {
static $i = 0;
echo "#{$i}\t alarm\n";
$i++;

if ($i > 20) {
swoole_process::alarm(-1);// 清除定时器
}
});

//100ms
swoole_process::alarm(100 * 1000);// 定时器，类似于定时触发，类似js 里面的setinterval()

协程

2.0开始执行，暂不深入了解

内存读写

内存锁—互斥锁

$lock = new swoole_lock(SWOOLE_MUTEX);
echo "[主进程]创建锁\n";
$lock->lock();

if (pcntl_fork() > 0){// 这个是主进程
sleep(1);
$lock->unlock();
}else{// 这个是子进程
echo "[子进程]等待锁\n";

$lock->lock();
echo "[子进程]获取锁\n";
$lock->unlock();
exit("[子进程]退出\n");
}

echo "[主进程]释放锁\n";
unset($lock);
sleep(1);
echo "[主进程]退出\n";

异步IO

DNS轮询
swoole_async_dns_lookup("www.baidu.com", function($host, $ip){
echo "{$host} : {$ip}\n";
});

异步读取

swoole_async_readfile(__DIR__."/server.php", function($filename, $content) {
echo "$filename: $content";
});

异步写入

$file_content = 'jingshan';
swoole_async_writefile('test.log', $file_content, function($filename) {
echo "wirte ok.\n";
}, $flags = 0);

异步事件

$fp = stream_socket_client("tcp://www.qq.com:80", $errno, $errstr, 30);
fwrite($fp,"GET / HTTP/1.1\r\nHost: www.qq.com\r\n\r\n");
swoole_event_add($fp, function($fp) {
$resp = fread($fp, 8192);

//socket处理完成后，从epoll事件中移除socket
//var_dump($resp);
swoole_event_del($fp);
fclose($fp);
});
echo "Finish\n";  //swoole_event_add不会阻塞进程，这行代码会顺序执行

异步mysql

// mysql异步客户端

$db = new swoole_mysql;
$server = array(
'host' => '192.168.50.145',
'user' => 'root',
'password' => 'flzx_3QC',
'database' => 'mysql',
'chatset' => 'utf8', //指定字符集
);

$db->connect($server, function ($db, $r) {

if ($r === false){
var_dump($db->connect_errno, $db->connect_error);
die;
}

$sql = 'show tables';
$db->query($sql, function(swoole_mysql $db, $r) {
global $s;

if ($r === false){
var_dump($db->error, $db->errno);
}
elseif ($r === true ){
var_dump($db->affected_rows, $db->insert_id);
}

var_dump($r);
$db->close();
});
});
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 212,686评论 6赞 492
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,668评论 3赞 385
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 158,160评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,736评论 1赞 284
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 65,847评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,043评论 1赞 291
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,129评论 3赞 410
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,872评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,318评论 1赞 303
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,645评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,777评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,470评论 4赞 333
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,126评论 3赞 317
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,861评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,095评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,589评论 2赞 362
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,687评论 2赞 351

推荐阅读更多精彩内容

  • 操作系统知识点
    1. 基础知识 1.1、 基本概念、 功能 冯诺伊曼体系结构1、计算机处理的数据和指令一律用二进制数表示2、顺序执...
    yunpiao阅读 5,275评论 1赞 22
  • 高性能服务器架构思路
    在服务器端程序开发领域，性能问题一直是备受关注的重点。业界有大量的框架、组件、类库都是以性能为卖点而广为人知。然而...
    零一间阅读 866评论 0赞 12
  • 第四模块： (1)并发编程
    必备的理论基础 1.操作系统作用： 隐藏丑陋复杂的硬件接口，提供良好的抽象接口。 管理调度进程，并将多个进程对硬件...
    drfung阅读 3,530评论 0赞 5
  • 高性能服务器架构思路，不仅是思路
    在服务器端程序开发领域，性能问题一直是备受关注的重点。业界有大量的框架、组件、类库都是以性能为卖点而广为人知。然而...
    dreamer_lk阅读 1,001评论 0赞 17
  • 无标题文章
    刚刚睡醒，做了一个长长的梦，我想家了。
    J一久阅读 149评论 1赞 0