远程订阅发布模式

watch_server.lua

sever

• M.publish(channel_name, …)
  描述: 发布名为channel_name的事件
  参数:
  - channel_name (string): 事件名

• M.pubsyn(channel_name, …)
  描述: 发布名为channel_name的同步事件
  参数:
  - channel_name (string): 事件名

watch_client.lua

sub/pub clinet

• M.watch(svr_name, channel_name, handle_name, handler)
  描述: watch监听 svr_name 的所有结点
  参数:
  - svr_name (string): 集群svr_name
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名
  - handler (function): 回调函数

• M.unwatch(svr_name, channel_name, handle_name, handler)
  描述: 取消监听 svr_name 的所有结点
  参数:
  - svr_name (string): 集群svr_name
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名

• M.watch_byid(svr_name, svr_id, channel_name, handle_name, handler)
  描述: 指定svr_id监听
  参数:
  - svr_name (string): 集群svr_name
  - svr_id (number): 指定svr_id
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名
  - handler (function): 回调函数

• M.unwatch_byid(svr_name, svr_id, channel_name, handle_name)
  描述: 指定svr_id取消监听
  参数:
  - svr_name (string): 集群svr_name
  - svr_id (number): 指定svr_id
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名

watch_syn_client.lua

subsyn/pubsyn clinet

• M.watch(svr_name, channel_name, handle_name, handler)
  描述: watch监听 svr_name 的所有结点
  参数:
  - svr_name (string): 集群svr_name
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名
  - handler (function): 回调函数

• M.unwatch(svr_name, channel_name, handle_name, handler)
  描述: 取消监听 svr_name 的所有结点
  参数:
  - svr_name (string): 集群svr_name
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名

• M.watch_byid(svr_name, svr_id, channel_name, handle_name, handler)
  描述: 指定svr_id监听
  参数:
  - svr_name (string): 集群svr_name
  - svr_id (number): 指定svr_id
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名
  - handler (function): 回调函数

• M.unwatch_byid(svr_name, svr_id, channel_name, handle_name)
  描述: 指定svr_id取消监听
  参数:
  - svr_name (string): 集群svr_name
  - svr_id (number): 指定svr_id
  - channel_name (string): 事件名
  - handle_name (string): 回调处理名