统一 API
publish、receive、consume、ack 与 reject 共用一套调用方式。
一套 API 收纳二十种消息系统
messaging-php 用纯 PHP 实现消息发布与消费，TCP 走 stream_socket_client，云服务走 Guzzle，不依赖 broker SDK 或扩展。
20 个产品名收敛为 13 套协议栈，切换 broker 通常只需修改 driver 与连接配置，业务代码保持不变。
- 统一 Manager 门面
- 20 个驱动名已实现
- 六框架可选适配
20覆盖系统
20已实现驱动
v1.8.1当前版本
小递
一台圆滚滚的浅蓝白色机器人信使，深色屏幕上亮着青色像素眼睛，头顶蓝色纸飞机天线，围着 PHP 紫围巾，胸口有信封投递口和三盏蓝、青、紫状态灯，正抬起右手打招呼。
信号满格，消息必达。从发布到确认的能力
统一契约、能力声明与纯 PHP 传输，一套代码适配多种 broker。
纯 PHP 传输
TCP 走 stream_socket_client，协议编解码全部用 PHP 实现。
能力模型
capabilities() 运行时查询，不支持的能力抛异常，不静默降级。
框架适配
Laravel、ThinkPHP、webman、Hyperf、Yii2 与 Yii3；Composer 安装时自动复制各框架配置。
连接管理
default 加 connections 配置，连接按名缓存，并提供 disconnect() 重连。
四层测试
742 项单元/协议测试，加假 broker、契约与重型 Docker 集成矩阵。
功能是这样长出来的
最近四次驱动里程碑，从 P2 到 P5。
v1.8.0
审计修复与真实 broker
RocketMQ 心跳/位点、Manager 重连、Pulsar 兼容与 CI 加固。
v1.7.0
框架配置自动复制
Composer Plugin 按框架规则复制配置，Yii3 自动合并。
v1.6.0
20 个驱动名全部实现
Pulsar 与 RocketMQ 上线，覆盖全部 20 个系统。
v1.5.0
Kafka 家族驱动
Kafka、Redpanda、AutoMQ、Confluent、Event Hubs 共用协议栈。
架构与设计
点击图片放大查看。
安装与使用
先安装，再用 Redis Streams 跑通发布、消费与确认。
安装
composer config allow-plugins.erikwang2013/messaging-php true
composer require erikwang2013/messaging-php最小示例
use Erikwang2013\Messaging\Contract\Message;
use Erikwang2013\Messaging\Contract\ReceiveOptions;
use Erikwang2013\Messaging\Manager;
$mq = new Manager([
'default' => 'redis',
'connections' => [
'redis' => [
'driver' => 'redis',
'host' => '127.0.0.1',
'port' => 6379,
'group' => 'orders',
],
],
]);
$connection = $mq->connection();
$connection->publish('orders', Message::json(['id' => 1]));
while ($message = $connection->receive('orders', new ReceiveOptions(timeoutMs: 5000))) {
$message->ack();
}小递的十二种动态表情
每个表情都有细微动画，鼠标停一停。