どのようにこのerlangの例を実行する

Question

誰かがこの単純な分散erlangのexampeで私を助けることができます。このerlangプログラムをどのように動かすことができますか？ 私はerl -sname pc1、erl -sname pc2、erl -snameサーバ の3つのシェルを見ており、それらの間を接続するためにpc1とpc2サーバからpingを行っています。 今私はこのプログラムをテストするために何をする必要がありますか？

-module(pubsub2). 
-export([startDispatcher/0, startClient/0, 
    subscribe/2, publish/3]). 

startClient() -> 
    Pid = spawn(fun clientLoop/0), 
    register(client, Pid). 

clientLoop() -> 
    receive {Topic, Message} -> 
     io:fwrite("Received message ~w for topic ~w~n", 
       [Message, Topic]), 
     clientLoop() 
    end. 

subscribe(Host, Topic) -> 
    {dispatcher, Host} ! {subscribe, node(), Topic}. 

publish(Host, Topic, Message) -> 
    {dispatcher, Host} ! {publish, Topic, Message}. 

startDispatcher() -> 
    Pid = spawn(fun dispatcherLoop/0), 
    register(dispatcher, Pid). 

dispatcherLoop() -> 
    io:fwrite("Dispatcher started\n"), 
    dispatcherLoop([]). 
dispatcherLoop(Interests) -> 
    receive 
    {subscribe, Client, Topic} -> 
     dispatcherLoop(addInterest(Interests, Client, Topic)); 
    {publish, Topic, Message} -> 
     Destinations = computeDestinations(Topic, Interests), 
     send(Topic, Message, Destinations), 
     dispatcherLoop(Interests) 
    end. 

computeDestinations(_, []) -> []; 
computeDestinations(Topic, [{SelectedTopic, Clients}|T]) -> 
    if SelectedTopic == Topic -> Clients; 
     SelectedTopic =/= Topic -> computeDestinations(Topic, T) 
    end. 

send(_, _, []) -> ok; 
send(Topic, Message, [Client|T]) -> 
    {client, Client} ! {Topic, Message}, 
    send(Topic, Message, T). 

addInterest(Interests, Client, Topic) -> 
    addInterest(Interests, Client, Topic, []). 
addInterest([], Client, Topic, Result) -> 
    Result ++ [{Topic, [Client]}]; 
addInterest([{SelectedTopic, Clients}|T], Client, Topic, Result) -> 
    if SelectedTopic == Topic -> 
     NewClients = Clients ++ [Client], 
     Result ++ [{Topic, NewClients}] ++ T; 
     SelectedTopic =/= Topic -> 
     addInterest(T, Client, Topic, Result ++ [{SelectedTopic, Clients}]) 
    end. 

Answer 1

私はあなたの本をお勧め：

(n1@ubuntu)1> pubsub2:startClient(). 
(n1@ubuntu)2> pubsub2:subscribe('n2@ubuntu', football). 

：3つの異なるシェルN1 DOで

erl -sname n1 
(n1@ubuntu)1> pubsub2:startClient(). 

erl -sname n2 
(n1@ubuntu)1> pubsub2:startDispatcher(). 

erl -sname n3 
(n1@ubuntu)1> pubsub2:startClient(). 

を開始し、あなたはすべてのノードが同じCookieを共有することを考えると、とにかくhttp://www.erlang.org/doc/getting_started/conc_prog.html

を

in n3：

N1で210

(n3@ubuntu)1> pubsub2:startClient(). 
(n3@ubuntu)1> pubsub2:publish('n2@ubuntu', football, news1). 

あなたが得る必要があります。もちろん

Received message news1 for topic football 

をあなたが望むように、あなたはそれを拡張することができます。