下面由laravel教程栏目带大家分享记录关于laravel observer 导致 redis 队列异常问题，希望对大家有所帮助！
1、业务逻辑
新建某个模型之后，利用 Observer 模型事件 Created 推入异步短信发送队列
AppHttpControllersUsersController
public function store(User $user) { DB::beginTransaction(); try{ $input = request()->validated(); $user->fill($input); $user->save(); //do something...... //其他数据表操作 DB::commit(); } catch ($e Exception) { DB::rollBack(); } }
AppObserversUserObserver
class UserObserver{ public function created (User $user) { dispatch(new SmsQueue($user)); }}
2、发现异常
业务部门反馈偶尔有用户收取不到短信通知，我便查看日志发现偶尔有错误异常：No query results for model [AppModelsUser]. 表示找不到对应的模型
我敲不应该啊，我是在创建模型之后再进行队列调用……，遂对业务代码再进行仔细核查猜测应该是受事务影响。
验证猜想：
public function store(User $user) { DB::beginTransaction(); try{ $input = request()->validated(); $user->fill($input); $user->save(); //do something...... //其他数据表操作 sleep(3); //三秒之后再提交事务 DB::commit(); } catch ($e Exception) { DB::rollBack(); } }
果然在等待三秒之后提交队列异常已是 100% 触发。
3、原因分析
$user->save() 这个方法创建数据成功，便会一并触发调度器，将模型事件一一执行。
在事件中推送模型至队列中，而队列进程在不间断消费队列中数据。
在大部分情况下 do something 处理速度正常的话，队列进程将会照常运行。
如果在 do something 阶段偶尔出现延迟，造成事务还未 commit 而队列已经开始消费新模型；故引发上述错误。
然后我在搜索 Github Issues 记录时，发现此问题在 2015 年的一个 Issue 已经有人提出，而在 Laravel 8.X 中终于新增了对事务模型事件的支持；learnku.com/docs/laravel/8.x/eloqu… ，在社区文档似乎并没有找到相关说明~
问问小宇宙
问问小宇宙是小宇宙团队出品的播客AI检索工具
77 查看详情 
由于我的版本是 6.x 所以用不了这个新特性[哭唧唧]~~
4、解决异常
1. 修改 MySQL 事务隔离级别（不推荐）
这里涉及到 MySQL 的事务隔离级别，InnoDB 引擎的默认隔离级别是 REPEATABLE READ，关于各个级别的区别可以在 官方文档 找到。
将隔离级别切换到 READ UNCOMMITTED 即可解决此问题，但是为了防止出现更大的问题我劝你别用这种方式~
2. 增加事件监听
查看源码得知在事务完成之后，会调用对应的事件，所以只需增加对事件的监听即可。
新增类 AppHandlersTransactionHandler
class TransactionHandler{ public array $handlers; public function __construct() { $this->handlers = []; } public function add(Closure $handler) { $this->handlers[] = $handler; } public function run() { foreach ($this->handlers as $handler) { $handler(); } $this->handlers = []; }}
创建辅助函数 app/helpers.php
if (! function_exists('after_transaction')) { /* * 事务结束之后再进行操作 * */ function after_transaction(Closure $job) { app()->singletonIf(AppHandlersTransactionHandler::class, function (){ return new AppHandlersTransactionHandler(); }); app(AppHandlersTransactionHandler::class)->add($job); }}
创建监听 AppListenersTransactionListener
namespace AppListeners;use AppHandlersTransactionHandler;class TransactionListener{ public function handle() { app(TransactionHandler::class)->run(); }}
绑定监听 AppProvidersEventServiceProvider
namespace AppProviders;use AppListenersTransactionListener;use IlluminateDatabaseEventsTransactionCommitted;use IlluminateDatabaseEventsTransactionRolledBack;use IlluminateFoundationSupportProvidersEventServiceProvider as ServiceProvider;;class EventServiceProvider extends ServiceProvider{ /** * The event listener mappings for the application. * * @var array */ protected $listen = [ TransactionCommitted::class => [ TransactionListener::class ], TransactionRolledBack::class => [ TransactionListener::class ] ];}
更改调用方式 AppObserversUserObserver
class UserObserver{ public function created (User $user) { after_transaction(function() use ($user) { dispatch(new SmsQueue($user)); }); }}
OK，一个优雅的解决方式就完成了~~
相关推荐：最新的五个Laravel视频教程
以上就是Laravel中用Observer事件致Redis队列异常问题的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/344000.html
微信扫一扫 
支付宝扫一扫 
