QPHP: Exchange messages with a queue server using Swoole

Recommend this page to a friend!

Download

Info

Example

Files

Install with Composer

Download

Reputation

Support forum

Blog

Links

Ratings				Unique User Downloads		Download Rankings
Not yet rated by the users				Total: 57		All time: 10,553 This week: 673

Version		License		PHP version		Categories
`qphp` 1.0		MIT/X Consortium ...		8		Networking, PHP 8

Description

Author

LAGGOUNE Walid

This package implements an application exchange messages with a queue server using Swoole.

It implements a server that listens to TCP connection requests and can receive messages from clients and store them in a queue table managed by Swoole.

The application also allows clients to pull queued messages from the queue table.

Innovation Award

December 2021
Number 7

Swoole is a framework for developing PHP applications that can run multiple parallel tasks using asynchronous programming to make the studies faster.

This package implements an application to exchange messages using queues. It uses Swoole to make it possible to exchange multiple notes simultaneously between clients and servers.

This way, the message exchange is faster than traditional solutions that do not use asynchronous programming.

Manuel Lemos

LAGGOUNE Walid

Performance

Level

Name:	LAGGOUNE Walid `<contact>`
Classes:	7 packages by LAGGOUNE Walid
Country:	Algeria

Level 1

Innovation award

Nominee: 2x

Example


<?php 



require "vendor/autoload.php";

use App\Booter;

use App\Server\Server;



$server = new Server((new Booter)->loadConfigurations(__DIR__));

$server->start();

Details

QPHP

QPHP is a simple, fast work queue server extendable to LUA scripts. Built using PHP & SWOOLE.

RUN it

First, build the image :

docker-compose build

Run :

docker-compose up
docker-compose exec php-queue bash
cd queue-worker
php server.php

Running port is : 15674

Config

src/config/.env <br/> - MAX_CONN : https://www.swoole.co.uk/docs/modules/swoole-server/configuration#max_conn - QUEUE_TABEL_SIZE: This table is responsible to store queues payloads. https://www.swoole.co.uk/docs/modules/swoole-table-construct - IGNORE_NO_LISTENERS: 0 or 1 , if 0 the server will not dispatch the queues if there is no >= 1 listener. - BUFFER_OUTPUT_SIZE: https://www.swoole.co.uk/docs/modules/swoole-server/configuration#buffer_output_size - REACTOR_NUM: https://www.swoole.co.uk/docs/modules/swoole-server/configuration#reactor_num - WORKER_NUM: https://www.swoole.co.uk/docs/modules/swoole-server/configuration#worker_num

How to use it / examples

See the examples/ folder

Observers

PHP observer

app/Parser/Observer/ParserObserver.php You can write PHP code to handle received queues and parse them before saving them to the storage. Also, you can handle the queue message before sending them to listeners.

Extend to Lua

You can write LUA code to handle received queues and parse them before saving them to the storage. Also, you can handle the queue message before sending them to listeners.

Files (1538)

File	Role	Description
`php` (1 file)
`src` (3 files, 6 directories)
`docker-compose.yml`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`README.md`	Doc.	Documentation

Files (1538)

php

File	Role	Description
`Dockerfile`	Data	Auxiliary data

Files (1538)

src

File	Role	Description
`app` (1 file, 4 directories)
`config` (1 file)
`examples` (2 files)
`scripts` (1 file)
`tests` (2 files)
`vendor` (1 file, 16 directories)
`composer.json`	Data	Auxiliary data
`composer.lock`	Data	Auxiliary data
`server.php`	Example	Example script

File	Role	Description
`Channel` (2 files)
`Parser` (2 files, 1 directory)
`Server` (5 files)
`Storage` (4 files)
`Booter.php`	Class	Class source

File	Role	Description
`Channel.php`	Class	Class source
`ChannelInterface.php`	Class	Class source

File	Role	Description
`Observer` (1 file)
`Parser.php`	Class	Class source
`ParserAbstract.php`	Class	Class source

File	Role	Description
`ConnectionHandler.php`	Class	Class source
`ConnectionHandlerInterface.php`	Class	Class source
`Server.php`	Class	Class source
`ServerInterface.php`	Class	Class source
`Worker.php`	Class	Class source

File	Role	Description
`ChannelStorage.php`	Class	Class source
`ConnectionStorage.php`	Class	Class source
`QueueStorage.php`	Class	Class source
`Storage.php`	Class	Class source

File	Role	Description
`receiver.php`	Aux.	Auxiliary script
`sender.php`	Aux.	Auxiliary script

File	Role	Description
`ConnectionHandlerTest.php`	Class	Class source
`ParserTest.php`	Class	Class source

File	Role	Description
`composer` (12 files)
`doctrine` (2 directories)
`graham-campbell` (1 directory)
`myclabs` (1 directory)
`nikic` (1 directory)
`pda` (1 directory)
`phar-io` (2 directories)
`phpdocumentor` (3 directories)
`phpoption` (1 directory)
`phpspec` (1 directory)
`phpunit` (6 directories)
`sebastian` (16 directories)
`symfony` (3 directories)
`theseer` (1 directory)
`vlucas` (1 directory)
`webmozart` (1 directory)
`autoload.php`	Aux.	Auxiliary script

File	Role	Description
`autoload_classmap.php`	Aux.	Auxiliary script
`autoload_files.php`	Aux.	Auxiliary script
`autoload_namespaces.php`	Aux.	Auxiliary script
`autoload_psr4.php`	Aux.	Auxiliary script
`autoload_real.php`	Class	Class source
`autoload_static.php`	Class	Class source
`ClassLoader.php`	Class	Class source
`installed.json`	Data	Auxiliary data
`installed.php`	Aux.	Auxiliary script
`InstalledVersions.php`	Class	Class source
`LICENSE`	Lic.	License text
`platform_check.php`	Aux.	Auxiliary script

File	Role	Description
`collections` (7 files, 2 directories)
`instantiator` (8 files, 3 directories)

File	Role	Description
`docs` (1 directory)
`lib` (1 directory)
`.doctrine-project.json`	Data	Auxiliary data
`composer.json`	Data	Auxiliary data
`CONTRIBUTING.md`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`phpstan.neon.dist`	Data	Auxiliary data
`psalm.xml.dist`	Data	Auxiliary data
`README.md`	Doc.	Documentation

File	Role	Description
`derived-collections.rst`	Data	Auxiliary data
`expression-builder.rst`	Data	Auxiliary data
`expressions.rst`	Data	Auxiliary data
`index.rst`	Class	Class source
`lazy-collections.rst`	Data	Auxiliary data
`sidebar.rst`	Data	Auxiliary data

File	Role	Description
`Expr` (6 files)
`AbstractLazyCollection.php`	Class	Class source
`ArrayCollection.php`	Class	Class source
`Collection.php`	Class	Class source
`Criteria.php`	Class	Class source
`ExpressionBuilder.php`	Class	Class source
`Selectable.php`	Class	Class source

File	Role	Description
`ClosureExpressionVisitor.php`	Class	Class source
`Comparison.php`	Class	Class source
`CompositeExpression.php`	Class	Class source
`Expression.php`	Class	Class source
`ExpressionVisitor.php`	Class	Class source
`Value.php`	Class	Class source

File	Role	Description
`.github` (1 file, 1 directory)
`docs` (1 directory)
`src` (1 directory)
`.doctrine-project.json`	Data	Auxiliary data
`composer.json`	Data	Auxiliary data
`CONTRIBUTING.md`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`phpbench.json`	Data	Auxiliary data
`phpcs.xml.dist`	Data	Auxiliary data
`phpstan.neon.dist`	Data	Auxiliary data
`README.md`	Doc.	Documentation

File	Role	Description
`coding-standards.yml`	Data	Auxiliary data
`continuous-integration.yml`	Data	Auxiliary data
`phpbench.yml`	Data	Auxiliary data
`release-on-milestone-closed.yml`	Data	Auxiliary data
`static-analysis.yml`	Data	Auxiliary data

File	Role	Description
`Exception` (3 files)
`Instantiator.php`	Class	Class source
`InstantiatorInterface.php`	Class	Class source

File	Role	Description
`ExceptionInterface.php`	Class	Class source
`InvalidArgumentException.php`	Class	Class source
`UnexpectedValueException.php`	Class	Class source

File	Role	Description
`src` (3 files)
`composer.json`	Data	Auxiliary data
`LICENSE`	Lic.	License text

File	Role	Description
`Error.php`	Class	Class source
`Result.php`	Class	Class source
`Success.php`	Class	Class source

File	Role	Description
`.github` (1 file)
`src` (1 directory)
`composer.json`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`README.md`	Doc.	Documentation

File	Role	Description
`Exception` (2 files)
`Filter` (4 files, 1 directory)
`Matcher` (4 files, 1 directory)
`Reflection` (1 file)
`TypeFilter` (3 files, 2 directories)
`TypeMatcher` (1 file)
`DeepCopy.php`	Class	Class source
`deep_copy.php`	Example	Example script

File	Role	Description
`CloneException.php`	Class	Class source
`PropertyException.php`	Class	Class source

File	Role	Description
`Doctrine` (3 files)
`Filter.php`	Class	Class source
`KeepFilter.php`	Class	Class source
`ReplaceFilter.php`	Class	Class source
`SetNullFilter.php`	Class	Class source

File	Role	Description
`DoctrineCollectionFilter.php`	Class	Class source
`DoctrineEmptyCollectionFilter.php`	Class	Class source
`DoctrineProxyFilter.php`	Class	Class source

File	Role	Description
`Doctrine` (1 file)
`Matcher.php`	Class	Class source
`PropertyMatcher.php`	Class	Class source
`PropertyNameMatcher.php`	Class	Class source
`PropertyTypeMatcher.php`	Class	Class source

File	Role	Description
`Date` (1 file)
`Spl` (3 files)
`ReplaceFilter.php`	Class	Class source
`ShallowCopyFilter.php`	Class	Class source
`TypeFilter.php`	Class	Class source

File	Role	Description
`ArrayObjectFilter.php`	Class	Class source
`SplDoublyLinkedList.php`	Class	Class source
`SplDoublyLinkedListFilter.php`	Class	Class source

File	Role	Description
`bin` (1 file)
`grammar` (8 files)
`lib` (1 directory)
`composer.json`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`README.md`	Class	Class source

File	Role	Description
`parser.template`	Class	Class source
`php5.y`	Data	Auxiliary data
`php7.y`	Data	Auxiliary data
`phpyLang.php`	Aux.	Auxiliary script
`README.md`	Doc.	Documentation
`rebuildParsers.php`	Aux.	Auxiliary script
`tokens.template`	Class	Class source
`tokens.y`	Data	Auxiliary data