最近在开发一个新的应用,有需要用到rabbitmq,workbunny大佬的插件很好用
记录一下如何使用重试机制,这对于消息消费失败很有用
按照文档需要开启延迟队列插件 [workbunny/webman-rabbitmq](https://www.workerman.net/plugin/67)
首先我创建了2个消费者
SendForgetPassWordEmailBuilder.php ===> 发送忘记密码邮箱发送忘记密码邮箱消费者
<?```
------------
```php
# 使用主队列重试消费 不使用延迟队列进行重试消费
<?$sync_publish) {
throw new ServiceException('发送忘记密码邮件失败,请稍后重试');
}
```
------------
效果图:
!