收藏此站 联系我们 宿迁腾云网络公司
全部 网站建设 SEO优化 技术日志
当前位置:网站首页 > 技术日志

php-fpm应用与php-swoole应用进行通信

作者: 腾云网络 . 阅读量: . 发表时间:2020-04-26

基础要求

  • linux万物皆文件

  • socket通信

  • 基础进制转换

写在前面

这篇文章是自己练习的内容,主要想实现应用间的通信机制。

Workerman中提供的建议方案

与其它mvc框架结合建议以上图的方式(ThinkPHP为例):

1、ThinkPHP与Workerman是两个独立的系统,独立部署(可部署在不同服务器),互不干扰。

2、ThinkPHP以HTTP协议提供网页页面在浏览器渲染展示。

3、ThinkPHP提供的页面的js发起websocket连接,连接workerman

4、连接后给Workerman发送一个数据包(包含用户名密码或者某种token串)用于验证websocket连接属于哪个用户。

5、仅在ThinkPHP需要向浏览器推送数据时,才调用workerman的socket接口推送数据。

6、其余请求还是按照原本ThinkPHP的HTTP方式调用处理。

总结:

把Workerman作为一个可以向浏览器推送的通道,仅仅在需要向浏览器推送数据时才调用Workerman接口完成推送。业务逻辑全部在ThinkPHP中完成。

我们使用swoole环境的常驻内存、协程特性来做一些其他事务,如:任务队列及其消费、缓存、异步执行等情况时

可以如建议中第5步所说,FPM环境调用Swoole环境提供的接口(可以用TCP/HTTP等方式)来开始一个任务

进程通信

上面的方案可以用在单机中,也可以用在集群部署中。

进程通信一般仅限于单机中使用

进程通信的方式有好几种,这里主要写明我测试的一种。

unix socket 文件

在linux环境中,万物皆为文件,套接字也可以用文件来表示,然后一个进程(一般是swoole环境)监听它,其他进程(FPM环境)连接它,并且发送数据

这里使用的是Easyswoole框架提供的一个基类,如果是纯Swoole环境可以下载框架源码并查看原理

EasySwoole部分

继承了 AbstractUnixProcess ,封装好了很多内容,直接写明onAccept 接受数据做处理即可

 \;

 \\\\;
 \\;

   
{

     (Socket $socket)
    {
        
        $header = $socket->recvAll(, );

         (strlen($header) != ) {
            $socket->sendAll(::pack(json_encode([
                 => ,
                 => ,
            ], )));
            $socket->close();
            ;
        }

        
        
        $allLength = ::packDataLength($header);
        $data = $socket->recvAll($allLength, );
         (strlen($data) == $allLength) {
             $data;

            

            $socket->sendAll(::pack(json_encode([
                 => ,
                 => ,
            ], )));
            $socket->close();
        }{

            $socket->sendAll(::pack(json_encode([
                 => ,
                 => ,
            ], )));
            $socket->close();
        }
    }

      ($string)
    {
         pack(, strlen($string)) . $string;
    }

      ($head)
    {
         unpack(, $head)[];
    }
}

写好了任务逻辑,还需要加入启动该进程

EasySwooleEvent.php文件
       (EventRegister $register)
    {
        $config =  UnixProcessConfig();
        $config->setSocketFile(EASYSWOOLE_ROOT.);
        $config->setProcessName();

        $siam =  Siam($config);
        ServerManager::getInstance()->getSwooleServer()->addProcess($siam->getProcess());
    }

普通环境发送数据

$sock = dirname().;

$unixSock = stream_socket_client(.$sock);

fwrite($unixSock, siam_pack());



fclose($unixSock);




 ($string)
{
     pack(, strlen($string)) . $string;
}

 ($head)
{
     unpack(, $head)[];
}



标签:
转载请注明来源:https://www.tyweb.net/jsrz/336.html
现在咨询免费送诊断方案,每天限3名
马上填写资料获取方案
腾云网络产品
网站建设 微信小程序 微商城 APP开发 SEO优化
腾云网络服务
7x24小时售后支持 市内上门服务 免费后台培训 定期回访
关于腾云网络
关于我们
网站建设案例 小程序案例 APP开发案例
联系腾云网络
联系腾云网络
紧急问题处理电话
131-6035-5545 131-6035-5545
131-6035-5545
扫一扫关注腾云网络公众号