似乎erlang只向远程节点发送有趣的引用。当试图发送闭包时,它显然在调用模块中内联了闭包,并向远程节点发送一个内联的fun ref。下面是测试:
-module(funserver).
-compile(export_all).
loop()->
receive {From, ping} ->
error_logger:info_msg("received ping from ~p~n", [From]),
From ! pong,
loop();
{From, Fun} when is_function(Fun) ->
error_logger:info_msg("executing function ~p received from ~p~n", [Fun, From]),
From ! Fun(),
loop();
M ->
error_logger:error_msg("received ~p, don't know what to do with it", [M])
end.
和客户端节点上的测试:
test_remote_node_can_execute_sent_clojure()->
{ok, ModName, Binary} = compile:file(funserver, [verbose,report_errors,report_warnings, binary]),
{module, ModName} = rpc:call(?other_node, code, load_binary, [ModName, atom_to_list(ModName), Binary]),
Pid = spawn(?other_node, funserver, loop, []),
OutVar = {"token with love from", node()},
Pid ! {self(), fun()-> {OutVar, erlang:node()} end},
receive Result ->
Result = {OutVar, node(Pid)}
after 300 ->
timeout
end.
得到
Error in process <7162.123.0> on node servas@sharas with exit value:
{undef,[{#Fun<tests.1.127565388>,[],[]},
{funserver,loop,0,[{file,"funserver.erl"},{line,12}]}]}
timeout
那么clojure可以被发送到远程节点吗?
您的示例的问题是,客户端节点编译并发送funserver
模块到远程节点-但该模块已经存在并执行,等待接收消息-但它不发送tests
模块,这是模块,实际上包含您正在发送的乐趣。
在compile:file
行中,将funserver
更改为tests
,应该可以工作。
另外,您可以使用code:get_object_code
而不是compile:file
,因为模块已经在本地节点中编译和加载。