Elixir 可以运行在主/从, 故障转移/接管模式下. 要使Elixir应用程序能够执行故障转移/接管, Elixir应用程序必须是一个OTP应用程序.
下面来创建一个包含Supervisor的Elixir项目
mix new distro --sup
修改distro.ex
添加logger
模块. 以记录当触发故障转移/接管操作时的日志记录.
defmodule Distro do
use Application
require Logger
def start(type, _args) do
import Supervisor.Spec, warn: false
Logger.info("Distro application in #{inspect type} mode")
children = [
worker(Distro.Worker, [])
]
opts = [strategy: :one_for_one, name: Distro.Supervisor]
Supervisor.start_link(children, opts)
end
end
Distro.Worker
是一个GenServer
: 它使用全局名称注册, 假设其运行在集群中的一个节点上, 全局注册让我们不用考虑其实际的运行位置, 只需要提供注册名称就可以访问.
defmodule Distro.Worker do
use GenServer
require Logger
def start_link do
GenServer.start_link(__MODULE__, [], name: {:global, __MODULE__})
end
def init([]) do
{:ok, [], 1000}
end
def handle_info(:timeout, state) do
Logger.debug "timeout"
{:noreply, state, 1000}
end
end
编译
$ mix compile
应用程序分布
本节阐述了如何把一个应用程序分布到多个节点上
假设应用程序运行在3个节点上, 名称分别为abc
, bcd
, def
. 创建三个配置文件如下:
touch config/abc.config
touch config/bcd.config
touch config/def.config
配置文件中有3个重要的键值对. distributed
, sync_nodes_mandatory
和 sync_nodes_timeout
, 其中:
distributed
定义了分布式应用的启动延迟, 备用节点.sync_nodes_mandatory
定义强制要求的节点sync_nodes_timeout
定义了distributed
中所有节点都启动完成需要等待的时间, 如果在此时间内要求的节点没有全部启动, 那么所有节点上的应用启动失败.
abc.config
[
{logger,[{console,[{format,<<"$date $time $metadata[$level] $message\n">>}]}]},
{kernel,
[{distributed, [
{'distro', 5000, ['abc@192.168.8.104', {'bcd@192.168.8.104', 'def@192.168.8.104'}]}]},
{sync_nodes_mandatory, ['bcd@192.168.8.104', 'def@192.168.8.104']},
{sync_nodes_timeout, 30000}
]}].
bcd.config
[
{logger,[{console,[{format,<<"$date $time $metadata[$level] $message\n">>}]}]},
{kernel,
[{distributed, [
{distro,5000, ['abc@192.168.8.104', {'bcd@192.168.8.104', 'def@192.168.8.104'}]}]},
{sync_nodes_mandatory, ['abc@192.168.8.104', 'def@192.168.8.104']},
{sync_nodes_timeout, 30000}
]}].
def.config
[
{logger,[{console,[{format,<<"$date $time $metadata[$level] $message\n">>}]}]},
{kernel,
[{distributed, [
{distro,5000, ['abc@192.168.8.104', {'bcd@192.168.8.104', 'def@192.168.8.104'}]}]},
{sync_nodes_mandatory, ['abc@192.168.8.104', 'bcd@192.168.8.104']},
{sync_nodes_timeout, 30000}
]}].
在不同的终端自动全部3个节点
iex --name abc@192.168.8.104 -pa _build/dev/lib/distro/ebin/ --app distro \
--erl "-config config/abc"
iex --name bcd@192.168.8.104 -pa _build/dev/lib/distro/ebin/ --app distro \
--erl "-config config/bcd"
iex --name def@192.168.8.104 -pa _build/dev/lib/distro/ebin/ --app distro \
--erl "-config config/def"
验证步骤
bcd
, def
是 abc
的备用节点. bcd
优先于def
, 如果abc
死掉, 应用程序会在bcd
上重启, 如果bcd
死掉, 应用程序会转移到def
, 这时候abc
, bcd
修复启动后, 应用会被abc
接管.
终止(Ctrl+C两次)节点
abc@192.168.8.104
后,5秒内会在节点bcd@192.168.8.104
上重启应用再次启动节点
abc@192.168.8.104
后,应用在bcd@192.168.8.104
上停止, 应用被恢复后的abc@192.168.8.104
节点接管(Takeover)