如何处理Laravel的排队活动听众？

实施应该启用排队的时间； 2。使用PHP Artisan Make：侦听器 - 以自动设置为名； 3.确保仅使用可序列化的数据（例如雄伟的模型或原语）来防止序列化问题； 4。通过$ Connection，$ queue，$ delay或诸如OnConnection（），onqueue（），delay（）之类的方法自定义队列行为，例如5。使用FAILED（）方法处理故障，并使用$ TRISE，$ backoff或backoff（）进行控制重试； 6。使用Event :: facefor（）或有条件逻辑时同步派遣事件； 7.遵循最佳实践，通过保留排队来完成繁重的任务，保持听众专注，避免过度招募，监视性能和测试序列化，以确保在Laravel应用程序中的最佳性能和可靠性。

在Laravel中，排队的事件听众允许您推迟执行重型或耗时的逻辑（例如发送电子邮件，拨打API呼叫或处理数据），直到主要请求周期完成后。这可以改善响应时间和整体应用程序性能。

这是如何正确处理Laravel中排队的活动听众的方法：

1。让听众实施应有

为了排队事件侦听器，您的侦听器类必须实现Illuminate\Contracts\Queue\ShouldQueue接口。

使用Illuminate \ Contracts \ queue \ sysequeue;

sendwelcomeemail工具应应
{
    //这个听众现在排队
}

射击事件时，Laravel将自动将侦听器作业派遣到队列。

2。与工匠一起生成可公开的听众

通过工匠创建听众时，请使用--queued标志：

 PHP Artisan Make：听众sendwelcomeemail-标题

这会产生一个已经实现ShouldQueue的听众。

3。处理依赖和序列化

排队的侦听器被序列化并存储在队列中，因此您必须谨慎注入构造函数或存储为属性。

• 仅包括可序列化数据（例如，雄辩的模型实例，原始类型）。
• 避免注入封闭，PDO实例或不可隔离的对象。

Laravel通过仅存储其主要钥匙并在作业运行时重新撤回雄伟的模型来自动处理雄辩的模型。

公共功能__construct（public用户$用户）{}

之所以安全，是因为Laravel仅序列化模型的ID并在处理作业时将其重新提及。

4。控制队列连接，队列名称和延迟

您可以使用听众中的公共属性或方法自定义队列行为：

 sendwelcomeemail工具应应
{
    public $ connection ='redis';
    public $ queue ='电子邮件';
    公共$ delay = 60; //延迟工作60秒

    公共功能句柄（用户注册$ event）
    {
        //发送电子邮件逻辑
    }
}

另外，请使用诸如onConnection() ， onQueue()或delay()之类的方法（例如，在EventServiceProvider中）：

受保护$ listen = [
    用户注册:: class => [
        sendwelcomeemail ::班级，
    ]，，
];

//或动态：
事件::听（userregistered :: class，sendwelcomeemail :: class）;

//自定义：
事件::听（userregistered :: class，function（$ event）{
    sendwelcomeemail :: dispatch（$ event->用户）
         - > onconnection（'redis'）
         - > onqueue（'电子邮件'）
         - > delay（现在（） - > addminutes（5））;
}）;

注意：此方法与工作相比，与听众更好。对于细粒度的控制，请考虑使用排队的作业代替听众。

5。错误处理和重试逻辑

排队的听众遵循标准队列工作行为：

• 失败的作业如果配置为failed_jobs表。
• 您可以定义failed()方法来处理失败：

公共功能失败（$ event，$ exception）
{
    //日志错误，通知管理员，等。
}

设置重试延迟或最大尝试：

 public $ tries = 3;
public $ backoff = 10; //等待10秒之前重试

或使用方法：

公共功能向后（）
{
    返回[5，10，15]; //增加延迟
}

6。在需要时同步调度事件

有时，您需要立即运行听众（例如，在测试或特定上下文中）。使用：

事件（新的用户注册（$ user））; //通过队列发射排队的听众

或同步派遣：

事件:: dispatch（新的用户注册（$ user））; //除非听众不应该使用，否则仍然使用队列

//强制同步：暂时禁用排队
事件:: fackfor（function（）{
    事件（新的用户注册（$ user））; //立即运行
}）;

另外，请勿在本地/测试期间或有条件地派遣时实现ShouldQueue 。

7。最佳实践

• 使用排队的听众进行缓慢的任务：电子邮件，通知，分析，网络钩。
• 保持听众专注：每个听众的责任。
• 避免过度招募：轻量级逻辑（例如，日志记录）应在线运行。
• 监视队列性能：使用Horizon或Scout跟踪作业吞吐量。
• 彻底测试：确保序列化工作和模型不会丢失。

概括

有效处理排队的事件听众：

• 实施ShouldQueue
• 使用工匠生成它们
• 谨慎
• 根据需要自定义队列设置
• 处理失败并进行检索
• 知道何时排队与同步运行

排队的听众很强大，但应明智地使用。如有疑问，请考虑从听众中派遣专门的排队工作，而不是将复杂的逻辑直接放在其中。

基本上，Laravel使它变得容易了 - 只是添加了ShouldQueue ，其余的由队列系统处理。

以上是如何处理Laravel的排队活动听众？的详细内容。更多信息请关注PHP中文网其他相关文章！