swoole 安装与简单应用

方法一:PECL安装

安装依赖包

apt-get install libpcre3 libpcre3-dev

安装swoole

pecl install swoole

修改PHP配置 php.ini  加载 swoole

验证安装与加载:

php -m | grep swoole

方法二:源码编译安装

1.下载swoole

下载源码包,解压,并切换到解压目录

wget -c https://github.com/swoole/swoole-src/archive/v2.0.6.tar.gz

解压:tar -zxvf v2.0.6.tar.gz

cd swoole-src-2.0.6/

2.编译安装

使用phpize来生成php编译配置

.configure来做编译配置检测

make进行编译 make install 进行安装

执行命令:

phpize

./configure

make 

make install

正常情况下会出现

Installing shared extensions :             /usr/lib64/php/modules

表示 在上述目录 /usr/lib64/php/modules  中生成了 swoole.so 文件

3.修改配置文件,加载模块

要在PHP配置文件 php.ini 添加swoole模块. 注意,PHP7模块配置文件是单独分开的,只需在 /etc/php.d/  目录中添加模块配置文件 swoole.ini 即可

进入到 /etc/php.d/  执行命令

vim swoole.ini    

在swoole.ini 中输入

;Enable swoole extension module 

extension=swoole.so

保存.

4.重启服务,模块是否已加载

service  apache2 restart

 php -m | grep swoole

三  .简单示例

1.TCP服务器

创建swoole_test.php 文件,内容如下:  示例代码

切换到所创建swoole_test.php 所在目录,执行命令

php  swoole_test.php  (本人电脑多版本PHP 故指明版本 php7.0)

监听9898 端口的程序已启动执行

新打开一个终端窗口,使用telnet 连接服务端监听的端口,输入文字,观察.可以发现  连接时  监听连接的回调函数正常输出了 如图:

示例只是简单的模拟个回复 ,客户端发什么,服务端就回什么

退出Telnet 连接 观察 服务器显示什么

Ctrl + ] 

quit

服务器 显示 Client:Close

上述telnet 连接测试 可用swoole_client 同理测试

注:swoole_client 是针对TCP服务器的客户端,即:swoole_server

创建swoole_client.php,内容如下:

1 1 function client($argv) 2 2 { 3 3 $client= new swoole_client(SWOOLE_SOCK_TCP); 4 4 //连接到服务器 5 5 if (!$client->connect($argv[1],$argv[2],'0.5')) { 6 6 die("connect failed."); 7 7 } 8 8 9 9 //向服务器发送数据 1010 if (!$client->send('data: '.$argv[3])) { 1111 die("send failed."); 1212 } 1313 echo "success send data: ".$argv[3]."\n"; 1414 $client->close(); 1515 } 1616 client($argv); 17 18打开终端执行:php7.0 swoole_client.php 127.0.0.1 9898 hello

1数据 'hello' 发送成功. PHP 中可用 exec()函数执行:exec('php7.0 swoole_client.php 127.0.0.1 9898 hello'),可打印日志,跟踪过程.2. webSocket服务器程序. 2 3内置的webSocket服务器支持,通过几行PHP代码就可以写出一个异步非阻塞多进程的webSocket服务 如下例: 4 5.html: 6 7 1 <table> 8 2 <tr> 9 3 <td><input type="text" id="text"></td> 10 4 </tr> 11 5 <tr> 12 6 <td><input type="button" value="点击" onclick="ab()"></td> 13 7 </tr> 14 8 </table> 15 9 <div id="div" style="width:200px; height:200px;" }> 1610 1711 </div> 18 19.客户端js: 20 21目前浏览器安基本都内置了js语言的webSocket客户端,微信小程序开发框架也内置了webSocket客户端,除此之外异步的php程序中可以使用swoole\http\client作为websocket客户端,注意的是:非webSocket客户端不能与webSocket服务器通讯. 22 23 1 //引入jQuery 24 2 <script> 25 3 var wsServer = 'ws://127.0.0.1:9999';//这里的IP应该更改 26 4 var websocket = new WebSocket(wsServer); 27 5 websocket.onopen = function (evt) { 28 6 console.log("Connected to WebSocket server."); 29 7 }; 30 8 31 9 websocket.onclose = function (evt) { 3210 console.log("Disconnected"); 3311 }; 3412 3513 websocket.onmessage = function (evt) { 3614 $('#div').append(evt.data+"<br>"); 3715 // document.getElementById('div').style.background = evt.data; 3816 console.log('Retrieved data from server: ' + evt.data); 3917 }; 4018 4119 websocket.onerror = function (evt, e) { 4220 console.log('Error occured: ' + evt.data); 4321 }; 4422 function ab(){ 4523 var zhi=document.getElementById('text').value; 4624 websocket.send(zhi); 4725 } 4826 </script> 49 50webSocket服务器: webSocket_server.php 51 52 1 //创建websocket服务器对象,监听0.0.0.0:9502端口 53 2 $ws = new swoole_websocket_server("0.0.0.0", 9999); 54 3 55 4 //监听WebSocket连接打开事件 56 5 $ws->on('open', function ($ws, $request) { 57 6 var_dump($request->fd, $request->get, $request->server); 58 7 //获取所有连接人存为数组 59 8 60 9 $GLOBALS['fd'][] = $request->fd; 6110 //$ws->push($request->fd, "hello, welcome\n"); 6211 }); 6312 6413 //监听WebSocket消息事件 6514 $ws->on('message', function ($ws, $frame) { 6615 echo "Message: {$frame->data}\n"; 6716 6817 //循环所有连接人发送内容 6918 7019 foreach($GLOBALS['fd'] as $key => $val){ 7120 $ws->push($val,$frame->data); 7221 } 7322 //$ws->push($frame->fd, "{$frame->data}"); 7423 }); 7524 7625 //监听WebSocket连接关闭事件 7726 $ws->on('close', function ($ws, $fd) { 7827 echo "client-{$fd} is closed\n"; 7928 }); 8029 8130 $ws->start(); 82 83运行 终端运行 php webSocket_server.php 84 85浏览器打开html页面:输入文字,得到回复

这里只做了简单的示例测试,具体应用参考官方文档 :https://wiki.swoole.com/

 实际项目应用示例demo

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

VirtualBox导入已安装好的操作系统的方法

VirtualBox导入已安装好的操作系统的方法1、修改UUID进入VirtualBox安装目录,运行VBoxManage修改UUID,命令运行如下:D:\\VirtualBoxVBoxManage.exe internalcommands setvdiuuid E:\\VirtualX

KVM调整cpu和内存

一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid