lingxiao/swoft-rabbitmq

swoft-RabbitMq component for swoft framework

dev-main 2022-02-14 13:09 UTC

Requires

• php: >7.1
• php-amqplib/php-amqplib: ^3.0
• swoft/connection-pool: ~2.0.0
• swoft/framework: ~2.0.0

Requires (Dev)

• phpunit/phpunit: ^7.5
• swoft/swoole-ide-helper: dev-master

Apache-2.0

• swoole
• swoft
• swoft-component

README

配置rabbitMq信息bean.php

return [
    'config' => [
        'path' => __DIR__ . '/config',
    ],
    'rabbit'            => [
        'class'         => \Lingxiao\Swoft\RabbitMq\RabbitMq::class,
        'host'          => '127.0.0.1',
        'port'          => 5672,
        'user'          => '',
        'password'      => '',
        "queueLists"  => config("rabbit.queueLists"),
    ],
    'rabbit.pool'     => [
        'class'       => \Lingxiao\Swoft\RabbitMq\Pool::class,
        'rabbitMq'    => \bean('rabbit'),
        'minActive'   => 10,
        'maxActive'   => 20,
        'maxWait'     => 0,
        'maxWaitTime' => 0,
        'maxIdleTime' => 60,
    ],
];

配置队列config/rabbit.php

return [
    //队列名称
    'queueLists' => [
        [
            'name' => 'test',
            'vhost' => '/vhost',
            'exchangeName' => 'test', //交换机名称
            'queueName' => 'test',//队列名称
            'routeKey' => '',
            'producerClass' => \Lingxiao\Swoft\RabbitMq\Producer\MqProducer::class,//生产者
            'consumerHandle' => \Lingxiao\Swoft\RabbitMq\Consumer\ConsumerHandle::class,//消费者处理类
            'autoAck' => false,//是否自动应答
            'exChange' => [
                'direct' => 'direct', //路由类型
                'passive' => true, //是否检测同名队列
                'durable' => false, //是否开启持久化
                'auto_delete' => false //关闭后是否删除
            ],
            'queue' => [
                'passive' => true, //是否检测同名队列
                'durable' => false, //是否开启持久化
                'exclusive' => false, //队列是否可以被其他队列访问
                'auto_delete' => false//关闭后是否删除
            ],
        ],
    ],

];

使用方法

消费者
/** @var Channel $channel */
$channel = BeanFactory::getBean(Channel::class);
$channel->setQueue('test');
/** @var ConsumerInterface $consumer */
$consumer = $channel->consumer();
$consumer->run();

生产者
/** @var Channel $channel */
$channel = BeanFactory::getBean(Channel::class);
$channel->setQueue('test');
/** @var ProducerInterface $producer */
$producer = $channel->producer();
$producer->setMessage('Hello World1');
$producer->setMessage('Hello World2');
$producer->push();