通过 
搜索
搜索php-mq / server
PHP 消息队列服务器
dev-master
2018-01-01 21:48 UTC
Requires
- php: >=7.1
- php-mq/protocol: dev-master
- php-mq/stream: dev-master
- psr/log: ~1.0.2
- roave/security-advisories: dev-master
Requires (Dev)
- tm/tooly-composer-script: ^1.0
This package is auto-updated.
Last update: 2024-09-10 04:31:39 UTC
README
PHPMQ\MessageQueueServer
一个轻量级的 PHP 消息队列
目前这是一个概念验证实现。
描述
本实现旨在满足以下要求。
有关客户端端点通信的详细信息，请参阅协议文档。
消息端点
- 通过网络或 Unix 域套接字建立通信端点。（两者都应可行）
- 接受对该端点的连接，并持续接收来自客户端的消息
消息发送者
- 可以连接/断开与消息端点的连接
- 可以请求一个命名队列
- 可以向队列发送任意数量的消息
消息队列
- 根据发送者的请求创建命名队列
- 按需刷新队列
- 释放已确认的消息
- 提供现有队列的状态反馈
- 先进先出
消息持久化
- 将传入的消息持久化到 SQLite3 内存存储
- 将 SQLite3 内存存储镜像到 SQLite3 文件存储以在重新启动后保持消息
- 在后台将镜像到文件存储以保持持久化快速
消息消费者
- 可以连接/断开与消息端点的连接
- 可以从一个或多个命名队列中消费可变数量的消息
- 必须确认已消费的消息以将其从队列中释放
消息分发
- 将消息均匀分配给所有连接的消费者
- 在消费者断开/连接时重新分配分配
- 如果消息已被分发但未确认且相应的消费者断开连接，则将消息发送给其他消费者
贡献
欢迎贡献，并将得到全额认可。有关详细信息，请参阅贡献指南。