PHP实现异步通信消息队列实例

使用PHP结合Redis、RabbitMQ或数据库可实现异步消息队列。1、Redis通过LPUSH与BRPOP命令实现轻量级任务队列，适合高性能场景；2、RabbitMQ基于AMQP协议提供可靠消息传递，支持持久化与路由，适用于复杂业务；3、数据库模拟队列则通过状态字段轮询处理，适合低并发无中间件环境。三种方案均需保持消费者常驻或定时执行，以保障任务及时处理。

如果您在开发Web应用时需要处理耗时任务，如发送邮件、处理图片或调用第三方API，直接在请求中执行这些操作会导致响应延迟。通过PHP实现消息队列可以将这些任务异步化，提升系统性能和用户体验。以下是基于PHP的消息队列应用实例及异步通信的实现方式。

本文运行环境：Ubuntu Server，PHP 8.2

一、使用Redis作为消息队列中间件

Redis提供了高效的键值存储和列表结构，适合用作轻量级消息队列。生产者将任务推入列表，消费者从列表中取出并执行。

1、安装Redis扩展：使用命令 sudo apt install php-redis 安装PHP Redis扩展。

2、创建生产者脚本：编写一个PHP脚本，使用 LPUSH 命令将任务数据以JSON格式推入Redis队列。

3、编写消费者脚本：使用 BRPOP 阻塞式读取队列中的任务，解码后执行具体逻辑。

4、启动消费者进程：在后台运行消费者脚本，例如通过 nohup php worker.php & 持续监听任务。

二、集成RabbitMQ实现高级消息队列协议

RabbitMQ是功能完整的AMQP消息代理，支持消息确认、持久化、路由等特性，适用于复杂场景下的异步通信。

1、安装RabbitMQ服务器：使用包管理器安装RabbitMQ服务，并确保其正在运行。

2、安装php-amqplib库：通过Composer引入官方推荐的客户端库，执行命令 composer require php-amqplib/php-amqplib。

3、编写发布者代码：实例化连接和通道，声明交换机与队列，绑定关系后发送消息。

4、实现消费者逻辑：建立通道并声明相同的队列，调用 basic_consume 方法注册回调函数处理 incoming 消息。

5、保持常驻进程：消费者需长期运行，可通过Supervisor监控进程状态防止意外退出。

三、利用数据库模拟队列表实现简单队列

当无法部署外部消息中间件时，可使用MySQL等关系型数据库模拟队列行为，适用于低并发环境。

1、设计任务表结构：创建包含字段如id、job_type、payload、status、created_at、processed_at的数据表。

2、插入新任务：在主业务逻辑中执行SQL语句，将待处理任务写入表中，状态设为 pending。

3、编写轮询脚本：使用PHP CLI脚本定期查询状态为 pending 的记录，并按顺序处理。

4、更新处理状态：每处理完一条任务，将其 status 改为 completed，并记录 processed_at 时间戳。

5、设置执行间隔：使用cron定时任务每分钟执行一次消费者脚本，避免频繁查询影响性能。