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() | 取消订阅 |
方法
| 说明 | ||||
|---|---|---|---|---|
| 初始化 | ||||
| 参数 | 必须 | 默认值 | 类型 | 说明 |
| $cfg | [] | array | 配置数据 | |
| 说明 | ||||
|---|---|---|---|---|
| 发布消息 | ||||
| 参数 | 必须 | 默认值 | 类型 | 说明 |
| $msg | Y | mixed | 消息，支持所有类型 | |
| 返回值 | ||||
| 成功返回true（bool）；失败返回false（bool） | ||||
| 说明 | ||||
|---|---|---|---|---|
| 订阅消息 | ||||
| 参数 | 必须 | 默认值 | 类型 | 说明 |
| $queue | null | string | 消息队列，默认取配置queue | |
| 返回值 | ||||
| 成功返回true（bool）；失败返回false（bool） | ||||
| 说明 | ||||
|---|---|---|---|---|
| 消费消息 | ||||
| 返回值 | ||||
| 返回消息正文（mixed），出错产生error日志并返回false（bool） |
| 说明 | ||||
|---|---|---|---|---|
| 消费处理确认 | ||||
| 返回值 | ||||
| 返回true（bool） |
| 说明 | ||||
|---|---|---|---|---|
| 取消订阅 | ||||
| 参数 | 必须 | 默认值 | 类型 | 说明 |
| $queue | null | string | 消息队列，默认取配置queue | |
| 返回值 | ||||
| 成功返回true（bool）；失败返回false（bool） | ||||