您的位置:首页 > Web前端 > Node.js

ejabberd_node_groups

2015-12-15 21:57 555 查看
作为gen_server启动,作为pg2模块的封装

pg2这个模块实现了进程组的功能。例如进程组的名称为test,而且有一系列进程位于组内,可能这些进程位于不同的节点上,都可以成为test的成员。不能够直接向test发送消息,但是通过方法get_members/1 和 get_local_members/1获取的组内的进程,然后可以与查出的进程通信。

对外提供几种方法,较为简单:

join(Name) ->
PG = {?MODULE, Name},
pg2:create(PG),
pg2:join(PG, whereis(?MODULE)).

leave(Name) ->
PG = {?MODULE, Name},
pg2:leave(PG, whereis(?MODULE)).

get_members(Name) ->
PG = {?MODULE, Name},
[node(P) || P <- pg2:get_members(PG)].

get_closest_node(Name) ->
PG = {?MODULE, Name},
node(pg2:get_closest_pid(PG)).
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: