Erlang分布式模式短名称介绍

简介

Erlang是一种支持分布式编程的语言，因此它提供了一些在分布式环境中使用的模式和技术。在Erlang中，节点间通讯是通过消息传递来实现的，这个消息传递的机制是可伸缩的，可靠的，同时也易于使用。

在Erlang中，分布式通讯的模式有很多，其中比较常用的有以下几种：

• Gossip模式
• Publish/Subscribe模式
• RPC模式

接下来，我们将逐一介绍这些模式及其用法。

Gossip模式

Gossip模式是一种分布式通讯模式，它通过Erlang节点间的消息传递来传递数据。在Gossip模式中，节点之间不仅仅是发送和接收消息，还会以某种方式共享它们拥有的信息。

Gossip模式适用于一组节点之间需要进行协作的情况。在Erlang中，可以使用net_kernel模块来实现Gossip模式通讯。其中，epmd是一个名字服务器，它允许节点找到其他节点的地址。

以下是一个简单的Gossip模式通讯的示例：

% 节点1启动
1> erl -sname node1
Erlang/OTP 23 [erts-11.1] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:1] [hipe]

2> net_kernel:start([node1]).
{ok,[node1]}

% 节点2启动
3> erl -sname node2
Erlang/OTP 23 [erts-11.1] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:1] [hipe]

4> net_kernel:start([node2]).
{ok,[node2]}

% 节点1和2建立连接
5> net_kernel:connect_node('node2@hostname').
true

% 在节点1中发送消息到节点2
6> {node2, Message} ! "Hello from node 1".
Hello from node 1

% 在节点2中接收消息
7> receive 
       Message -> Message 
   end.
"Hello from node 1"

上述示例中，我们创建了两个节点，让它们通过net_kernel:connect_node/1建立连接后，使用Gossip模式通讯规则，在节点1中发送了一个消息到节点2，并在节点2中接收到了该消息。

Publish/Subscribe模式

Publish/Subscribe模式是另一种分布式通讯模式，它一般用于事件驱动型的场景。在该模式中，有多个订阅者（Subscribers）可以订阅一个发布者（Publisher）的事件。当事件发生时，发布者会通知所有订阅者。

在Erlang中，可以使用gen_event模块来实现Publish/Subscribe模式。gen_event是Erlang的事件处理器，它可以让你定义、注册、调度和处理事件。

以下是一个简单的Publish/Subscribe模式通讯的示例：

% 创建一个gen_event进程
1> {ok, PID} = gen_event:start_link({local, topic}).

% 订阅一个主题
2> gen_event:add_handler(topic, fun(Event) -> io:format("Received event: ~p\n", [Event]) end).

% 向主题发送消息
3> gen_event:notify(topic, "Hello, world!").
Received event: "Hello, world!"
ok

上述示例中，我们通过gen_event:start_link/1创建了一个gen_event进程，它将作为发布者的主题。接着，我们使用gen_event:add_handler/2函数来订阅该主题，并定义了一个回调函数用于处理接收到的事件。最后，我们通过gen_event:notify/2函数来向主题发送消息。

RPC模式

RPC（Remote Procedure Call）模式是一种在分布式环境中广泛使用的模式。在该模式中，远程机器上的函数可以被本地机器上的代码所调用，就像调用本地函数一样。在Erlang中，可以使用rpc模块来实现RPC模式。

以下是一个简单的RPC模式通讯的示例：

% 在节点1中定义一个函数
1> fun my_func() -> "Hello, world!" end.
#Fun<erl_eval.6.50752066>

% 在节点1中启动一个shell
2> erl -sname node1
Erlang/OTP 24 [erts-12.0] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:1]

Eshell V12.0  (abort with ^G)

% 在节点1中开启分布式支持
3> net_kernel:start([node1]).
{ok,[node1]}

% 在节点2中启动一个shell
4> erl -sname node2
Erlang/OTP 24 [erts-12.0] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:1]

Eshell V12.0  (abort with ^G)

% 在节点2中开启分布式支持
5> net_kernel:start([node2]).
{ok,[node2]}

% 在节点2中调用节点1中的函数
6> rpc:call('node1@hostname', erlang, apply, [fun my_func/0, []]).
"Hello, world!"

上述示例中，我们通过在节点1中定义了一个函数my_func/0，并在节点2中使用rpc:call/4函数来调用节点1中的该函数。由于该函数没有参数，我们可以将参数列表指定为空[]。

总结

通过本文的介绍，我们了解了Erlang在分布式编程中常用的三个模式：Gossip模式、Publish/Subscribe模式和RPC模式。这些通讯模式各有特点，能够满足不同的分布式通讯需求。在实际应用中，会根据具体的场景选用合适的通讯模式。