Heim Backend-Entwicklung PHP-Tutorial Ausführliche Erläuterung des Beispiels für den asynchronen PHP-Prozess Async-Helper

Ausführliche Erläuterung des Beispiels für den asynchronen PHP-Prozess Async-Helper

Feb 06, 2018 pm 04:01 PM
php 详解

PHP 的异步进程助手,借助于 AMQP 实现异步执行 PHP 的方法,将一些很耗时、追求高可用、需要重试机制的操作放到异步进程中去执行,将你的 HTTP 服务从繁重的业务逻辑中解脱出来。以一个较低的成本将传统 PHP 业务逻辑转换成非阻塞、高可用、可扩展的异步模式。本文主要和大家介绍PHP异步进程助手async-helper的详细用法以及相关代码实例,对此有需要的朋友学习下。希望能帮助到大家。

依赖

  • php 5.6+

  • ext-bcmath

  • ext-amqp 1.9.1+

  • ext-memcached 3.0.3+

安装

通过 composer 安装


composer require l669/async-helper
Nach dem Login kopieren

或直接下载项目源码


wget https://github.com/l669306630/async-helper/archive/master.zip
Nach dem Login kopieren

使用范例

业务逻辑:这里定义了很多等待被调用的类和方法,在你的项目中这可能是数据模型、或是一个发送邮件的类。


<?php
class SendMailHelper 
{
  /**
   * @param array $mail
   * @throws Exception
   */
  public static function request($mail)
  {
    // 在这里发送邮件,或是通过调用第三方提供的服务发送邮件
    // 发送失败的时候你抛出了异常,希望被进程捕获,并按设定的规则进行重试
  }  
}
Nach dem Login kopieren

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


<?php 
use l669\AsyncHelper;
class UserController
{
  public function register()
  {
    // 假设这是一个用户注册的请求,用户提交了姓名、邮箱、验证码
    // 第一步、校验用户信息
    // 第二步、实例化异步助手,这时候会连接 AMQP
    $async_helper = new AsyncHelper([
      &#39;host&#39; => &#39;127.0.0.1&#39;,
      &#39;port&#39; => &#39;5672&#39;,
      &#39;user&#39; => &#39;root&#39;,
      &#39;pass&#39; => &#39;123456&#39;,
      &#39;vhost&#39; => &#39;/&#39;
    ]);
    // 第三步、保存用户信息到数据库
    $mail = [
      &#39;from&#39; => &#39;service@yourdomain.com&#39;, 
      &#39;to&#39; => &#39;username@163.com&#39;, 
      &#39;subject&#39; => &#39;恭喜你注册成功&#39;,
      &#39;body&#39; => &#39;请点击邮件中的链接完成验证....&#39;
    ];
    // 第四步、通过异步助手发送邮件
    $async_helper->run(&#39;\\SendMailHelper&#39;, &#39;request&#39;, [$mail]);
    
    // 这是同步的模式去发送邮件,如果邮件服务响应迟缓或异常,就会直接影响该请求的响应时间,甚至丢失这封重要邮件
    // SendMailHelper::request($mail);
  }
}
Nach dem Login kopieren

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

consume.php


<?php
require_once(&#39;vendor/autoload.php&#39;);
require_once(&#39;SendMailHelper.php&#39;);

use l669\AsyncHelper;
use l669\CacheHelper;

$cache_helper = new CacheHelper(&#39;127.0.0.1&#39;, 11211);
while(true){
  try{
    $async_helper = new AsyncHelper([
      &#39;host&#39; => &#39;127.0.0.1&#39;,
      &#39;port&#39; => &#39;5672&#39;,
      &#39;user&#39; => &#39;root&#39;,
      &#39;pass&#39; => &#39;123456&#39;,
      &#39;vhost&#39; => &#39;/&#39;,
      &#39;cacheHelper&#39; => $cache_helper
    ]);
    $async_helper->consume();
  }catch(Exception $e){
    // 可以在这里记录一些日志
    sleep(2);
  }
}
Nach dem Login kopieren

# 在命令行下启动消费者进程,推荐使用 supervisor 来管理进程

php consume.php

支持事务:需要一次提交执行多个异步方法,事务可以确保完成性。


// 接着上面的示例来说,这里省略了一些重复的代码,下同
$async_helper->beginTransaction();
try{
  $async_helper->run(&#39;\\SendMailHelper&#39;, &#39;request&#39;, [$mail1]);
  $async_helper->run(&#39;\\SendMailHelper&#39;, &#39;request&#39;, [$mail2]);
  $async_helper->run(&#39;\\SendMailHelper&#39;, &#39;request&#39;, [$mail3]);
  $async_helper->commit();
}catch(\Exception $e){
  $async_helper->rollback();
}
Nach dem Login kopieren

阻塞式重试:当异步进程执行一个方法,方法内部抛出异常时进行重试,一些必须遵循执行顺序的业务就要采用阻塞式的重试,通过指定重试最大阻塞时长来控制。


use l669\CacheHelper;
use l669\AsyncHelper;
$async_helper = new AsyncHelper([
  &#39;host&#39; => &#39;127.0.0.1&#39;,
  &#39;port&#39; => &#39;5672&#39;,
  &#39;user&#39; => &#39;root&#39;,
  &#39;pass&#39; => &#39;123456&#39;,
  &#39;vhost&#39; => &#39;/&#39;,
  &#39;cacheHelper&#39; => new CacheHelper(&#39;127.0.0.1&#39;, 11211),
  &#39;retryMode&#39; => AsyncHelper::RETRY_MODE_REJECT, // 阻塞式重试
  &#39;maxDuration&#39; => 600              // 最长重试 10 分钟
]);
$send_mail_helper = new \SendMailHelper();
$mail = new \stdClass();
$mail->from = &#39;service@yourdomain.com&#39;;
$mail->to = &#39;username@163.com&#39;;
$mail->subject = &#39;恭喜你注册成功&#39;;
$mail->body = &#39;请点击邮件中的链接完成验证....&#39;;
$async_helper->run($send_mail_helper, &#39;request&#39;, [$mail]);

// 如果方法中需要抛出异常来结束程序,又不希望被异步进程重试,可以抛出以下几种错误码,进程捕获到这些异常后会放弃重试:
// l669\AsyncException::PARAMS_ERROR
// l669\AsyncException::METHOD_DOES_NOT_EXIST
// l669\AsyncException::KNOWN_ERROR
Nach dem Login kopieren

非阻塞式重试:当异步执行的方法内部抛出异常,async-helper 会将该方法重新放进队列的尾部,先执行新进入队列的方法,回头再重试刚才执行失败的方法,通过指定最大重试次数来控制。


use l669\CacheHelper;
use l669\AsyncHelper;
$async_helper = new AsyncHelper([
  &#39;host&#39; => &#39;127.0.0.1&#39;,
  &#39;port&#39; => &#39;5672&#39;,
  &#39;user&#39; => &#39;root&#39;,
  &#39;pass&#39; => &#39;123456&#39;,
  &#39;vhost&#39; => &#39;new&#39;,
  &#39;cacheHelper&#39; => new CacheHelper(&#39;127.0.0.1&#39;, 11211),
  &#39;queueName&#39; => &#39;emails.vip&#39;,          // 给付费的大爷走 VIP 队列
  &#39;retryMode&#39; => AsyncHelper::RETRY_MODE_TTL,   // 非阻塞式重试
  &#39;maxRetries&#39; => 10               // 最多重试 10 次
]);
$mail = new \stdClass();
$mail->from = &#39;service@yourdomain.com&#39;;
$mail->to = &#39;username@163.com&#39;;
$mail->subject = &#39;恭喜你注册成功&#39;;
$mail->body = &#39;请点击邮件中的链接完成验证....&#39;;
$async_helper->run(&#39;\\SendMailHelper&#39;, &#39;request&#39;, [$mail]);
Nach dem Login kopieren

应用和解惑

  • 我们采用的是开源的 RabbitMQ 来为我们提供的 AMQP 服务。

  • 你的项目部署在拥有很多服务器节点的集群上,每个节点的程序都需要写日志文件,现在的问题就是要收集所有节点上面的日志到一个地方,方便我们及时发现问题或是做一些统计。所有节点都可以使用 async-helper 异步调用一个写日志的方法,而执行这个写日志的方法的进程只需要在一台机器上启动就可以了,这样所有节点的日志就都实时掌握在手里了。

  • 做过微信公众号开发的都知道,腾讯微信可以将用户的消息推送到我们的服务器,如果我们在 5s 内未及时响应,腾讯微信会重试 3 次,其实这就是消息队列的应用,使用 async-helper 可以轻松的做和这一样的事情。

  • 得益于 RabbitMQ,你可以轻松的横向扩展你的消费者进程的能力,因为 RabbitMQ 天生就支持集群部署,你可以轻松的启动多个消费者进程,或是将消费者进程分布到多台机器上。

  • 如果 RabbitMQ 服务不可用怎么办呢?部署 RabbitMQ 高可用服务是容易的,对外提供单一 IP,这个 IP 是个负载均衡,背后是 RabbitMQ 集群,负载均衡承担对后端集群节点的健康检查。

  • async-helper 能否承受高并发请求?async-helper 生产者使用的是短连接,也就说在你的 HTTP 还没有响应浏览器的时候 async-helper 就已经结束了工作,你连接 RabbitMQ 的时间是百分之百小于 HTTP 请求的时间的,换言之,只要 RabbitMQ 承受并发的能力超过你的 HTTP 服务的承受并发的能力,RabbitMQ 就永远不会崩,通过横向扩展 RabbitMQ 很容易做到的。

和传统 PHP 相比

  • 对任何 PHP 方法通过反射进行异步执行;

  • 高可用,执行方法进入消息队列,可持久化,即使服务器宕机,执行任务也不丢失;

  • 高可用,对异常可以进行不限次数和时间的重试,重试次数和时间可配置;

  • 支持对多个异步方法包含在事务中执行,支持回滚事务;

  • 方法的参数类型支持除资源类型(resource)和回调函数(callable)外的任意类型的参数;

  • Dank AMQP können asynchrone Methoden hoher Parallelität und hoher Last standhalten und Clusterbereitstellung und horizontale Erweiterung unterstützen

  • Geringe Latenz, gemessene Latenzzeit 0,016; ~ 0,021 s;

  • Anwendbar für: tägliche Datenbankoperationen, Protokollerfassung, Finanztransaktionen, Nachrichten-Push, Senden von E-Mails und Textnachrichten, Datenimport und -export, Berechnung großer Datenmengen Berichte erstellen;

Verwandte Empfehlungen:

Detaillierte Erläuterung, wie Laravel Supervisor implementiert, um asynchrone Prozesse auszuführen

Supervisor in Laravel im PHP-Framework implementieren. Führen Sie einen asynchronen Prozess aus

Die Methode zum Implementieren von Supervisor, um einen asynchronen Prozess im Laravel-Framework auszuführen

Das obige ist der detaillierte Inhalt vonAusführliche Erläuterung des Beispiels für den asynchronen PHP-Prozess Async-Helper. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

AI Hentai Generator

AI Hentai Generator

Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
2 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Repo: Wie man Teamkollegen wiederbelebt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Abenteuer: Wie man riesige Samen bekommt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

CakePHP-Projektkonfiguration CakePHP-Projektkonfiguration Sep 10, 2024 pm 05:25 PM

In diesem Kapitel werden wir die Umgebungsvariablen, die allgemeine Konfiguration, die Datenbankkonfiguration und die E-Mail-Konfiguration in CakePHP verstehen.

PHP 8.4 Installations- und Upgrade-Anleitung für Ubuntu und Debian PHP 8.4 Installations- und Upgrade-Anleitung für Ubuntu und Debian Dec 24, 2024 pm 04:42 PM

PHP 8.4 bringt mehrere neue Funktionen, Sicherheitsverbesserungen und Leistungsverbesserungen mit einer beträchtlichen Menge an veralteten und entfernten Funktionen. In dieser Anleitung wird erklärt, wie Sie PHP 8.4 installieren oder auf PHP 8.4 auf Ubuntu, Debian oder deren Derivaten aktualisieren. Obwohl es möglich ist, PHP aus dem Quellcode zu kompilieren, ist die Installation aus einem APT-Repository wie unten erläutert oft schneller und sicherer, da diese Repositorys in Zukunft die neuesten Fehlerbehebungen und Sicherheitsupdates bereitstellen.

CakePHP Datum und Uhrzeit CakePHP Datum und Uhrzeit Sep 10, 2024 pm 05:27 PM

Um in cakephp4 mit Datum und Uhrzeit zu arbeiten, verwenden wir die verfügbare FrozenTime-Klasse.

CakePHP-Datei hochladen CakePHP-Datei hochladen Sep 10, 2024 pm 05:27 PM

Um am Datei-Upload zu arbeiten, verwenden wir den Formular-Helfer. Hier ist ein Beispiel für den Datei-Upload.

CakePHP-Routing CakePHP-Routing Sep 10, 2024 pm 05:25 PM

In diesem Kapitel lernen wir die folgenden Themen im Zusammenhang mit dem Routing kennen.

Besprechen Sie CakePHP Besprechen Sie CakePHP Sep 10, 2024 pm 05:28 PM

CakePHP ist ein Open-Source-Framework für PHP. Es soll die Entwicklung, Bereitstellung und Wartung von Anwendungen erheblich vereinfachen. CakePHP basiert auf einer MVC-ähnlichen Architektur, die sowohl leistungsstark als auch leicht zu verstehen ist. Modelle, Ansichten und Controller gu

So richten Sie Visual Studio-Code (VS-Code) für die PHP-Entwicklung ein So richten Sie Visual Studio-Code (VS-Code) für die PHP-Entwicklung ein Dec 20, 2024 am 11:31 AM

Visual Studio Code, auch bekannt als VS Code, ist ein kostenloser Quellcode-Editor – oder eine integrierte Entwicklungsumgebung (IDE) –, die für alle gängigen Betriebssysteme verfügbar ist. Mit einer großen Sammlung von Erweiterungen für viele Programmiersprachen kann VS Code c

CakePHP erstellt Validatoren CakePHP erstellt Validatoren Sep 10, 2024 pm 05:26 PM

Der Validator kann durch Hinzufügen der folgenden zwei Zeilen im Controller erstellt werden.

See all articles