swoole マルチプロセス メッセージング システムについて 1 つの記事で学ぶ

シナリオ: ほとんどのメッセージ キュー シナリオに当てはまります。一般的な場所をいくつか挙げます: 自動注文キャンセルと在庫返品、自動受領、一括メール、プッシュ WeChat メッセージ テンプレート、非同期メール送信、メンバーシップの有効期限が切れると自動的にキャンセルされるなど。

1. まず、このメッセージ側システムの実装プロセスを見てみましょう。

次に、2 つのメソッド [doJob => カスタム ビジネス、after=> ビジネス フォローアップ オペレーション]

# を使用して、Job クラスにビジネス ロジックを記述します。 # #2. Serve-Queue でプロセスを詳しく説明します:

1. git clone https://github.com/twomiao/Serve.git をインストールし、コマンドを実行します: Composer install

2. cd Serve/app/ ディレクトリを開き、レンダリングします:

3. ディレクトリの紹介: Config、Services、Utils、Job、Func

(1) 構成設定ファイル ディレクトリ (Redis、MySQL、Serve-Queue)

(2) サービス ビジネス レイヤ化 (OrderService)

(3) Utils ツール クラス (ヘルパーは

# に相当します。 (4) ジョブディレクトリ (Job::doJob() のビジネスが記述されます。ジョブクラス名は変更しないでください)

(5) Func よく使う関数 (env、db など)

#(6) log ログディレクトリと TEST ディレクトリ (シミュレーションデータファイルが入っています)

3. Serve-Queue 実行プロセス:

phpserve start コマンドを開始する:

php test/ を通じてシミュレートされたデータを配信します。 placeOrder.php 1000

swoole はマルチプロセス処理を開始し、データを注文します

phpserve reload: スムーズに再起動します(new Job())->doJob( )Method の更新と同等のタスク プロセス;

新しいテキスト リマインダー「2333、スムーズな再起動が成功しました」を追加します; はは、実際には説明が有効になっています！

#デーモン プロセスが実行中: コマンド実行 phpserve start -d

注文を送信しました。テストしましょうか? -1 保留中の支払いステータス 0 は自動的にキャンセルされました

リマインダー: テスト ファイルは Serve/data/sp_order.sql

にあります。 IV. を実装するには上記のプロセスでは、次のことが必要です。 これらの環境のインストール

1. Redis をキューとしてインストールし、MySQL データベースをインストールします

2. コマンド pecl install swoole、pecl を使用して拡張インストールを完了します。 install seaslog

php --ini コマンドは php.ini の場所を特定し、swoole.so と seaslog.so

3 を追加します。Mix Delayer ツールを使用します (遅延を実現するため)

ダウンロード アドレス: https://github.com/mix-basic/layer/releases

使用説明: https://github. com/mix-basic/layer-client-php

4. Management Serve コマンドはそれぞれ: phpserve start | stop | reload | reload:all

5. Git ウェアハウスのアドレス:

https://github.com/twomiao/Serve.git (Redis 遅延キュー)

https://github.com/twomiao/Jober

PHP 中国語 Web サイト、多数の無料

swoole 入門チュートリアル

、オンライン学習へようこそ!

以上がswoole マルチプロセス メッセージング システムについて 1 つの記事で学ぶの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。