Learn about the swoole multi-process messaging system in one article

Scenario: Applicable to most message queue scenarios, I will list a few common places: automatic order cancellation and inventory return, automatic receipt, mass email, push WeChat message template, asynchronous email Send, automatically cancel when membership expires, etc.

1. Let’s start by looking at the implementation process of this message-side system.

Then write the business logic in the Job class, with two methods [doJob => Custom business, after=> Business follow-up operations]

2. Serve-Queue explains the process in detail:

1. Install git clone https://github.com/twomiao/Serve.git, and then execute the command: Composer install

2. cd Serve/app/ Open the directory, rendering:

3. Directory introduction: Config, Services, Utils, Job, Func

(1) Config configuration File directory (Redis, MySQL, Serve-Queue)

(2) Services business layering (OrderService)

(3) Utils tool class (email, SMS, etc. etc.), Helper is equivalent to

(4) Job directory (Job::doJob() business is written in it, do not change the Job class name)

(5) Func Commonly used functions (env, db as examples)

(6) log log directory and TEST directory (simulation data files are in it)

3. Serve-Queue running process :

php serve start command to start:

Deliver simulated data through php test/placeOrder.php 1000

swoole starts multi-process processing, order data

php serve reload: smoothly restarts the Task process, equivalent to updating (new Job())->doJob( )Method;

Add a new text reminder "2333, smooth restart successful"; Haha, actually the description has taken effect!

Daemon process running: command execution php serve start -d

Submit an order, shall we test it? -1 Pending payment status 0 has been automatically canceled

Reminder: The test file is in Serve/data/sp_order.sql

IV. To implement the above process, the following is required Installation of these environments

1. Install Redis as a queue and MySQL database

2. Complete the extended installation through the commands pecl install swoole, pecl install seaslog

php --ini command determines the location of php.ini, and adds swoole.so and seaslog.so

3. Use the Mix Delayer tool (to achieve delay)

Download address: https://github.com/mix-basic/delayer/releases

Instructions for use: https://github.com/mix-basic/delayer-client-php

4. Management Serve commands, respectively: php serve start | stop | reload | reload:all

5. Git warehouse address:

https://github.com/twomiao/Serve.git (Redis delay queue)

https://github.com/twomiao/Jober

PHP Chinese website, a large number Freeswoole introductory tutorial, welcome to learn online!

The above is the detailed content of Learn about the swoole multi-process messaging system in one article. For more information, please follow other related articles on the PHP Chinese website!