xezzus/amqp-im

发送和接收 AMQP 协议的消息

dev-master / 1.0.x-dev 2015-04-15 14:46 UTC

This package is not auto-updated.

Last update: 2024-09-14 18:04:04 UTC


README

安装

要使用此组件,需要通过 PECL 安装 AMQP 库

pecl amqp

使用

// подклimючение к точке обмена сообщениями
$im = Yii::$app->exchange('globalChat');

// Отправить сообщение в точку обмена
$im->send('Text message');

// Получить сообщение
$take = $im->take();

// Получить тело сообщения
$take->msg();

// Сообщение серверу, что сообщение обработано и его можно удалить из очереди
$take->ack();

配置

"components"=>[
  "im"=>[
    'class' => 'common\components\im\Connection',
    'host'=>'127.0.0.1',
    'login'=>'guest',
    'password'=>'guest',
    'port'=>'5672'
  ]
]