设为首页收藏本站
天天打卡

 找回密码
 立即注册
搜索
查看: 89|回复: 7

Linux下搭建swoole实现php消息推送的方法

[复制链接]

2

主题

39

回帖

122

积分

注册会员

积分
122
发表于 2024-4-20 09:39:16 | 显示全部楼层 |阅读模式
目录

Swoole使用纯C语言编写,提供了PHP语言的异步多线程服务器,异步 TCP/UDP 网络客户端,异步 MySQL,异步 Redis,数据库连接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,异步DNS查询。 Swoole内置了Http/WebSocket服务器端/客户端、Http2.0服务器端,完美支持PHP语言。本文讲解Linux下搭建swoole实现php消息推送的方法。

swoole简介

Swoole是一个面向生产环境的 PHP 异步网络通信引擎,使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务。Swoole 可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网(IOT)、车联网、智能家居等领域。 使用 PHP + Swoole 作为网络通信框架,可以使企业 IT 研发团队的效率大大提升。
Swoole不是一个像Zend Framework、CakePHP、Yii、symfony、ThinkPHP等一样的框架,也不是一个像WordPress、Drupal、Discuz、UChome等开源产品看齐的项目。 Swoole的目标是向Java框架、Ruby On Rails、Python DjangoPylons等一流框架发起挑战。
Swoole虽然是标准的PHP扩展,实际上与普通的扩展不同。普通的扩展只是提供一个库函数。而Swoole扩展在运行后会接管PHP的控制权,进入事件循环。当IO事件发生后底层会自动回调指定的PHP函数。
包含以下几个特色功能:
1、 类似ORM的数据查询,提供SQL封装器,让MySQL的SQL与PHP的Array,会话,Cache无缝结合。
2、App MVC分层结构,有效的程序结构分层,提高程序的可维护性和扩展性,实现低耦合,基于接口开发。
3、集成大量,实用的功能,比如方便的数据库操作,模板操作,缓存操作,系统配置,表单处理,分页,数据调用,字典操作,上传处理,内容编辑,调试等。
4、模板-数据反射系统,可以直接在模板中调用数据,提供很多标签,可以无需修改程序,只修改模板,即可实现网站各类更新维护工作。
另外的几个功能
1、Swoole包含了大量类,提供众多的功能扩展,基本上Web开发能够用到的功能类,大部分都可以在Swoole框架中找到。
2、Swoole拥有插件系统,Fckeditor、Adodb、pscws中文分词、中文全文索引系统、最新的Key-Value数据库思想,TokyoTyrant,可以无限扩展框架的功能。

安装swoole服务

1.下载swoole源码,下载地址: https://github.com/swoole/swoole-src/releases
2.将tar包上传到/usr/local/src/swoole下面,这里面存储安装源文件。
3.解压源文件,tar –xvfswoole.tar
4.进入到刚解压的目录下输入命令phpize
5.注意:phpize是php-devel中的东西,它可以给PHP动态添加扩展,所以,请确保你的机器上安装了php-devel软件包。
6.接着,依次输入如下命令:./configure,执行编译检测make,编译swoole
7.缺少pcre和pcre-devel相关软件包,安装上即可。
8.sudo make install
9.php.ini一般在etc下面 编译安装成功后,我们还需要修改php.ini,在其中加入swoole.so扩展:
10.extension=swoole.so
11.输入php -m中能查看到swoole说明扩展安装成功。

安装apache启动swoole服务

(1)测试是否安装正确启动swoole Php服务
(2)在apache中添加server.php文件,和client.php文件。一般目录在var/www/html下面
(3)打开两个终端 在这两个文件所在的目录下面打开这两个文件,可以实现socket长连接服务。
安装lsof:yum -y install lsof

Server端PHP程序
  1. class WebSocketService {
  2.    private static $instance = NULL;
  3.    public $tagindex = 0;
  4.    public    $server    = null;
  5.    public   $office_cache = null;
  6.    public    $timer_arr = [];    //该变量保存所有的定时器任务ID,每一个客户端可以通过$timer_arr[客户端ID]
  7.    得到该客户端建立的所有定时器
  8.    public $conf      = [
  9.        'host'            => '0.0.0.0',
  10.        'port'            => 9999,     //服务使用端口
  11.        'worker_num'      => 2,         //启动worker进程数
  12.        'task_worker_num' => 8,           //启动task进程数
  13.        'is_daemonize'    => 0,          //是否后台运行:0-否,1-是
  14.        'log_file'        =>'/tmp/swoole_webSocket_server.log',    //日志文件路径
  15.        'abc'              =>0,
  16.    ];
  17.    public function getTagIndex() {
  18.        return $this->conf['abc'];
  19.     }
  20.    public function setSetTagIndex($index) {
  21.        $this->conf['abc'] = 100;
  22.        echo $this->getTagIndex();
  23.     }
  24.    public function __construct($config = []) {
  25.        $this->office_cache = array('1' => '1', '3'=>'2');
  26.        $this->conf = array_merge($this->conf, (array)$config);
  27.     }
  28.    //静态方法,返回此类唯一实例
  29.    public static function getInstance(){
  30.        if(empty(self::$instance)){
  31.            echo "instance \n";
  32.            self::$instance=new WebSocketService();
  33.        }
  34.        return self::$instance;
  35.     }
  36.    /**
  37.     * 服务器端运行webSocket的入口
  38.     */
  39.    public function run() {
  40.        try {
  41.            $this->server = new \swoole_websocket_server($this->conf['host'],$this->conf['port']);
  42.            $this->server->set(
  43.                 [
  44.                     'worker_num'      => $this->conf['worker_num'],
  45.                     'task_worker_num' =>$this->conf['task_worker_num'],
  46.                     'daemonize'       => $this->conf['is_daemonize'],
  47.                     'log_file'        => $this->conf['log_file'],
  48.                 ]
  49.            );
  50.            //注册方法列表
  51.            $this->server->on('open', [$this, 'open']);
  52.            $this->server->on('message', [$this, 'message']);
  53.            $this->server->on('task', [$this, 'task']);
  54.            $this->server->on('finish', [$this, 'finish']);
  55.            $this->server->on('close', [$this, 'close']);
  56.            $this->server->start();
  57.        } catch (\Exception $e) {
  58.            var_dump($e->getCode() . ':' . $e->getMessage());
  59.        }
  60.     }
  61.    /**
  62.     * 建立socket链接时,执行方法
  63.     * @param $server
  64.     * @param $request
  65.     */
  66.    public function open($server, $request) {
  67.        $data = [
  68.            'client_id' => $request->fd,
  69.            'request'   => $request
  70.        ];
  71.        echo 'open<<'.$data['client_id'];
  72.        $this->doOpen($data);
  73.     }
  74.    /**
  75.     * 发送消息时,执行方法
  76.     * @param $server
  77.     * @param $frame
  78.     */
  79.    public function message($server, $frame) {
  80.        echo "GET_mesage\n";
  81.        $data = [
  82.            'client_id' => $frame->fd,
  83.            'data'      => $frame->data,
  84.            'frame'     => $frame,
  85.        ];
  86.        $this->doMessage($data);
  87.     }
  88.    /**
  89.     * 执行具体任务
  90.     * @param $server
  91.     * @param $task_id
  92.     * @param $from_id
  93.     * @param $data
  94.     */
  95.    public function task($server, $task_id, $from_id, $data) {
  96.        $data['task_id'] = $task_id;
  97.        $data['from_id'] = $from_id;
  98.        $this->doTask($data);
  99.     }
  100.    /**
  101.     * 任务结果处理
  102.     * @param $server    服务器对象
  103.     * @param $taskId    任务进程ID
  104.     * @param $data
  105.     */
  106.    public function finish($server, $taskId, $data) {
  107.        $data['task_id'] = $taskId;
  108.        $this->doFinish($data);
  109.     }
  110.    /**
  111.     * 关闭链接
  112.     * @param $server        服务器对象
  113.     * @param $client_id     客户端唯一标识
  114.     */
  115.    public function close($server, $client_id) {
  116.        $data = [
  117.            'client_id' => $client_id
  118.        ];
  119.        $this->doClose($data);
  120.     }
  121.    /**
  122.     * 客户端成功连接到服务器时,会触发该方法
  123.      * 子类根据需求重写该方法
  124.     * @param $data
  125.     * [
  126.     *    'client_id',    //客户端唯一标识
  127.     *    'data',        //一些请求数据
  128.     *    'frame',        //swoole的数据
  129.     * ];
  130.     */
  131.    public function doOpen($data) {
  132.        echo "建立连接成功";
  133.     }
  134.    /**
  135.     * 得到Swoole Websocket Server
  136.     *
  137.     * @return null|\swoole_websocket_server
  138.     */
  139.    public function getServer()
  140.     {
  141.        return $this->server;
  142.     }
  143.    /**
  144.     * 收到客户端发来的消息,会触发该方法
  145.     * 子类根据需求重写该方法
  146.     * @param $data
  147.     * [
  148.     *    'client_id',    //客户端唯一标识
  149.     *    'data',        //客户端发送过来的消息(数据)
  150.     *    'frame',        //swoole的数据
  151.     * ];
  152.     */
  153.    public function doMessage($data) {
  154.        $info = json_decode($data['data'],true);
  155.        $officeid = $info['officeid'];
  156.        $client_id = $data['client_id'];
  157.        echo"<<<<".$officeid.">>>>".$client_id."\r\n";
  158.        if ($officeid == 1) {
  159.            $this->sendMsgToClient('2',array('msg' =>'我是1号场地发送给你数据'));
  160.        } else {
  161.            $this->sendMsgToClient('1',array('msg' =>'我是3号场地发送给你数据'));
  162.        }
  163.     }
  164.    /**
  165.     * 具体的工作任务。需要通过 $this->doJob()来触发
  166.     * 子类根据需求重写该方法
  167.     * @param $data
  168.     * [
  169.     *    'client_id',    //客户端唯一标识
  170.     * ];
  171.     */
  172.    public function doTask($data) {
  173.     }
  174.    /**
  175.     * 工作的结果处理。
  176.      * 子类根据需求重写该方法
  177.     * @param $data
  178.     * [
  179.     *    'client_id',    //客户端唯一标识
  180.     * ];
  181.     */
  182.    public function doFinish($data) {
  183.     }
  184.    /**
  185.     * 客户端断开时会自动触发该方法
  186.     * 子类根据需求重写该方法
  187.     * @param $data
  188.     * [
  189.     *    'client_id',    //客户端唯一标识
  190.     * ];
  191.     */
  192.    public function doClose($data) {
  193.     }
  194.    /**
  195.     * 发送任务
  196.     * @param $data    必须是数组,且要有$data['client_id']
  197.     */
  198.    public function doJob($data) {
  199.        $this->server->task($data);
  200.     }
  201.    public function finishJob($data) {
  202.        $this->server->finish($data);
  203.     }
  204.    /**
  205.     * 发送消息到客户端
  206.     * @param $client_id
  207.     * @param $msg
  208.     */
  209.    public function sendMsgToClient($client_id, $msg) {
  210.        echo "发送信息给客户端:{$client_id} | {$msg['action']['name']} | " . date('Y-m-dH:i:s') . "\r\n";
  211.        $this->server->push($client_id, json_encode($msg));
  212.     }
  213.    /**
  214.     * 关闭客户端链接
  215.     * @param $client_id
  216.     */
  217.    public function closeClient($client_id) {
  218.        $this->server->close($client_id);
  219.     }
  220.    /**
  221.     * 添加定时器
  222.     * @param $client_id
  223.     * @param $tick_time
  224.     */
  225.    public function addTimer($client_id, $tick_time) {
  226.        //暂未实现,先使用swoole原生写法
  227.     }
  228.    /**
  229.     * 清除定时器
  230.     * @param $client_id
  231.     * @param $arr
  232.     */
  233.    public function clearTimer($client_id, &$arr) {
  234.        if (is_array($arr)) {
  235.            foreach ($arr[$client_id] as $val) {
  236.                 if (is_array($val)) {
  237.                     foreach ($val as $v) {
  238.                         swoole_timer_clear($v);
  239.                     }
  240.                 } else {
  241.                     swoole_timer_clear($val);
  242.                 }
  243.            }
  244.        }
  245.        unset($arr[$client_id]);
  246.     }
  247. }
复制代码
html前端javascript程序
  1. $(document).ready(function(){
  2.     varwsurl = "ws://182.92.101.206:9999/";
  3.     console.log(wsurl);
  4.     varwebsocket = new WebSocket(wsurl);
  5.     websocket.onopen= function(evt){
  6.     console.log('Server:  打开WebSocket连接');
  7.     };
  8.     websocket.onclose= function(evt){
  9.            console.log('Server:  关闭WebSocket连接');
  10.     };
  11.     websocket.onmessage= function(evt){
  12.            varres = JSON.parse(evt.data);
  13.            console.log('Server:  收到消息(来自:'+res+'请求)');
  14.            console.log(res);
  15.     };
  16.     websocket.οnerrοr= function(evt){
  17.            console.log('Server:  出现错误');
  18.            console.log(evt.data);
  19.     }
  20.     functiondoSend(msg){
  21.            console.log('Client:发送消息  ' + msg);
  22.            websocket.send(msg);
  23.     }
  24. });
复制代码
启动start.php文件

启动start.php文件,cd到指定目录下,然后PHP-CLI运行php start.php。这种方式是没有启用线程保护的关掉后程序结束线程还在占用。
  1. require'src/WebSocketSwoole/WebSocketService.php';
  2. // require './WebSocketService.php';
  3. session_start();
  4. // $demoService = new\WebSocketSwoole\WebSocketService();
  5. $demoService =\WebSocketSwoole\WebSocketService::getInstance();
  6. $demoService->run();
复制代码
总结

到此这篇关于Linux下搭建swoole实现php消息推送的方法的文章就介绍到这了,更多相关swoole实现php消息推送内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!

0

主题

40

回帖

79

积分

注册会员

积分
79
发表于 2024-5-6 01:45:26 | 显示全部楼层
非常感谢你的观点,让我受益良多!

3

主题

47

回帖

159

积分

注册会员

积分
159
发表于 2024-5-8 07:27:57 | 显示全部楼层
好用好用

1

主题

68

回帖

160

积分

注册会员

积分
160
发表于 2024-5-16 07:45:52 | 显示全部楼层
这个话题真是有趣,我也对它感兴趣。
  • 打卡等级:偶尔看看
  • 打卡总天数:10
  • 打卡月天数:0
  • 打卡总奖励:180
  • 最近打卡:2024-06-20 09:02:38

9

主题

80

回帖

605

积分

高级会员

积分
605

推广达人宣传达人热心会员付费会员

发表于 2024-8-31 08:53:27 | 显示全部楼层
666666666666666666

2

主题

49

回帖

138

积分

注册会员

积分
138
发表于 2024-9-11 20:43:00 | 显示全部楼层
牛逼

0

主题

44

回帖

87

积分

注册会员

积分
87
发表于 2024-9-13 12:42:09 | 显示全部楼层
保持尊重和礼貌对待其他成员是必要的。
  • 打卡等级:无名新人
  • 打卡总天数:1
  • 打卡月天数:0
  • 打卡总奖励:10
  • 最近打卡:2024-04-19 21:38:57

1

主题

32

回帖

96

积分

注册会员

积分
96
发表于 6 天前 | 显示全部楼层
666666666666
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|爱云论坛 - d.taiji888.cn - 技术学习 免费资源分享 ( 蜀ICP备2022010826号 )|天天打卡

GMT+8, 2024-11-15 05:34 , Processed in 0.107523 second(s), 28 queries .

Powered by i云网络 Licensed

© 2023-2028 正版授权

快速回复 返回顶部 返回列表