Laravel에서 Observer 이벤트를 사용하면 Redis 대기열 예외 문제가 발생합니다.

藏色散人
풀어 주다: 2021-12-03 09:33:48
앞으로
2314명이 탐색했습니다.

라라벨 옵저버로 인해 발생하는 Redis 큐 예외에 대한 기록을 Laravel의 튜토리얼 칼럼에서 공유해드리도록 하겠습니다.

1. 비즈니스 로직

새 모델을 생성한 후 Created Observer 모델 이벤트를 사용하여 비동기 SMS 전송 대기열로 푸시합니다

AppHttpControllersUsersControllerAppHttpControllersUsersController

    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... ,在社区文档似乎并没有找到相关说明~

由于我的版本是 6.x 所以用不了这个新特性[哭唧唧]~~

4、解决异常

1. 修改 MySQL 事务隔离级别(不推荐)

这里涉及到 MySQL 的事务隔离级别,InnoDB 引擎的默认隔离级别是 REPEATABLE READ,关于各个级别的区别可以在 官方文档 找到。

将隔离级别切换到 READ UNCOMMITTED 即可解决此问题,但是为了防止出现更大的问题我劝你别用这种方式~

2. 增加事件监听

查看源码得知在事务完成之后,会调用对应的事件,所以只需增加对事件的监听即可。

Laravel에서 Observer 이벤트를 사용하면 Redis 대기열 예외 문제가 발생합니다.

  1. 新增类 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 = [];
        }}
    로그인 후 복사
  2. 创建辅助函数  app/helpers.php

    if (! function_exists('after_transaction')) {
        /*
         * 事务结束之后再进行操作
         * */
        function after_transaction(Closure $job)
        {
            app()->singletonIf(\App\Handlers\TransactionHandler::class, function (){
                return new \App\Handlers\TransactionHandler();
            });
            app(\App\Handlers\TransactionHandler::class)->add($job);
        }}
    로그인 후 복사
  3. 创建监听  AppListenersTransactionListener

    namespace App\Listeners;use App\Handlers\TransactionHandler;class TransactionListener{
        public function handle()
        {
            app(TransactionHandler::class)->run();
        }}
    로그인 후 복사
  4. 绑定监听 AppProvidersEventServiceProvider

    namespace App\Providers;use App\Listeners\TransactionListener;use Illuminate\Database\Events\TransactionCommitted;use Illuminate\Database\Events\TransactionRolledBack;use Illuminate\Foundation\Support\Providers\EventServiceProvider 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
            ]
        ];}
    로그인 후 복사
  5. 更改调用方式  AppObserversUserObserver

    class UserObserver{
        public function created (User $user)
        {
            after_transaction(function() use ($user) {
                dispatch(new SmsQueue($user));
            });
        }}
    로그인 후 복사
    AppObserversUserObserver
  6. rrreee

2. 예외가 발견되었습니다
사업부에서 가끔 사용자가 SMS 알림을 받을 수 없다고 보고하여 로그를 확인해보니 가끔 [AppModelsUser] 모델에 대한 쿼리 결과가 없습니다. 해당 모델을 찾을 수 없다는 뜻입니다
Me 맞지 않아야 합니다. 모델을 생성한 후 대기열 호출을 했습니다... 그리고 비즈니스 코드를 주의 깊게 확인하여 거래에 영향을 받은 것으로 추측했습니다. 🎜🎜추측 검증:🎜rrreee🎜 물론 3초를 기다린 후 제출 대기열 예외가 100% 발생합니다. 🎜🎜🎜🎜3. 원인 분석🎜
  • 🎜$user->save() 이 메서드로 데이터가 성공적으로 생성되면 스케줄러도 실행됩니다. .모델 이벤트를 하나씩 실행합니다. 🎜🎜
  • 🎜이벤트에서 모델을 대기열에 푸시하면 대기열 프로세스가 대기열의 데이터를 지속적으로 소비합니다. 🎜🎜
  • 🎜대부분의 경우 do Something 처리 속도가 정상이라면 대기열 프로세스는 평소대로 실행됩니다. 🎜🎜
  • 🎜Do Something 단계에서 간헐적으로 지연이 발생하는 경우 트랜잭션이 아직 커밋되지 않았지만 대기열이 이미 새 모델을 사용하기 시작했기 때문에 위 오류가 발생합니다. 🎜🎜
🎜Github Issues 기록을 검색해보니 이 문제가 2015년 이슈에서 제기된 것을 발견했고, 마침내 Laravel 8.X learnku.com /docs에 트랜잭션 모델 이벤트에 대한 지원이 추가되었습니다. /laravel/8.x/eloqu... 커뮤니티 문서에서 관련 지침을 찾을 수 없는 것 같습니다~🎜🎜제 버전이 6.x이므로 이 새로운 기능을 사용할 수 없습니다 [울음]~~🎜 🎜🎜🎜 4. 예외 해결🎜

🎜🎜1. MySQL 트랜잭션 격리 수준 수정(권장하지 않음)

🎜여기에는 MySQL의 트랜잭션 격리 수준이 포함됩니다. InnoDB 엔진의 기본 격리 수준은 REPEATABLE입니다. 읽기 레벨 간의 차이점은 공식 문서에서 확인할 수 있습니다. 🎜🎜isolation level을 READ UNCOMMITTED로 바꾸면 해결이 되지만, 더 큰 문제를 방지하기 위해서는 이 방법을 사용하지 않는 것이 좋습니다~🎜

🎜🎜2.이벤트 모니터링 추가

🎜소스코드 보기 트랜잭션이 완료된 후 해당 이벤트가 호출된다는 것을 알고 있으므로 이벤트에 대한 모니터링만 추가하면 됩니다. 🎜🎜Laravel에서 Observer 이벤트를 사용하면 Redis 대기열 예외 문제가 발생합니다.🎜
  1. 🎜새 클래스 AppHandlersTransactionHandler🎜rrreee🎜
  2. 🎜도우미 함수 만들기 app/helpers.php🎜rrreee🎜
  3. 🎜리스너 만들기 AppListenersTransactionListener 🎜rrreee🎜
  4. 🎜Bind 리스너AppProvidersEventServiceProvider🎜rrreee🎜
  5. 🎜호출 메서드 변경 AppObserversUserObserver🎜🎜🎜rrreee🎜OK, 우아한 The 솔루션이 완성되었습니다~~🎜🎜관련 권장 사항: 🎜최신 5개의 Laravel 비디오 튜토리얼🎜🎜

위 내용은 Laravel에서 Observer 이벤트를 사용하면 Redis 대기열 예외 문제가 발생합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:learnku.com
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿