Download the PHP package jarviscdr/webman-rabbitmq without Composer
On this page you can find all versions of the php package jarviscdr/webman-rabbitmq. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Download jarviscdr/webman-rabbitmq
More information about jarviscdr/webman-rabbitmq
Files in jarviscdr/webman-rabbitmq
Package webman-rabbitmq
Short Description Webman plugin workbunny/webman-rabbitmq
License MIT
FAQ
Example:
In general, it is recommended to use always a project to download your libraries. In an application normally there is more than one library needed.
- Some hosting areas are not accessible by a terminal or SSH. Then it is not possible to use Composer.
- To use Composer is sometimes complicated. Especially for beginners.
- Composer needs much resources. Sometimes they are not available on a simple webspace.
- If you are using private repositories you don't need to share your credentials. You can set up everything on our site and then you provide a simple download link to your team member.
- Simplify your Composer build process. Use our own command line tool to download the vendor folder as binary. This makes your build process faster and you don't need to expose your credentials for private repositories.
Informations about the package webman-rabbitmq
基于workbunny/webman-rabbitmq修改而来，主要是为了增加一个NACK且不重新入队的场景
workbunny/webman-rabbitmq
🐇 A PHP implementation of RabbitMQ Client for webman plugin. 🐇
A PHP implementation of RabbitMQ Client for webman plugin
常见问题
-
什么时候使用消息队列？
当你需要对系统进行解耦、削峰、异步的时候；如发送短信验证码、秒杀活动、资产的异步分账清算等。
-
RabbitMQ和Redis的区别？
Redis中的Stream的特性同样适用于消息队列，并且也包含了比较完善的ACK机制，但在一些点上与RabbitMQ存在不同：
- Redis Stream没有完善的后台管理；RabbitMQ拥有较为完善的后台管理及Api；
- Redis的持久化策略取舍：默认的RDB策略极端情况下存在丢失数据，AOF策略则需要牺牲一些性能；RabbitMQ持久化方案更多，可对消息持久化也可对队列持久化；
- RabbitMQ拥有更多的插件可以提供更完善的协议支持及功能支持；
-
什么时候使用Redis？什么时候使用RabbitMQ？
当你的队列使用比较单一或者比较轻量的时候，请选用 Redis Stream；当你需要一个比较完整的消息队列体系，包括需要利用交换机来绑定不同队列做一些比较复杂的消息任务的时候，请选择RabbitMQ；
当然，如果你的队列使用也比较单一，但你需要用到一些管理后台相关系统化的功能的时候，又不想花费太多时间去开发的时候，也可以使用RabbitMQ；因为RabbitMQ提供了一整套后台管理的体系及 HTTP API 供开发者兼容到自己的管理后台中，不需要再消耗多余的时间去开发功能；
注：这里的 轻量 指的是 无须将应用中的队列服务独立化，该队列服务是该应用独享的
简介
RabbitMQ的webman客户端插件；
- 支持5种消费模式：简单队列、workQueue、routing、pub/sub、exchange；
- 支持延迟队列（rabbitMQ须安装插件）；
- 异步无阻塞消费、异步无阻塞生产、同步阻塞生产；
安装
配置
使用
- 2.x与1.x在Builder结构有着较大的变化，1.x文档
- 2.x已生产可用
QueueBuilder
- 可实现官网的5种消费模式
命令行
-
创建
- 移除
移除包含了类文件的移除和配置的移除
- 关闭
关闭仅对配置进行移除
注意
- 创建的Builder类可以手动修改调整
- 为Builder添加进process.php的配置可以手动修改
-
延迟队列需要为 rabbitMQ 安装 rabbitmq_delayed_message_exchange 插件
-
进入 rabbitMQ 的 plugins 目录下执行命令下载插件（以rabbitMQ 3.8.x举例）：
- 执行安装命令
-
查看Builder
注：当 Builder 未启动时，handler 与 count 显示为 --
生产
- 每个builder各包含一个连接，使用多个builder会创建多个连接
- 生产消息默认不关闭当前连接
- 异步生产的连接与消费者共用
1. 同步发布消息
该方法会阻塞等待至消息生产成功，返回bool
- 发布普通消息
注：向延迟队列发布普通消息会抛出一个 WebmanRabbitMQException 异常
- 发布延迟消息
注：向普通队列发布延迟消息会抛出一个 WebmanRabbitMQException 异常
2. 异步发布消息
该方法不会阻塞等待，立即返回 React\Promise， 可以利用 React\Promise 进行 wait； 也可以纯异步不等待，React\Promise 项目地址；
- 发布普通消息
注：向延迟队列发布普通消息会抛出一个 WebmanRabbitMQException 异常
- 发布延迟消息
注：向普通队列发布延迟消息会抛出一个 WebmanRabbitMQException 异常
自定义Builder
-
创建自定义Builder需继承实现AbstractBuilder；
- onWorkerStart 消费进程启动时会触发，一般用于实现基础消费逻辑；
- onWorkerStop 消费进程结束时会触发，一般用于回收资源；
- onWorkerReload 消费进程重载，一般可置空；
- classContent 用于配合命令行自动生成BuilderClass；
-
Builder会创建Connection，每个Connection会分别创建一个同步RabbitMQ客户端连接和一个异步客户端RabbitMQ连接；
- 不同的Builder默认不复用Connection，配置选项reuse_connection可开启复用Connection；
- 复用Connection可以减少创建的RabbitMQ-Client连接数，但一定程度上会降低并发能力
- 复用不影响消费者，不影响跨进程的生产者
- 复用仅影响当前进程内的不同Builder的生产者
说明
- 生产可用，欢迎 issue 和 PR；
- Message 可以理解为队列、交换机的配置信息；
- 继承实现 AbstractMessage 可以自定义Message；
- Builder 可通过 Builder->setMessage() 可设置自定义配置；
- 可使用 SyncClient 或 AsyncClient 自行实现一些自定义消费/自定义生产的功能；
