boa框架开发手册v5.2

zeromq类
版本 1.0+
命名空间 boa\mq\driver
文件 boa/mq/driver/zeromq.php
说明 zeromq消息队列驱动类,继承base类
配置
配置项 默认值 类型 说明
broker tcp://127.0.0.1:5555 string 消息中间件服务器,支持inproc, ipc, tcp, pgm, epgm
persist_id null string 持久连接ID
queue boa string 发布/订阅的消息队列
目录
方法 说明
__construct() 初始化
publish() 发布消息
subscribe() 订阅消息
read() 消费消息
ack() 空方法
unsubscribe() 取消订阅
方法

__construct()

说明
初始化
参数 必须 默认值 类型 说明
$cfg [] array 配置数据

publish()

说明
发布消息
参数 必须 默认值 类型 说明
$msg Y mixed 消息,支持所有类型
返回值
成功返回true(bool);失败返回false(bool)

subscribe()

说明
订阅消息
参数 必须 默认值 类型 说明
$queue null string 消息队列,默认取配置queue
返回值
成功返回true(bool);失败返回false(bool)

read()

说明
消费消息
返回值
返回消息正文(mixed),出错产生error日志并返回false(bool)

ack()

说明
空方法
返回值
返回true(bool)

unsubscribe()

说明
取消订阅
参数 必须 默认值 类型 说明
$queue null string 消息队列,默认取配置queue
返回值
成功返回true(bool);失败返回false(bool)