标签归档:PHP

使用PHP并发执行任务–curl_multi应用

注释:
1.关于curl_multi_exec函数的返回值:

返回CURLM_CALL_MULTI_PERFORM 说明curl_multi_exec需要马上被再调用一次。
返回CURLM_OK 说明已经有需要处理的数据。这时你需要进行相关处理,处理完后再次调用curl_multi_exec。
php中的curl_multi_exec是调用的curl库中的curl_multi_perform方法。代码在multi.c的230行左右。

2.此方式,虽然在获取数据和数据处理上是并行的,但是在数据处理时依然是串行的。即数据是一条条依次处理的。如果deal方法比较耗时的话,那整体会非常耗时。

php并发执行shell

最近在项目中做一个功能,是PHP调用shell来探测资源

在很快把,页面逻辑梳理好以后就开始动手,功能完成后开始测试使用,发现当多条命令发出以后,相应会非常慢,因为在PHP中循环调用,上一次执行完成后,才会调用下一步,这样就有问题了。会卡主,504等等

要不然限制用户输入的数据条数,不行,这样感觉体验太差了。于是经过和其他同事探讨,给进程加上一个超时时间,并用使用并发来解决此问题。下面上代码进化步骤

下面是主要代码

程序设计之状态机PHP版本

状态机

把复杂的控制逻辑分解成有限个稳定状态,在每个状态上判断事件,变连续处理为离散数字处理,符合计算机的工作特点。
同时,因为有限状态机具有有限个状态,所以可以在实际的工程上实现。但这并不意味着其只能进行有限次的处理,相反,有限状态机是闭环系统,有限无穷,可以用有限的状态,处理无穷的事务。

状态机可归纳为4个要素,即 现态条件动作次态。这样的归纳,主要是出于对状态机的内在因果关系的考虑。“现态”和“条件”是因,“动作”和“次态”是果。详解如下:

  1. 现态:是指当前所处的状态。
  2. 条件:又称为“事件”,当一个条件被满足,将会触发一个动作,或者执行一次状态的迁移。
  3. 动作:条件满足后执行的动作。动作执行完毕后,可以迁移到新的状态,也可以仍旧保持原状态。动作不是必需的,当条件满足后,也可以不执行任何动作,直接迁移到新状态。
  4. 次态:条件满足后要迁往的新状态。“次态”是相对于“现态”而言的,“次态”一旦被激活,就转变成新的“现态”了。

举个最简单的例子。
人有三个状态健康,感冒,康复中。
触发的条件有淋雨(t1),吃药(t2),打针(t3),休息(t4)。

所以状态机就是

  • 健康-(t4)->健康;
  • 健康-(t1)->感冒;
  • 感冒-(t3)->健康;
  • 感冒-(t2)->康复中;
  • 康复中-(t4)->健康,

就是这样状态在不同的条件下跳转到自己或不同状态的图。

举个例子:找出一个文本文件中所有符合条件的字符串(文本文件都是字母可能有回车,换行)

文本文件str.txt如下:

sdfasdfAAAsAAAdfasddllfadsBBBsBBBdfdfdfsdfdf dfadfsfaHHHsKKKsaddfkkslslAAAAhBBBddfFFhMMM

条件格式:
1. 左边三个大写字母
2. 中间一个小写字母
3. 右边三个大写字母

解决这个问题可能涉及栈结构
栈(stack)
后进先出

++++++++++++++++++++++++++++++解题思路++++++++++++++++++++++++++++++

定义状态:对栈的情况定义相关的状态

  • 栈空状态: stat0,
  • 栈中一个有效数据:stat1
  • 栈中两个有效数据:stat2
  • 栈中三个有效数据:stat3
  • 栈中四个有效数据:stat4
  • 栈中五个有效数据:stat5
  • 栈中六个有效数据:stat6
  • 栈中七个有效数据:stat7

单个字符扫描文件让符合条件的字符入栈,根据栈的状态做出相应动作
0.初始状态栈空,即$curState=0,遇到大写字母入栈,栈中一个有效字母,修改栈状态:$curState=1

  1. 当栈状态为1时,下一个字母必须为大写,才能入栈,否则置空栈,恢复栈状态:$curState=0
  2. 当栈状态为2时,下一个字母必须为大写,才能入栈,否则置空栈,恢复栈状态:$curState=0
  3. 当栈状态为3时,下一个字母必须为小写,才能入栈,否则置空栈,恢复栈状态:$curState=0
  4. 当栈状态为4时,下一个字母必须为大写,才能入栈,否则置空栈,恢复栈状态:$curState=0
  5. 当栈状态为5时,下一个字母必须为大写,才能入栈,否则置空栈,恢复栈状态:$curState=0
  6. 当栈状态为6时,下一个字母必须为大写,才能入栈,否则置空栈,恢复栈状态:$curState=0
  7. 当栈状态为7时,下一个字母必须为小写,此时栈中元素符合了有效条件格式,把栈中元素传给$box数组,然后置空栈,恢复栈状态:$curState=0;否则置空栈,恢复栈状态:$curState=0

必须考虑栈的当前状态与下一个状态成立间的关系,即现态与次态
$box数组中就是文本文件中所有符合条件格式的字符串

(PS:例子从别处抄来的,觉得很好理解,所以码在这里)

PHP中闭包的使用

PHP中闭包的使用

例子一

例子二

Ubuntu下手动编译php-amqp扩展附PHP中RabbitMQ使用例子

Linux教程之ubuntu下手动编译php-amqp扩展

首先,神马是amqp?介绍在这里,简单的讲就是高级队列协议。而这个扩展就是为了让php可以支持amqp协议与相关的队列服务通讯。

优点:可以解决服务器处理的并发问题。
高级消息队列协议(AMQP)是一个异步消息传递所使用的应用层协议规范。作为线路层协议,而不是API(例如JMS),AMQP 客户端能够无视消息的来源任意发送和接受信息。现在,已经有相当一部分不同平台的服务器和客户端可以投入使用。

(一)基本概念

RabbitMQ 是流行的开源消息队列系统,用erlang语言开发。RabbitMQ是AMQP(高级消息队列协 议)的标准实现。如果不熟悉AMQP,直接看RabbitMQ的文档会比较困难。不过它也只有几个关键概念,这里简单介绍。

几个概念说明:

  • Broker:简单来说就是消息队列服务器实体。
  • Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
  • Queue:消息队列载体,每个消息都会被投入到一个或多个队列。
  • Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来。
  • Routing Key:路由关键字,exchange根据这个关键字进行消息投递。
  • vhost:虚拟主机,一个broker里可以开设多个vhost,用作不同用户的权限分离。
  • producer:消息生产者,就是投递消息的程序。
  • consumer:消息消费者,就是接受消息的程序。
  • channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务。

(二)使用流程

即 Client – AMQP server – Client
左边的Client向右边的Client发送消息,流程:

  • 获取Conection
  • 获取Channel
  • 定义Exchange,Queue
  • 使用一个RoutingKey将Queue Binding到一个Exchange上
  • 通过指定一个Exchange和一个RoutingKey来将消息发送到对应的Queue上,
  • 接收方在接收时也是获取connection,接着获取channel,然后指定一个Queue直接到它关心的Queue上取消息,它对Exchange,RoutingKey及如何binding都不关心,到对应的Queue上去取消息就OK了

由于ubuntu的默认源里面没有php5-amqp这个包,所以要用上amqp得考手动编译。

准备工作:

安装php编译工具

安装rabbitmq的库

如果你的Linux发行版没有现成的librabbitmq-dev包,那么可以通过下载源码编译安装

然后如果你没有安装git话请安装一下git,因为我们要从官方的版本库中获取源代码

克隆源码并编译

编译库

然后我们需要去下载php扩展的源代码,地址在此:

http://pecl.php.net/package/amqp

当前最新版本为1.4.0

创建配置文件

然后重启你的web服务器或者php-fpm并打印phpinfo,如果见到以下的内容就说明扩展安装好了

@RabbitMQ使用例子

生产方

消费方

PHP版本Socket学习

PHP版本Socket学习

Socket是在应用层和传输层之间的一个抽象层,它把TCP/IP层复杂的操作抽象为几个简单的接口供应用层调用已实现进程在网络中通信。

Socket起源于UNIX,在Unix一切皆文件哲学的思想下,Socket是一种 打开—读/写—关闭 模式的实现,服务器和客户端各自维护一个”文件”,在建立连接打开后,可以向自己文件写入内容供对方读取或者读取对方内容,通讯结束时关闭文件。服务器根据地址类型(ipv4,ipv6)、socket类型、协议创建socket

Socket通信流程

  • 服务器为socket绑定ip地址和端口号
  • 服务器socket监听端口号请求,随时准备接收客户端发来的连接,这时候服务器的socket并没有被打开
  • 客户端创建socket
  • 客户端打开socket,根据服务器ip地址和端口号试图连接服务器socket
  • 服务器socket接收到客户端socket请求,被动打开,开始接收客户端请求,直到客户端返回连接信息。这时候socket进入 阻塞 状态,所谓阻塞即accept()方法一直到客户端返回连接信息后才返回,开始接收下一个客户端谅解请求
  • 客户端连接成功,向服务器发送连接状态信息
  • 服务器accept方法返回,连接成功
  • 客户端向socket写入信息
  • 服务器读取信息
  • 客户端关闭
  • 服务器端关闭

服务端代码,运行在cli模式

客户端代码

PHP设计模式之代理模式

代理模式:在客户端和实体之间建立一个代理对象(Proxy),客户端对实体的操作全部委派给代理对象,隐藏实体的具体实现细节
Proxy还可以与业务代码分离,部署到另外的服务器。业务代码通过RPC来委派任务

代理模式proxy.php

当要执行一个读操作时,在从库执行,当要执行写操作时连接主库,这样就实现了读写分离,连接数据库的操作交给代理类来执行。

PHP设计模式之装饰器模式

装饰器模式可以动态的添加修改类的功能
一个类提供了一项功能,如果要在修改并添加额外的功能,传统编程,需要写一个字类继承它,并重新实现类的方法
使用装饰器模式,只需在运行时添加一个装饰器对象,可以实现最大的灵活性

 

PHP设计模式之原型模式

原型模式与工厂模式作用相似,都是用来创建对象的;

与工厂模式的实现不同,原型模式是先创建一个对象,然后通过clone原型对象来创建新的对象,这样就免去了类创建时的重复初始化操作;

原型模式适合于大对象的创建,创建一个对象需要很大的开销,如果每次new就会消耗很大,原型模式仅需内存拷贝即可;

 

PHP设计模式之观察者模式

当一个对象发生改变时,依赖它的对象全部收到通知,并自动更新
场景:一个事件发生后,要执行一连串更新操作。传统的编程方法就是在事件的代码之后直接加入处理逻辑。当更新的逻辑增多之后,代码变得难以维护。这种方式是耦合的,侵入式的,增加新的逻辑要修改事件主体代码
观察者模式实现了低耦合,非侵入式的通知与更新机制