在erlang中是否有办法向远程节点发送闭包?



似乎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,因为模块已经在本地节点中编译和加载。

最新更新