函数 | |
| int | rdb_pushjsonmessage_setfun (int h, rdbcb_OnPushJsonMsgs fun, void *pfunparam) |
| 设置处理实时库推送json消息的处理回调函数,用于高级用户自己解析订阅推送的快照和SOE | |
| int | rdb_subscription_setfun (int h, rdbcb_OnPushValSnaps funVal, void *pValparam, rdbcb_OnPushObjSnaps funObj, void *pObjparam) |
| 设置订阅标签快照处理回调函数 | |
| int | rdb_sscsnaps (int h, int mode, int codepage, const char *tagnames[], int nsize, void(*funErr)(const char *tagname, int errcode, void *param), void *paramFun) |
| 订阅快照,订阅后,当有新的快照数据写入实时库时,对每个订阅者推送一份快照数据。 | |
| int | rdb_unsscsnaps (int h, int codepage, const char *tagnames[], int nsize, void(*funErr)(const char *tagname, int errcode, void *param), void *paramFun) |
| 取消订阅快照 | |
| int | rdb_unsscallsnaps (int h) |
| 取消所有订阅 | |
| int | rdb_listsscsnaps (int h, int codepage, void(*funTag)(const char *tagname, void *param), void *paramFun) |
| 读取当前自己的订阅表 | |
标签快照订阅相关接口。
| int rdb_listsscsnaps | ( | int | h, |
| int | codepage, | ||
| void(*)(const char *tagname, void *param) | funTag, | ||
| void * | paramFun ) |
读取当前自己的订阅表
| h | rdb_create创建的句柄 |
| codepage | 指示参数字符串和回调函数参数字符串使用的编码;0:GBK, 1:utf8 |
| funTag | 标签回调,有多少标签回调多少次。 |
| paramFun | 回调函数funTag的param参数 |
| int rdb_pushjsonmessage_setfun | ( | int | h, |
| rdbcb_OnPushJsonMsgs | fun, | ||
| void * | pfunparam ) |
设置处理实时库推送json消息的处理回调函数,用于高级用户自己解析订阅推送的快照和SOE
| h | rdb_create创建的句柄 |
| fun | 处理接收json消息的回调函数 |
| pfunparam | 回调函数自己的参数 |
| int rdb_sscsnaps | ( | int | h, |
| int | mode, | ||
| int | codepage, | ||
| const char * | tagnames[], | ||
| int | nsize, | ||
| void(*)(const char *tagname, int errcode, void *param) | funErr, | ||
| void * | paramFun ) |
订阅快照,订阅后,当有新的快照数据写入实时库时,对每个订阅者推送一份快照数据。
| h | rdb_create创建的句柄 |
| mode | 订阅模式;0:订阅后不推送当前快照;1:订阅需要推送当前快照; 当前快照是指订阅前就存在的快照,这个mode不影响订阅后新快照的推送。 |
| codepage | 指示参数字符串和回调函数参数字符串使用的编码;0:GBK, 1:utf8 |
| tagnames | 需要订阅的标签名字符串数组,字符串编码由codepage指定,标签名可以最多有16个通配标签("d0.*","d1.*"等,"*"表示全部)和不限个数的精确指定标签。 |
| nsize | 标签个数 |
| funErr | 错误回调,有多少个错误标签回调多少次。 |
| paramFun | 错误回调函数的param参数。 |
| int rdb_subscription_setfun | ( | int | h, |
| rdbcb_OnPushValSnaps | funVal, | ||
| void * | pValparam, | ||
| rdbcb_OnPushObjSnaps | funObj, | ||
| void * | pObjparam ) |
设置订阅标签快照处理回调函数
| h | rdb_create创建的句柄 |
| funVal | 标签值数据回调函数 |
| pValparam | 值数据回调函数的param参数,回调时原样压缩参数栈。 |
| funObj | 标签对象数据回调函数 |
| pObjparam | 对象数据回调函数的param参数,回调时原样压缩参数栈。 |
| int rdb_unsscallsnaps | ( | int | h | ) |
取消所有订阅
| h | rdb_create创建的句柄 |
| int rdb_unsscsnaps | ( | int | h, |
| int | codepage, | ||
| const char * | tagnames[], | ||
| int | nsize, | ||
| void(*)(const char *tagname, int errcode, void *param) | funErr, | ||
| void * | paramFun ) |
取消订阅快照
| h | rdb_create创建的句柄 |
| codepage | 指示参数字符串和回调函数参数字符串使用的编码;0:GBK, 1:utf8 |
| tagnames | 需要取消订阅的标签名数组,字符串编码由codepage指定 |
| nsize | 标签个数 |
| funErr | 错误回调,有多少个错误标签回调多少次。 |
| paramFun | 错误回调的param参数。 |