快捷導(dǎo)航

Erlang分布式節(jié)點中的注冊進(jìn)程使用實例

更新時間：2015年02月09日 09:56:56 投稿：junjie

這篇文章主要介紹了Erlang分布式節(jié)點中的注冊進(jìn)程使用實例,本文直接給出實例代碼,需要的朋友可以參考下

上一篇文章中說到, 注冊進(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']).