Swoole 高性能高并发 PHP 协程框架

embedded/2024/10/20 17:31:36/

Swoole是一个强大的工具，它允许PHP开发人员编写高性能高并发的TCP、UDP、Unix Socket、HTTP、WebSocket等服务，从而让PHP可以超越Web领域的局限。

特别值得一提的是Swoole4协程的成熟，将PHP带入了前所未有的时代。通过协程，我们可以实现异步非阻塞的编程方式，大大提升了程序的性能。

Swoole4协程为性能的提升提供了独一无二的可能性。通过使用协程，我们可以在一个线程中同时执行多个任务，而不需要创建多个线程或进程。这样可以减少上下文切换的开销，提高服务器的吞吐量。

除了协程，Swoole还提供了许多其他的功能，如事件驱动、异步网络通信等。这些功能让PHP开发人员可以更加灵活地处理各种网络编程需求，并且提供了更好的性能和可扩展性。

在这里插入图片描述
Swoole是一个功能强大的网络通信框架，适用于互联网、移动通信、云计算、网络游戏、物联网（IOT）、车联网、智能家居等多个领域。通过使用PHP + Swoole，企业的IT研发团队可以显著提升效率，将更多精力专注于开发创新产品。

HTTP Server

//高性能HTTP服务器
$http = new Swoole\Http\Server("127.0.0.1", 9501);
$http->on("start", function ($server) {echo "Swoole http server is started at http://127.0.0.1:9501\n";
});$http->on("request", function ($request, $response) {$response->header("Content-Type", "text/plain");$response->end("Hello World\n");});$http->start();

WebSocket Server

$server = new Swoole\Websocket\Server("127.0.0.1", 9502);$server->on('open', function($server, $req) {
echo "connection open: {$req->fd}\n";
});
$server->on('message', function($server, $frame) {
echo "received message: {$frame->data}\n";
$server->push($frame->fd, json_encode(["hello", "world"]));
});
$server->on('close', function($server, $fd) {
echo "connection close: {$fd}\n";});
$server->start();

TCP Server

$server = new Swoole\Server("127.0.0.1", 9503);
$server->on('connect', function ($server, $fd){
echo "connection open: {$fd}\n";});
$server->on('receive', function ($server, $fd, $reactor_id, $data) {
$server->send($fd, "Swoole: {$data}");
$server->close($fd);});$server->on('close', function ($server, $fd) {
echo "connection close: {$fd}\n";});
$server->start();

UDP Server

$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();

Task

$server = new Swoole\Server("127.0.0.1", 9502);
$server->set(array('task_worker_num' => 4));
$server->on('receive', function($server, $fd, $reactor_id, $data) {
$task_id = $server->task("Async");
echo "Dispatch AsyncTask: [id=$task_id]\n";});
$server->on('task', function ($server, $task_id, $reactor_id, $data) {
echo "New AsyncTask[id=$task_id]\n";  $server->finish("$data -> OK");});
$server->on('finish', function ($server, $task_id, $data) {
echo "AsyncTask[$task_id] finished: {$data}\n";});
$server->start();

Coroutine
在一个进程内一秒内完成1万次睡眠、读取、写入、检查和删除文件操作，以及使用PDO和MySQLi与数据库进行通信1万次，创建TCP服务器和多个客户端进行相互通信1万次，创建UDP服务器和多个客户端进行相互通信1万次。

Swoole\Runtime::enableCoroutine();
//此行代码后，文件操作，sleep，Mysqli，PDO，streams等都变成异步IO，见文档'一键协程化'章节$s = microtime(true);
//Co/run()见文档'协程容器'章节Co\run(function() {
// i just want to sleep...for ($c = 100; $c--;) {
go(function () {
for ($n = 100; $n--;) {
usleep(1000);
}
});}
// 10k file read and writefor ($c = 100; $c--;) {
go(function () use ($c) {
$tmp_filename = "/tmp/test-{$c}.php";
for ($n = 100; $n--;) {
$self = file_get_contents(__FILE__);
file_put_contents($tmp_filename, $self);
assert(file_get_contents($tmp_filename) === $self);
}    
unlink($tmp_filename);
});}
// 10k pdo and mysqli readfor ($c = 50; $c--;) {
go(function () {
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8', 'root', 'root');
$statement = $pdo->prepare('SELECT * FROM `user`');
for ($n = 100; $n--;) {
$statement->execute();
assert(count($statement->fetchAll()) > 0);
}
});}for ($c = 50; $c--;) {
go(function () {
$mysqli = new Mysqli('127.0.0.1', 'root', 'root', 'test');
$statement = $mysqli->prepare('SELECT `id` FROM `user`');
for ($n = 100; $n--;) {
$statement->bind_result($id);
$statement->execute();
$statement->fetch();
assert($id > 0);
}
});}
// php_stream tcp server & client with 12.8k requests in single processfunction tcp_pack(string $data): string{  
return pack('n', strlen($data)) . $data;}function tcp_length(string $head): int{  
return unpack('n', $head)[1];}go(function () {
$ctx = stream_context_create(['socket' => ['so_reuseaddr' => true, 'backlog' => 128]]);  
$socket = stream_socket_server(    
'tcp://0.0.0.0:9502',    
$errno, $errstr, STREAM_SERVER_BIND | STREAM_SERVER_LISTEN, $ctx  );  
if (!$socket) {
echo "$errstr ($errno)\n";
} else {
$i = 0;
while ($conn = stream_socket_accept($socket, 1)) {
stream_set_timeout($conn, 5);
for ($n = 100; $n--;) {
$data = fread($conn, tcp_length(fread($conn, 2)));
assert($data === "Hello Swoole Server #{$n}!");
fwrite($conn, tcp_pack("Hello Swoole Client #{$n}!"));
}
if (++$i === 128) {
fclose($socket);
break;
}
}
}});for ($c = 128; $c--;) {
go(function () {
$fp = stream_socket_client("tcp://127.0.0.1:9502", $errno, $errstr, 1);
if (!$fp) {
echo "$errstr ($errno)\n";
} else {
stream_set_timeout($fp, 5);
for ($n = 100; $n--;) {
fwrite($fp, tcp_pack("Hello Swoole Server #{$n}!"));
$data = fread($fp, tcp_length(fread($fp, 2)));
assert($data === "Hello Swoole Client #{$n}!");
}      
fclose($fp);
}
});}// udp server & client with 12.8k requests in single processgo(function () {
$socket = new Swoole\Coroutine\Socket(AF_INET, SOCK_DGRAM, 0);
$socket->bind('127.0.0.1', 9503);  $client_map = [];
for ($c = 128; $c--;) {
for ($n = 0; $n < 100; $n++) { $recv = $socket->recvfrom($peer);
$client_uid = "{$peer['address']}:{$peer['port']}";
$id = $client_map[$client_uid] = ($client_map[$client_uid] ?? -1) + 1;assert($recv === "Client: Hello #{$id}!");
$socket->sendto($peer['address'], $peer['port'], "Server: Hello #{$id}!");
}
}
$socket->close();});for ($c = 128; $c--;) {
go(function () {
$fp = stream_socket_client("udp://127.0.0.1:9503", $errno, $errstr, 1);
if (!$fp) {
echo "$errstr ($errno)\n";
} else {
for ($n = 0; $n < 100; $n++) {
fwrite($fp, "Client: Hello #{$n}!");
$recv = fread($fp, 1024);
list($address, $port) = explode(':', (stream_socket_get_name($fp, true)));
assert($address === '127.0.0.1' && (int)$port === 9503);
assert($recv === "Server: Hello #{$n}!");
}      fclose($fp);
}
});}});echo 'use ' . (microtime(true) - $s) . ' s';

Channel

Co\run(function(){  
//使用Channel进行协程间通讯  
$chan = new Swoole\Coroutine\Channel(1);  
Swoole\Coroutine::create(function () use ($chan) {    
for($i = 0; $i < 100000; $i++) { co::sleep(1.0); $chan->push(['rand' => rand(1000, 9999), 'index' => $i]);      
echo "$i\n";    
}  
});  
Swoole\Coroutine::create(function () use ($chan) {    
while(1) {      
$data = $chan->pop();      
var_dump($data);    
}  
});});

Swoole 特性
Swoole是使用C/C++语言编写的，提供了异步多线程服务器、异步TCP/UDP网络客户端、异步MySQL、异步Redis、数据库连接池、AsyncTask、消息队列、毫秒定时器、异步文件读写、异步DNS查询等功能。此外，Swoole还内置了Http/WebSocket服务器端/客户端以及Http2.0服务器端。

除了支持异步IO，Swoole还为PHP多进程模式设计了并发数据结构和IPC通信机制，大大简化了多进程并发编程的工作。其中包括并发原子计数器、并发HashTable、Channel、Lock、进程间通信IPC等功能特性。

Swoole4.0引入了类似Go语言的协程，可以使用完全同步的代码实现异步程序。在编写PHP代码时无需额外增加任何关键词，底层会自动进行协程调度，实现异步IO。


http://www.ppmy.cn/embedded/118257.html

相关文章

2024.09.22 leetcode 每日一题

2024.09.22 leetcode 每日一题

Excel表列名称 给你一个整数 columnNumber &#xff0c;返回它在 Excel 表中相对应的列名称。 https://leetcode.cn/problems/excel-sheet-column-title/description/ 我的解法&#xff1a; class Solution { public:string convertToTitle(int columnNumber) {std::map<…
阅读更多...
数字安全二之密钥结合消息摘要

数字安全二之密钥结合消息摘要

HMACSHA256的定义 HMACSHA256是一种使用 SHA-256 哈希算法的 HMAC&#xff08;基于哈希的消息认证码&#xff0c;Hash-based Message Authentication Code&#xff09; 机制。它结合了【散列函数】 和 【密钥】&#xff0c;用于确保消息的完整性和真实性 HMAC 与 SHA-256 的作…
阅读更多...
【Webpack】优化前端开发环境的热更新效率

【Webpack】优化前端开发环境的热更新效率

概述 为了优化前端开发环境的热更新效率&#xff0c;可以从以下几个方面入手&#xff1a; 减少不必要的文件监听&#xff1a; 确保 Webpack 只监听需要的文件和目录&#xff0c;可以通过配置watchOptions的ignore来忽略一些变化频率高且不需要监听的文件&#xff0c;如node_m…
阅读更多...
理解C语言之深入理解指针（三）

理解C语言之深入理解指针（三）

目录 1. 字符指针变量 2. 数组指针变量 2.1 数组指针变量是什么&#xff1f; 2.2 数组指针变量怎么初始化 3. ⼆维数组传参的本质 4. 函数指针变量 4.1 函数指针变量的创建 4.2 函数指针变量的使⽤ 4.3 两段有趣的代码 4.3.1 typedef 关键字 5. 函数指针数组 6. 转移…
阅读更多...
STM32篇：按键点亮LED灯

STM32篇：按键点亮LED灯

输入&#xff08;按键&#xff09;&#xff1a;KEY1---PA0 KEY2---PA1 输出&#xff08;LED灯&#xff09;&#xff1a;LED1---PB8 LED2---PB9
阅读更多...
如何有效检测住宅IP真伪?

如何有效检测住宅IP真伪?

在当今的互联网时代&#xff0c;住宅IP&#xff08;即家庭用户通过宽带服务提供商获得的IP地址&#xff09;在跨境电商、广告投放、网络安全等多个领域扮演着重要角色。然而&#xff0c;随着网络环境的复杂化和欺诈行为的增多&#xff0c;如何有效检测和辨别住宅IP的真伪成为了…
阅读更多...
Spring MVC 基础 : 文件、cookies的接收 ，REST响应

Spring MVC 基础 : 文件、cookies的接收 ，REST响应

一、接受文件 在 Spring MVC 中&#xff0c;可以使用 RequestPart 注解来接收文件。这个注解常用于处理复杂的请求&#xff0c;如同时发送 JSON 数据和文件。RequestPart 非常适用于多部分请求&#xff08;multipart requests&#xff09;&#xff0c;这在单个请求中同时发送文…
阅读更多...
C++密码安全检测

C++密码安全检测

目标 关键代码 int getScore(string s) {int score 0;for (int i 0; i < s.size(); i) {char currentLetter s[i];if (isdigit(currentLetter))score scoreOfNumber;else if (isalpha(currentLetter)) {int ascii currentLetter;if (ascii < 0x5A) // Upper-casesc…
阅读更多...
最新文章

Copyright @ 2022~2023