async-helper|PHP 的异步进程助手，async-helperphp

async-helper|PHP 的异步进程助手，async-helperphp

async-helper 简介 PHP 的异步进程助手，借助于 AMQP 实现异步执行 PHP 的方法，将一些很耗时、追求高可用、需要重试机制的操作放到异步进程中去执行，将你的 HTTP 服务从繁重的业务逻辑中解脱出来。以一个较低的成本将传统 PHP 业务逻辑转换成非阻塞、高可用、可扩展的异步模式。

依赖

1. php 7.1.5+

2. ext-bcmath

3. ext-amqp 1.9.1+

4. ext-memcached 3.0.3+

安装 通过 composer 安装

composer require l669/async-helper 或直接下载项目源码

wget https://github.com/l669306630/async-helper/archive/master.zip 使用范例 业务逻辑：这里定义了很多等待被调用的类和方法，在你的项目中这可能是数据模型、或是一个发送邮件的类。

1. <?php

2. class SendMailHelper

3. {

4.    /**

5.     * @param array $mail

6.     * @throws Exception

7.     */

8.    public static function request($mail)

9.    {

10.        // 在这里发送邮件，或是通过调用第三方提供的服务发送邮件

11.        // 发送失败的时候你抛出了异常，希望被进程捕获，并按设定的规则进行重试

12.    }    

13. }

生产者：通常是 HTTP 服务，传统的 PHP 项目或是一个命令行程序，接收到某个请求或指令后进行一系列的操作。

1. <?php

2. use l669\AsyncHelper;

3. class UserController

4. {

5.    public function register()

6.    {

7.        // 假设这是一个用户注册的请求，用户提交了姓名、邮箱、验证码

8.        // 第一步、校验用户信息

9.        // 第二步、实例化异步助手，这时候会连接 AMQP

10.        $async_helper = AsyncHelper([

11.            'host' => '127.0.0.1',

12.            'port' => '5672',

13.            'user' => 'root',

14.            'pass' => '123456',

15.            'vhost' => '/'

16.        ]);

17.        // 第三步、保存用户信息到数据库

18.        $mail = [

19.            'from' => 'service@yourdomain.com',

20.            'to' => 'username@163.com',

21.            'subject' => '恭喜你注册成功',

22.            'body' => '请点击邮件中的链接完成验证，吧啦啦啦'

23.        ];

24.        // 第四步、通过异步助手发送邮件

25.        $async_helper->run('\\SendMailHelper', 'request', [$mail]);

27.        // 这是同步的模式去发送邮件，

28.        // 如果邮件服务响应迟缓或异常，就会直接影响该请求的响应时间，甚至丢失这封重要邮件。

29.        // SendMailHelper::request($mail);

30.    }

31. }

消费者：PHP 的异步进程，监听消息队列，执行你指定的方法。并且该消费者进程是可扩展的高可用的服务，这一切都得益于 AMQP，这是系统解耦、布局微服务的最佳方案。

consume.php

1. <?php

2. require_once('vendor/autoload.php');

3. require_once('SendMailHelper.php');

5. use l669\AsyncHelper;

6. use l669\CacheHelper;

8. $cache_helper = new CacheHelper('127.0.0.1', 11211);

9. while(true){

10.    try{

11.        $async_helper = new AsyncHelper([

12.            'host' => '127.0.0.1',

13.            'port' => '5672',

14.            'user' => 'root',

15.            'pass' => '123456',

16.            'vhost' => '/',

17.            'cacheHelper' => $cache_helper

18.        ]);

19.        $async_helper->consume();

20.    }catch(Exception $e){

21.        // 可以在这里记录一些日志

22.    }

23. }

php consume.php 和传统 PHP 相比 对任何 PHP 方法通过反射进行异步执行； 高可用，执行方法进入消息队列，即使服务器宕机，执行任务也不丢失； 高可用，对异常可以进行不限次数和时间的重试，重试次数和时间可配置； 支持对多个异步方法包含在事务中执行，支持回滚事务； 方法的参数类型支持除资源类型（resource）和回调函数（callable）外的任意类型的参数； 得益于 AMQP，异步方法可以承受高并发、高负载，支持集群部署、横向扩展； 低延时，实测延时时间 0.016 ～ 0.021s； 适用于：日常数据库操作、日志收集、金融交易、消息推送、发送邮件和短信、数据导入导出、计算大量数据生成报表； 附录 安装 memcached 安装 rabbitmq 安装 php7.1.5、ext-amqp、ext-memcached 安装 supervisor