mix-plus/queue

queue

Maintainers

Details

github.com/mixphp-plus/queue

Source

Issues

Installs: 27

Dependents: 0

Suggesters: 0

Security: 0

Stars: 1

Watchers: 1

Forks: 0

pkg:composer/mix-plus/queue

0.3.7 2022-10-14 01:56 UTC

Requires

Requires (Dev)

Apache-2.0 0f0895f4a3c446c99bb6688b93ae00a364767630

  • cexll <evanxian9.woop@gmail.com>

This package is not auto-updated.

Last update: 2025-10-28 22:39:05 UTC

README

Generic resident memory queue Swoole support

install

composer require mix-plus/queue

run

// create queue
$queue = new RedisDriver([
                'default' => 'default',
                'host' => '127.0.0.1',
                'port' => 6379,
                'password' => '',
                'select' => 0,
                'timeout' => 0,
            ], [
                QueueHandleListener::class,
                QueueLengthListener::class,
                ReloadChannelListener::class,
            ]);

// start consume
// Swoole is coroutine run  go $queue->consume();
$queue->consume();

test

code

php test/queue.php

array(10) {
  [0]=>
  bool(false)
  [1]=>
  bool(false)
  [2]=>
  bool(false)
  [3]=>
  bool(false)
  [4]=>
  bool(false)
  [5]=>
  bool(false)
  [6]=>
  bool(false)
  [7]=>
  bool(false)
  [8]=>
  bool(false)
  [9]=>
  bool(true)
}
string(9) "123123123"
string(8) "dispatch"
string(8) "dispatch"
string(8) "dispatch"
string(8) "dispatch"

LICENSE

Apache License Version 2.0, http://www.apache.org/licenses/