2

我正在测试这样的节点间函数调用（rpc）：

defmodule RpcTest do
  def run do 
    Task.Supervisor.async( {DBServer.DistSupervisor, :'dbserver@hostname'},  fn -> "test" end)
    |> Task.await
    |> IO.inspect
  end
end

然后我运行dbservernode，调用接收rcp，在另一个node执行上面的Task.Supervisor.start_link(name: DBServer.DistSupervisor)代码dbserverdbclient

它可以正确运行 rpc，如下所示。

dbserver

$ iex --sname dbserver --cookie a -S mix
Erlang/OTP 18 [erts-7.3] [source] [64-bit] [smp:8:8] [async-threads:10] [hipe] [kernel-poll:false] [dtrace]

Compiling 1 file (.ex)
Interactive Elixir (1.3.1) - press Ctrl+C to exit (type h() ENTER for help)
iex(dbserver@hostname)1> Task.Supervisor.start_link(name: DBServer.DistSupervisor)
{:ok, #PID<0.101.0>}
iex(dbserver@hostname)2>

dbclient

$ elixir --sname dbclient --cookie a -S mix run -e RpcTest.run
"test"

但是，将代码从“更改"test"为"test test”后，dbclient 节点不起作用。

这是错误消息

dbserver

iex(dbserver@hostname)2> 
12:54:57.430 [error] Task #PID<0.110.0> started from {:"dbclient@hostname", #PID<13423.52.0>} terminating
** (BadFunctionError) expected a function, got: #Function<0.113878361/0 in RpcTest>
    :erlang.apply/2
    (elixir) lib/task/supervised.ex:94: Task.Supervised.do_apply/2
    (elixir) lib/task/supervised.ex:45: Task.Supervised.reply/5
    (stdlib) proc_lib.erl:240: :proc_lib.init_p_do_apply/3
Function: #Function<0.113878361/0 in RpcTest>
    Args: []

dbclient

$ elixir --sname dbclient --cookie a -S mix run -e RpcTest.run
Compiling 1 file (.ex)
** (EXIT from #PID<0.52.0>) an exception was raised:
    ** (BadFunctionError) expected a function, got: #Function<0.113878361/0 in RpcTest.run/0>
        :erlang.apply/2
        (elixir) lib/task/supervised.ex:94: Task.Supervised.do_apply/2
        (elixir) lib/task/supervised.ex:45: Task.Supervised.reply/5
        (stdlib) proc_lib.erl:240: :proc_lib.init_p_do_apply/3

此外，它在手动重新启动后确实有效。dbserver

有趣的是，它适用于iex任何代码。

$ iex --sname dbclient --cookie a -S mix
Erlang/OTP 18 [erts-7.3] [source] [64-bit] [smp:8:8] [async-threads:10] [hipe] [kernel-poll:false] [dtrace]

Compiling 1 file (.ex)
Interactive Elixir (1.3.1) - press Ctrl+C to exit (type h() ENTER for help)
iex(dbclient@hostname)1> Task.Supervisor.async( {DBServer.DistSupervisor, :'dbserver@hostname'},  fn -> "test" end) |>  
...(dbclient@hostname)1> Task.await |>                                      
...(dbclient@hostname)1> IO.inspect                                          
"test"                                       
"test"
iex(dbclient@hostname)2> Task.Supervisor.async( {DBServer.DistSupervisor, :'dbserver@hostname'},  fn -> "test test" end) |> 
...(dbclient@hostname)2> Task.await |>                                      
...(dbclient@hostname)2> IO.inspect  
"test test"                                       
"test test"

我的问题是，

  • 从另一个节点调用节点中的函数是错误的方法吗？
  • 使用节点间函数调用时，每次更改客户端代码时是否必须重新执行被调用节点？
  • iex为什么和之间的行为不同elixir script？

代码和整个项目上传到这里：https ://github.com/ayamamori/rpc_test/blob/master/lib/rpc_test.ex

提前致谢！

4

1 回答 1

1

在 IEx 中声明的函数和在模块中声明的函数之间存在细微差别，即使它们是匿名的。

假设我们有以下模块：

defmodule FunInfo do
  def info do
    :erlang.fun_info(fn -> "test" end)
  end
end

现在在IEx：

iex(1)> FunInfo.info
[pid: #PID<0.91.0>, module: FunInfo, new_index: 0,
 new_uniq: <<98, 250, 216, 183, 54, 136, 109, 221, 200, 243, 9, 84, 249, 185, 187, 173>>,
 index: 0, uniq: 51893957, name: :"-info/0-fun-0-", arity: 0, env: [], 
 type: :local]

和相同的函数，但在 IEx 中声明：

iex(2)> :erlang.fun_info(fn -> "test" end)
[pid: #PID<0.91.0>, module: :erl_eval, new_index: 20,
 new_uniq: <<103, 57, 49, 11, 11, 201, 159, 65, 226, 96, 121, 97, 18, 82, 151, 208>>,
 index: 20, uniq: 54118792, name: :"-expr/5-fun-3-", arity: 0,
 env: [{[], :none, :none,
   [{:clause, 12, [], [],
     [{:bin, 0,
       [{:bin_element, 0, {:string, 0, 'test'}, :default, :default}]}]}]}],
 type: :local]

我们可以强调一些关于函数信息的事情。对于FunInfo模块中定义的，我们有：

  • module: FunInfo
  • :new_uniq:和:uniq标识符。
  • :env不包含函数的 AST。

而对于 IEx 中的定义，我们有：

  • module: :erl_eval
  • :new_uniq:和:uniq标识符。
  • :env具有匿名函数的 AST。

模块中声明的匿名函数

每次更改匿名函数源代码时，和值都会更改:new_uniq。:uniq如果两个节点具有相同模块的不同版本，则此匿名函数将具有不同:new_uniq的:uniq标识符。当您尝试执行服务器不知道的匿名函数时，它将失败。

IEx 中声明的匿名函数

:new_uniq和:uniq值不会因您声明的每个函数而改变。它们存在于:erl_eval已编译的模块中，您无需更改其源代码。此外，在 IEx 中声明的每个函数都有其 AST，:env因此当您要求远程节点执行该函数时，您也在发送函数的主体。

iex(1)> :erlang.fun_info(fn -> "test" end)
[pid: #PID<0.91.0>, module: :erl_eval, new_index: 20,
 new_uniq: <<103, 57, 49, 11, 11, 201, 159, 65, 226, 96, 121, 97, 18, 82, 151, 208>>,
 index: 20, uniq: 54118792, name: :"-expr/5-fun-3-", arity: 0,
 env: [{[], :none, :none,
       [{:clause, 26, [], [],
         [{:bin, 0,
           [{:bin_element, 0, {:string, 0, 'test'}, :default, :default}]}]}]}],
 type: :local]

如果我创建另一个匿名函数，:new_uniq并且:uniq值不会改变，但:env值会随着正确的 AST 而改变。

iex(2)> :erlang.fun_info(fn -> "test test" end)
[pid: #PID<0.91.0>, module: :erl_eval, new_index: 20,
new_uniq: <<103, 57, 49, 11, 11, 201, 159, 65, 226, 96, 121, 97, 18, 82, 151, 208>>,
 index: 20, uniq: 54118792, name: :"-expr/5-fun-3-", arity: 0,
 env: [{[], :none, :none,
       [{:clause, 27, [], [],
         [{:bin, 0,
           [{:bin_element, 0, {:string, 0, 'test test'}, :default, :default}]}]}]}],
 type: :local]

我希望这回答了你的问题。

于 2016-07-04T11:57:46.147 回答