Skip to content

Latest commit

 

History

History
105 lines (85 loc) · 2.64 KB

README.md

File metadata and controls

105 lines (85 loc) · 2.64 KB

Yunba PHP SDK

Yunba (http://yunba.io) SDK PHP版。

提示:此SDK只能在cli模式下以阻塞方式运行,如果只用于发布消息推荐使用更简单的RESTful API

声明:对于自行修改 sdk 而导致的问题,云巴恕不提供技术支持。如果对于 sdk 有个性化需求,可以联系商务定制开发:[email protected]

API说明

构造器

$yunba = new Yunba(array $setup);

参数:

  • array $setup 配置选项,包括:
    • server(可选) - 服务器域名或IP
    • port(可选)- 服务器端口
    • appkey - 应用AppKey字符串
    • debug(可选)- 是否开启调试模式
    • sessionFilePath(可选)- 存储会话ID的文件路径(默认为当目录下的session.dat)

初始化

$yunba->init($initCallback = null, $recCallback = null);

参数:

  • callable $initCallback 初始化结果回调函数
  • $recCallback 重新连接回调函数

连接服务

$yunba->connect($callback = null);

参数

  • callable $callback 连接成功或失败回调函数
$yunba->connect_v2($callback = null);

说明

功能与connect一致,不同的是此接口会将会话状态保存下来(保存到sessionFilePath中),当由于网络不稳定等原因发生重新连接后会话状态不会丢失(包括离线消息、已订阅的频道和别名)。

参数

  • callable $callback 连接成功或失败回调函数

断开连接

$yunba->disconnect($callback = null);

参数

  • callable $callback 回调函数

触发事件

$yunba->emit($event, array $args, $callback = null);

参数:

  • string $event 事件名
  • array $args 参数
  • callable $callback 回调函数

监听事件

$yunba->on($event, $callback);

参数:

  • string $event 事件名
  • callable $callback 回调函数

订阅

$yunba->subscribe (array $args, $subscribeCallback = null, $messageCallback = null);

参数:

  • array $args 参数,包括topic, qos两个选项
  • callable $subscribeCallback 订阅结果回调函数
  • callable $messageCallback 消息接收回调函数

取消订阅

$yunba->unsubscribe (array $args, $callback = null);

参数:

  • array $args 参数,包括topic一个选项
  • callable $callback 回调函数

发布消息

$yunba->publish (array $args, $callback = null);

参数:

  • array $args 要发布的消息的内容,包括topic, msg, qos三个选项
  • callable $callback 回调函数

等待和服务间的通讯

$yunba->wait();

使用示例

请见 examples/subscribe.php 和 examples/publish.php