初识PHP中的Swoole

2021-01-08 14:57wangyulu PHP教程

Swoole是一种PHP高级Web开发框架，框架不是为了提升网站的性能，是为了提升网站的开发效率。最少的性能损耗，换取最大的开发效率

Swoole是一种PHP高级Web开发框架，框架不是为了提升网站的性能，是为了提升网站的开发效率。最少的性能损耗，换取最大的开发效率。利用Swoole框架，开发一个复杂的Web功能，可以在很短的时间内完成。

官方定义：

Swoole：重新定义PHP

PHP的异步、并行、高性能网络通信引擎，使用纯C语言编写，提供了PHP语言的异步多线程服务器，异步TCP/UDP网络客户端，异步MySQL，异步Redis，数据库连接池，AsyncTask，消息队列，毫秒定时器，异步文件读写，异步DNS查询。 Swoole内置了Http/WebSocket服务器端/客户端、Http2.0服务器端。

Swoole可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网、车联网、智能家居等领域。使用PHP+Swoole作为网络通信框架，可以使企业IT研发团队的效率大大提升，更加专注于开发创新产品。

swoole 扩展安装及案例来源：http://wiki.swoole.com/wiki/page/6.html

简单案例：

									<?php

									class Server

									{

									private $serv;

									public function __construct()

									{

									$this->serv = new swoole_server("0.0.0.0", 9501);

									$this->serv->set(array(

									'worker_num' => 8,

									'daemonize' => false,

									'max_request' => 10000,

									'dispatch_mode' => 2,

									'debug_mode' => 1

									));

									$this->serv->on('Start', array($this, 'onStart'));

									$this->serv->on('Connect', array($this, 'onConnect'));

									$this->serv->on('Receive', array($this, 'onReceive'));

									$this->serv->on('Close', array($this, 'onClose'));

									$this->serv->start();

									}

									public function onStart($serv)

									{

									echo "Start\n";

									}

									public function onConnect($serv, $fd, $from_id)

									{

									$serv->send($fd, "Hello {$fd}!");

									}

									public function onReceive(swoole_server $serv, $fd, $from_id, $data)

									{

									echo "Get Message From Client {$fd}:{$data}\n";

									}

									public function onClose($serv, $fd, $from_id)

									{

									echo "Client {$fd} close connection\n";

									}

									}

									// 启动服务器

									$server = new Server(); 

									<?php

									class Client

									{

									private $client;

									public function __construct()

									{

									$this->client = new swoole_client(SWOOLE_SOCK_TCP);

									}

									public function connect()

									{

									if (!$this->client->connect("127.0.0.1", 9501, 1)) {

									echo "Error: {$fp->errMsg}[{$fp->errCode}]\n";

									}

									$message = $this->client->recv();

									echo "Get Message From Server:{$message}\n";

									fwrite(STDOUT, "请输入消息：");

									$msg = trim(fgets(STDIN));

									$this->client->send($msg);

									}

									}

									$client = new Client();

									$client->connect();