使用中は非常に優れていると思います。
shmilyzxt/yii2-queue
簡単な説明:shmilyzxt/yii2-queue
简单解释:
我用的yii2高级版,我们从配置开始看代码,这里我用的是mysql队列,首先配置文件,我把
queue
配置项写在根目录commonconfigmain-local.php
下的components
数组下,更改一下数据库配置.复制composer
安装后复制vendorshmilyzxtyii2-queuejobsjobs.sql
vendorshmilyzxtyii2-queuefailedfailed.sql
2个sql文件到数据库中建立队列数据表和执行任务失败时的数据表.推送任务开始语法:
Yii::$app->queue->pushOn(new SendMial(),['email'=>'49783121@qq.com','title'=>'test','content'=>'email test'],'email');
我们到vendorshmilyzxtqueuequeuesDatabaseQueue.php
去看看代码,pushOn()
方法写在了DatabaseQueue
类的父类vendorshmilyzxtqueuebaseQueue.php
中:
//入队列public function pushOn($job, $data = '', $queue = null) { //canPush 检查队列是否已达最大任务量 if ($this->canPush()) { //beforePush 入队列前的事件 $this->trigger(self::EVENT_BEFORE_PUSH); //入队列 $ret = $this->push($job, $data, $queue); //afterPush 入队列后的事件 $this->trigger(self::EVENT_AFTER_PUSH); return $ret; } else { throw new \Exception("max jobs number exceed! the max jobs number is {$this->maxJob}"); } }
注释:这里最好去看看yii2 event事件类.
关于入队列: $this->push($job, $data, $queue);
,这里在配合queue
类文件查看,相关函数跳转,处理一下数据记录到数据库中.(函数走向:getQueue()-->createPayload()-->pushToDatabase()
),pushOn()
最终返回数据插入数据库的结果,成功$ret
是1.
3.后台运行命令处理队列,例:php ./yii worker/listen default 10 128 3 0
其中default
是队列的名称,上面推送了一个email
队列 应该改为email
.
启动命令后,我们来看代码:首先执行:WorkerController
控制器 actionListen
方法,我们跟着代码进入到 vendorshmilyzxtqueueWorker.php -- listen
方法中,这里其实就是一直在循环,执行操作队列的任务:
/** * 启用一个队列后台监听任务 * @param Queue $queue * @param string $queueName 监听队列的名称(在pushon的时候把任务推送到哪个队列,则需要监听相应的队列才能获取任务) * @param int $attempt 队列任务失败尝试次数,0为不限制 * @param int $memory 允许使用的最大内存 * @param int $sleep 每次检测的时间间隔 */ public static function listen(Queue $queue, $queueName = 'default', $attempt = 10, $memory = 512, $sleep = 3, $delay = 0){ while (true){ try{ //DatabaseQueue从数据库队列取出一个可用任务(实例),并且更新任务 $job = $queue->pop($queueName); }catch (\Exception $e){ throw $e; continue; } if($job instanceof Job){ //判断执行错误的次数是否大于传入的执行次数 if($attempt > 0 && $job->getAttempts() > $attempt){ $job->failed(); }else{ try{ //throw new \Exception("test failed"); $job->execute(); }catch (\Exception $e){ //执行失败,判断是否被删除,重新入队 if (! $job->isDeleted()) { $job->release($delay); } } } }else{ self::sleep($sleep); } if (self::memoryExceeded($memory)) { self::stop(); } } }
注释:在$queue->pop($queueName);
是vendorshmilyzxtqueuequeuesDatabaseQueue.php
方法内使用事务执行SQL,并且创建vendorshmilyzxtqueuejobsDatabaseJob.php
的实例
//取出一个任务 public function pop($queue = null) { $queue = $this->getQueue($queue); if (!is_null($this->expire)) { //$this->releaseJobsThatHaveBeenReservedTooLong($queue); } $tran = $this->connector->beginTransaction(); //判断是否有一个可用的任务需要执行 if ($job = $this->getNextAvailableJob($queue)) { $this->markJobAsReserved($job->id); $tran->commit(); $config = array_merge($this->jobEvent, [ 'class' => 'shmilyzxt\queue\jobs\DatabaseJob', 'queue' => $queue, 'job' => $job, 'queueInstance' => $this, ]); return \Yii::createObject($config); } $tran->commit(); return false; }
至于:$job->execute();
是DatabaseJob
继承父类Job
执行的,顺着代码找下去是yiibaseComponent trigger
执行的事件,
/** * 执行任务 */ public function execute(){ //beforeExecute 执行任务之前的一个事件 在JobEvent中并没有什么可执行的代码 $this->trigger(self::EVENT_BEFORE_EXECUTE, new JobEvent(["job" => $this, 'payload' => $this->getPayload()])); $this->resolveAndFire();//真正执行的任务的方法 }
/** * 真正任务执行方法(调用hander的handle方法) * @param array $payload * @return void */ protected function resolveAndFire() { $payload = $this->getPayload(); $payload = unserialize($payload); //反序列化数据 $type = $payload['type']; $class = $payload['job']; if ($type == 'closure' && ($closure = (new Serializer())->unserialize($class[1])) instanceof \Closure) { $this->handler = $this->getHander($class[0]); $this->handler->closure = $closure; $this->handler->handle($this, $payload['data']); } else if ($type == 'classMethod') { $payload['job'][0]->$payload['job'][1]($this, $payload['data']); } else if ($type == 'staticMethod') { $payload['job'][0]::$payload['job'][1]($this, $payload['data']); } else {//执行的`SendMail`类的`handle($job,$data)`方法 $this->handler = $this->getHander($class); $this->handler->handle($this, $payload['data']); } //执行完任务后删除 if (!$this->isDeletedOrReleased()) { $this->delete(); } }
最后到了执行的SendMail
类的handle($job,$data)
yii2 アドバンスト バージョンを使用します。まず、mysql キューを使用して、queue というファイルを設定します。 code> 構成アイテムのルート ディレクトリ <code>commonconfigmain-local.php
の components
配列の下で、インストール後に composer
をコピーします。 vendorshmilyzxtyii2- queuejobsjobs.sql
vendorshmilyzxtyii2-queuefailedfailed.sql
🎜 2 つの SQL ファイルをデータベースに追加して、キュー データ テーブルとタスクが失敗したときのデータ テーブルを確立します。🎜🎜🎜 🎜プッシュタスク開始構文: Yii::$app->queue->pushOn(new SendMial(),['email'=>'49783121@qq.com','title'=>' test','content' =>'email test'],'email');
vendorshmilyzxtqueuequeuesDatabaseQueue.php
に移動して、pushOn のコードを見てみましょう。 ()
メソッドは DatabaseQueue に記述されています。 class is in vendorshmilyzxtqueuebaseQueue.php
: 🎜🎜public function handle($job,$data) { if($job->getAttempts() > 3){ $this->failed($job); } $payload = $job->getPayload(); echo '<pre class="brush:php;toolbar:false">';print_r($payload); //$payload即任务的数据,你拿到任务数据后就可以执行发邮件了 //TODO 发邮件 }🎜注:ここで yii2 イベント イベント クラスを確認するのが最善です。🎜🎜キューに入る:
$this->push($job, $data, $queue);
、ここで確認します。 queue
クラス ファイルを使用して、関連する関数にジャンプして処理します。データはデータベースに記録されます (関数の指示: getQueue()-->createPayload()-- >pushToDatabase()
)、pushOn()
は最終的にデータ挿入を返します。データベースの結果、成功した $ret
は 1.🎜🎜3 バックグラウンド実行です。コマンド処理キュー、例: php ./yii worker/listendefault 10 128 3 0
ここで、default
はキューの名前です。 > 上記でプッシュされたキューを email
に変更する必要があります。 コマンドを開始したら、コードを見てみましょう: まず、WorkerController
コントローラーの actionListen
メソッドを実行します。コードに従って、vendorshmilyzxtqueueWorker.php -- listen
メソッドを入力します。これは実際にはキュー タスクを実行し続けるループです: 🎜🎜🎜🎜rrreee🎜 注: $queue- >pop($queueName);
は、トランザクションを使用して SQL を実行する vendorshmilyzxtqueuequeuesDatabaseQueue.php
メソッドであり、vendorshmilyzxtqueuejobsDatabaseJob.php
のインスタンスを作成します🎜🎜🎜🎜 rrreee🎜: $job->execute();
については、DatabaseJob
が親クラスを継承して Job が実行されます。コードに従ってください。 yiibaseComponent トリガー
によって実行されたイベントを見つけます。🎜🎜🎜🎜rrreee🎜🎜🎜rrreee🎜 最後に、実行された SendMail
handle($job,$data) に到達します。 )
クラスの、ここにキューにプッシュされたオブジェクトとデータ、そして処理ロジックがあります。🎜🎜🎜🎜rrreee以上がPHPyii2 キューの概要 shmilyzxt/yii2-queueの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

PHPは、現代のWeb開発、特にコンテンツ管理とeコマースプラットフォームで依然として重要です。 1)PHPには、LaravelやSymfonyなどの豊富なエコシステムと強力なフレームワークサポートがあります。 2)パフォーマンスの最適化は、Opcacheとnginxを通じて達成できます。 3)PHP8.0は、パフォーマンスを改善するためにJITコンパイラを導入します。 4)クラウドネイティブアプリケーションは、DockerおよびKubernetesを介して展開され、柔軟性とスケーラビリティを向上させます。

PHPは、特に迅速な開発や動的なコンテンツの処理に適していますが、データサイエンスとエンタープライズレベルのアプリケーションには良くありません。 Pythonと比較して、PHPはWeb開発においてより多くの利点がありますが、データサイエンスの分野ではPythonほど良くありません。 Javaと比較して、PHPはエンタープライズレベルのアプリケーションでより悪化しますが、Web開発により柔軟性があります。 JavaScriptと比較して、PHPはバックエンド開発により簡潔ですが、フロントエンド開発のJavaScriptほど良くありません。

PHPとPythonにはそれぞれ独自の利点があり、さまざまなシナリオに適しています。 1.PHPはWeb開発に適しており、組み込みのWebサーバーとRich Functionライブラリを提供します。 2。Pythonは、簡潔な構文と強力な標準ライブラリを備えたデータサイエンスと機械学習に適しています。選択するときは、プロジェクトの要件に基づいて決定する必要があります。

PHPは、サーバー側で広く使用されているスクリプト言語で、特にWeb開発に適しています。 1.PHPは、HTMLを埋め込み、HTTP要求と応答を処理し、さまざまなデータベースをサポートできます。 2.PHPは、ダイナミックWebコンテンツ、プロセスフォームデータ、アクセスデータベースなどを生成するために使用され、強力なコミュニティサポートとオープンソースリソースを備えています。 3。PHPは解釈された言語であり、実行プロセスには語彙分析、文法分析、編集、実行が含まれます。 4.PHPは、ユーザー登録システムなどの高度なアプリケーションについてMySQLと組み合わせることができます。 5。PHPをデバッグするときは、error_reporting()やvar_dump()などの関数を使用できます。 6. PHPコードを最適化して、キャッシュメカニズムを使用し、データベースクエリを最適化し、組み込み関数を使用します。 7

PHPが多くのWebサイトよりも優先テクノロジースタックである理由には、その使いやすさ、強力なコミュニティサポート、広範な使用が含まれます。 1)初心者に適した学習と使用が簡単です。 2)巨大な開発者コミュニティと豊富なリソースを持っています。 3)WordPress、Drupal、その他のプラットフォームで広く使用されています。 4)Webサーバーとしっかりと統合して、開発の展開を簡素化します。

PHPは、特にWeb開発の分野で、最新のプログラミングで強力で広く使用されているツールのままです。 1)PHPは使いやすく、データベースとシームレスに統合されており、多くの開発者にとって最初の選択肢です。 2)動的コンテンツ生成とオブジェクト指向プログラミングをサポートし、Webサイトを迅速に作成および保守するのに適しています。 3)PHPのパフォーマンスは、データベースクエリをキャッシュおよび最適化することで改善でき、その広範なコミュニティと豊富なエコシステムにより、今日のテクノロジースタックでは依然として重要になります。

PHPでは、弱い参照クラスを通じて弱い参照が実装され、ガベージコレクターがオブジェクトの回収を妨げません。弱い参照は、キャッシュシステムやイベントリスナーなどのシナリオに適しています。オブジェクトの生存を保証することはできず、ごみ収集が遅れる可能性があることに注意する必要があります。

\ _ \ _ Invokeメソッドを使用すると、オブジェクトを関数のように呼び出すことができます。 1。オブジェクトを呼び出すことができるように\ _ \ _呼び出しメソッドを定義します。 2。$ obj(...)構文を使用すると、PHPは\ _ \ _ Invokeメソッドを実行します。 3。ロギングや計算機、コードの柔軟性の向上、読みやすさなどのシナリオに適しています。


ホットAIツール

Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。

Undress AI Tool
脱衣画像を無料で

Clothoff.io
AI衣類リムーバー

AI Hentai Generator
AIヘンタイを無料で生成します。

人気の記事

ホットツール

Safe Exam Browser
Safe Exam Browser は、オンライン試験を安全に受験するための安全なブラウザ環境です。このソフトウェアは、あらゆるコンピュータを安全なワークステーションに変えます。あらゆるユーティリティへのアクセスを制御し、学生が無許可のリソースを使用するのを防ぎます。

MantisBT
Mantis は、製品の欠陥追跡を支援するために設計された、導入が簡単な Web ベースの欠陥追跡ツールです。 PHP、MySQL、Web サーバーが必要です。デモおよびホスティング サービスをチェックしてください。

SAP NetWeaver Server Adapter for Eclipse
Eclipse を SAP NetWeaver アプリケーション サーバーと統合します。

SublimeText3 英語版
推奨: Win バージョン、コードプロンプトをサポート!

SublimeText3 Mac版
神レベルのコード編集ソフト(SublimeText3)
