Erlang服务器编程思想和实现

阿树 2012-03-04

下面会写到4个服务器程序,他们以server1,server2...这样的方式命名,好戏即将开始深吸一口气,go!!

更多关于Erlang的详细信息,或者下载地址请点这里

1.server1 原始服务器程序

server1.erl

  1. -module(server1).  
  2. -export([start/2, rpc/2]).  
  3.   
  4. start(Name, Mod) ->  
  5.     register(Name, spawn(fun() -> loop(Name, Mod, Mod:init()) end)).  
  6.   
  7. rpc(Name, Request) ->  
  8.     Name ! {self(), Request},  
  9.     receive  
  10.         {Name, Response} -> Response  
  11.     end.  
  12.   
  13. loop(Name, Mod, State) ->  
  14.     receive  
  15.     {From, Request} ->  
  16.             {Response, State1} = Mod:handle(Request, State),  
  17.             From ! {Name, Response},  
  18.             loop(Name, Mod, State1)  
  19.     end. 

这段代码是erlang的标准服务器程序,下面写一个回调函数来运行测试。

name_server.erl

  1. -module(name_server).  
  2. -export([init/0, add/2, whereis/1, handle/2]).  
  3. -import(server1, [rpc/2]).  
  4.   
  5. %% client routines  
  6. add(Name, Place) -> rpc(name_server, {add, Name, Place}).  
  7. whereis(Name)    -> rpc(name_server, {whereis, Name}).  
  8.   
  9. %% callback routines  
  10. init() -> dict:new().  
  11.   
  12. handle({add, Name, Place}, Dict) -> {ok, dict:store(Name, Place, Dict)};  
  13. handle({whereis, Name}, Dict)    -> {dict:find(Name, Dict), Dict}.

首先看后面的代码1.他负责回调服务器程序,处理其他进程发货来的请求2.相当于定义接口。

如下运行程序:

  1. erlc *.erl   
  1. Eshell V5.6.5  (abort with ^G)  
  2. 1> server1:start(name_server, name_server).  
  3. true  
  4. 2> nameserver:add("lengzijian","go to school").  
  5. ** exception error: undefined function nameserver:add/2  
  6. 3> name_server:add("lengzijian","go to school").  
  7. ok  
  8. 4> name_server:whereis("lengzijian").  
  9. {ok,"go to school"}  
  10. 5>   

如果读者细心可以发现,这段代码里面并没有spawn这样的创建进程的命令,不错,这个服务器程序完全是顺序性代码,也许有人质疑这样做的意义,不要急这才刚刚开始

2.server2:支持事务的服务器程序

接下来要向大家展示的是,当服务器宕机,客户端回或得到异常,然后做相应的处理。

server2.erl

  1. -module(server2).  
  2. -export([start/2, rpc/2]).  
  3.   
  4. start(Name, Mod) ->  
  5.     register(Name, spawn(fun() -> loop(Name,Mod,Mod:init()) end)).  
  6.   
  7. rpc(Name, Request) ->  
  8.     Name ! {self(), Request},  
  9.     receive  
  10.         {Name, crash} -> exit(rpc);  
  11.         {Name, ok, Response} -> Response  
  12.     end.  
  13.   
  14. loop(Name, Mod, OldState) ->  
  15.     receive  
  16.     {From, Request} ->  
  17.         try Mod:handle(Request, OldState) of  
  18.         {Response, NewState} ->  
  19.             From ! {Name, ok, Response},  
  20.             loop(Name, Mod, NewState)  
  21.         catch  
  22.         _:Why ->  
  23.             log_the_error(Name, Request, Why),  
  24.             %% send a message to cause the client to crash  
  25.             From ! {Name, crash},  
  26.             %% loop with the *original* state  
  27.             loop(Name, Mod, OldState)  
  28.         end  
  29.     end.  
  30.   
  31. log_the_error(Name, Request, Why) ->  
  32.     io:format("Server ~p request ~p ~n"  
  33.           "caused exception ~p~n",   
  34.           [Name, Request, Why]).    

想对于之前的版本,多了注册函数和创建进程函数,可以理解的认为是增加了并行操作,但是我之前做过一些小项目而言,erlang的进程的确有他特殊的地方,这里会在之后的文章详细讲解,这段代码实际上是提供了“事务机制”,在handler发生异常时,回调用loop(Name, Mod, OldState)在之前的状态下进行循环,否则会在新的状态下进行运行

流程是怎样的呢:当服务端宕机,服务器会给客户端发送crash消息,说明服务器异常,然后客户端接收到消息后,可以做相应处理(在我们的项目中用到的是重连,例子中是退出),然后调用loop并带入变量OldState说明本次服务处理异常,同时不影响其他连接到服务器的客户端。

要测试的话,与server1完全相同只需要改变import时改为server2即可。

相关推荐

ganyouxianjava / 0评论 2012-05-31