limingxinleo/swoft-amqplib

Amqplib简单封装组件

1.1.9 2018-12-14 07:47 UTC

Requires

• php: >=7.1
• ext-pcntl: *
• php-amqplib/php-amqplib: ^2.7

Requires (Dev)

• limingxinleo/x-trait-common: ^1.1
• phpstan/phpstan: ^0.10.5
• phpunit/phpunit: ^5.7
• swoft/framework: ^1.0
• swoft/swoole-ide-helper: dev-master

MIT

• 李铭昕

• php
• component

README

安装

composer require limingxinleo/swoft-amqplib

使用

Yii2框架

<?php

use yii\base\StaticInstanceTrait;
use Swoftx\Amqplib\Connection;
use Swoftx\Amqplib\Message\Publisher;

class YiiConnection extends \Swoftx\Amqplib\Connection
{
    use StaticInstanceTrait;
}

class DemoMessage extends Publisher
{
    protected $exchange = 'demo';

    protected $queue = 'demo.queue';

    protected $routingKey = 'test';

    public function getConnection(): Connection
    {
        return YiiConnection::instance()->build();
    }
}

$msg = new DemoMessage();
$msg->setData(['id' => $id]);
$msg->publish();

Swoft 框架

<?php

use Swoftx\Amqplib\Message\Publisher;
use Swoftx\Amqplib\SwoftConnection;
use Swoftx\Amqplib\Pool\RabbitMQPool;
use Swoft\Pool\ConnectionInterface;

class DemoMessage extends Publisher
{
    protected $exchange = 'demo';

    protected $queue = 'demo.queue';

    protected $routingKey = 'test';
    
    /** @var ConnectionInterface SwoftConnection */
    protected $swoftConnection;

    public function getConnection(): \Swoftx\Amqplib\Connection
    {
        $pool = \Swoft\App::getPool(RabbitMQPool::class);
        /** @var SwoftConnection $connection */
        $this->swoftConnection = $pool->getConnection();
        return $this->swoftConnection->getConnection();
    }
    
    public function publish()
    {
        parent::publish();
        // 释放资源 【很重要】
        $this->swoftConnection->release(true);
    }
}

$msg = new DemoMessage();
$msg->setData(['id' => $id]);
$msg->publish();

Swoft 对应配置默认值

RABBITMQ_MIN_ACTIVE=5
RABBITMQ_MAX_ACTIVE=10
RABBITMQ_MAX_WAIT=20
RABBITMQ_MAX_WAIT_TIME=3
RABBITMQ_MAX_IDLE_TIME=120
RABBITMQ_TIMEOUT=3
RABBITMQ_URI=127.0.0.1:5672
RABBITMQ_USER=guest
RABBITMQ_PASSWORD=guest
RABBITMQ_VHOST=/

RABBITMQ_PARAMS_INSIST=false
RABBITMQ_PARAMS_LOGIN_METHOD=AMQPLAIN
RABBITMQ_PARAMS_LOGIN_RESPONSE=null
RABBITMQ_PARAMS_LOCALE=en_US
RABBITMQ_PARAMS_CONNECTION_TIMEOUT=3
RABBITMQ_PARAMS_READ_WRITE_TIMEOUT=3
RABBITMQ_PARAMS_CONTEXT=null
RABBITMQ_PARAMS_KEEPALIVE=false
RABBITMQ_PARAMS_HEARTBEAT=0