上一篇文章中說到, 注冊進(jìn)程關(guān)聯(lián)的原子具有全局作用域, 這里的全局指的是當(dāng)前 Erlang 虛擬機(jī), 在分布式中, 便是當(dāng)前分布式節(jié)點. 因此, 在一個節(jié)點中注冊進(jìn)程關(guān)聯(lián)的原子, 在另一個節(jié)點中是不能直接使用, 而必須配和目標(biāo)節(jié)點使用.
復(fù)制代碼 代碼如下:
{RegName, Node} ! {messages}.
例子
先啟動一個 Server 節(jié)點
復(fù)制代碼 代碼如下:
erl -sname server
然后在 Erlang Shell 中操作
先簡單介紹幾個常用函數(shù)
復(fù)制代碼 代碼如下:
% 查看當(dāng)前節(jié)點
node().
% => 'server@Gentoo-PC'
% 查看所有已連接的節(jié)點
nodes().
% => [] % 此時還未連接其它節(jié)點
% 查看當(dāng)前節(jié)點是否存活
is_alive().
% => true
然后進(jìn)入正題
復(fù)制代碼 代碼如下:
% 啟動上一篇文章中最后的那個程序
test:start().
% Waiting for new message.
% => true
% 當(dāng)前節(jié)點可以使用 testp 原子
testp ! message.
% New message: message
% Waiting for new message.
% => message
然后啟動另外一個 Client 節(jié)點
復(fù)制代碼 代碼如下:
erl -sname client
在新的 Erlang Shell 中
復(fù)制代碼 代碼如下:
nodes().
% => [] % 此時未連接節(jié)點
% 當(dāng)前節(jié)點無法直接使用這個原子的
testp ! {}.
% ** exception error: bad argument
% in operator !/2
% called as testp ! {}
% 需要配合目標(biāo)節(jié)點一起使用
{testp, 'server@Gentoo-PC'} ! {}.
% => {} % 語句返回值
此時, server 節(jié)點就會接收到消息, 并打印出
復(fù)制代碼 代碼如下:
% New message: {}
% Waiting for new message.
節(jié)點間首次連接后, 兩個節(jié)點將會保持連接
在 Client 節(jié)點中
復(fù)制代碼 代碼如下:
nodes().
% => ['server@Gentoo-PC']
在 Server 節(jié)點中
復(fù)制代碼 代碼如下:
nodes().
% => ['client@Gentoo-PC']
結(jié)尾
當(dāng)然, 這只是個方法, 由于在模塊中定義了 call 函數(shù)包裹了起來, 所以可以使用遠(yuǎn)程調(diào)用, 調(diào)用 Server 節(jié)點上的 test:call 方法.
可以使用 rpc 模塊中的 call/4 方法遠(yuǎn)程調(diào)用函數(shù)
復(fù)制代碼 代碼如下:
% 在 Node 節(jié)點上執(zhí)行 apply(Module, Function, Args)
% 調(diào)用成功時返回 Result, 調(diào)用失敗時返回 {badrpc, Reason}
-spec rpc:call(Node, Module, Function, Args} -> Result | {badrpc, Reason}
在 Client 節(jié)點中
復(fù)制代碼 代碼如下:
rpc:call('server@Gentoo-PC', test, call, ['message from other node']).
