Erlang服务器编程思想和实现
下面会写到4个服务器程序，他们以server1，server2...这样的方式命名，好戏即将开始深吸一口气，go！！
更多关于Erlang的详细信息，或者下载地址请点这里
1.server1 原始服务器程序
server1.erl
- -module(server1).
- -export([start/2, rpc/2]).
- start(Name, Mod) ->
- register(Name, spawn(fun() -> loop(Name, Mod, Mod:init()) end)).
- rpc(Name, Request) ->
- Name ! {self(), Request},
- receive
- {Name, Response} -> Response
- end.
- loop(Name, Mod, State) ->
- receive
- {From, Request} ->
- {Response, State1} = Mod:handle(Request, State),
- From ! {Name, Response},
- loop(Name, Mod, State1)
- end.
这段代码是erlang的标准服务器程序，下面写一个回调函数来运行测试。
name_server.erl
- -module(name_server).
- -export([init/0, add/2, whereis/1, handle/2]).
- -import(server1, [rpc/2]).
- %% client routines
- add(Name, Place) -> rpc(name_server, {add, Name, Place}).
- whereis(Name) -> rpc(name_server, {whereis, Name}).
- %% callback routines
- init() -> dict:new().
- handle({add, Name, Place}, Dict) -> {ok, dict:store(Name, Place, Dict)};
- handle({whereis, Name}, Dict) -> {dict:find(Name, Dict), Dict}.
首先看后面的代码1.他负责回调服务器程序，处理其他进程发货来的请求2.相当于定义接口。
如下运行程序：
- erlc *.erl
- Eshell V5.6.5 (abort with ^G)
- 1> server1:start(name_server, name_server).
- true
- 2> nameserver:add("lengzijian","go to school").
- ** exception error: undefined function nameserver:add/2
- 3> name_server:add("lengzijian","go to school").
- ok
- 4> name_server:whereis("lengzijian").
- {ok,"go to school"}
- 5>
如果读者细心可以发现，这段代码里面并没有spawn这样的创建进程的命令，不错，这个服务器程序完全是顺序性代码，也许有人质疑这样做的意义，不要急这才刚刚开始
2.server2：支持事务的服务器程序
接下来要向大家展示的是，当服务器宕机，客户端回或得到异常，然后做相应的处理。
server2.erl
- -module(server2).
- -export([start/2, rpc/2]).
- start(Name, Mod) ->
- register(Name, spawn(fun() -> loop(Name,Mod,Mod:init()) end)).
- rpc(Name, Request) ->
- Name ! {self(), Request},
- receive
- {Name, crash} -> exit(rpc);
- {Name, ok, Response} -> Response
- end.
- loop(Name, Mod, OldState) ->
- receive
- {From, Request} ->
- try Mod:handle(Request, OldState) of
- {Response, NewState} ->
- From ! {Name, ok, Response},
- loop(Name, Mod, NewState)
- catch
- _:Why ->
- log_the_error(Name, Request, Why),
- %% send a message to cause the client to crash
- From ! {Name, crash},
- %% loop with the *original* state
- loop(Name, Mod, OldState)
- end
- end.
- log_the_error(Name, Request, Why) ->
- io:format("Server ~p request ~p ~n"
- "caused exception ~p~n",
- [Name, Request, Why]).
想对于之前的版本，多了注册函数和创建进程函数，可以理解的认为是增加了并行操作，但是我之前做过一些小项目而言，erlang的进程的确有他特殊的地方，这里会在之后的文章详细讲解，这段代码实际上是提供了“事务机制”，在handler发生异常时，回调用loop(Name, Mod, OldState)在之前的状态下进行循环，否则会在新的状态下进行运行
流程是怎样的呢：当服务端宕机，服务器会给客户端发送crash消息，说明服务器异常，然后客户端接收到消息后，可以做相应处理（在我们的项目中用到的是重连，例子中是退出），然后调用loop并带入变量OldState说明本次服务处理异常，同时不影响其他连接到服务器的客户端。
要测试的话，与server1完全相同只需要改变import时改为server2即可。
相关推荐
IT之家 2020-03-11
graseed 2020-10-28
zbkyumlei 2020-10-12
SXIAOYI 2020-09-16
jinhao 2020-09-07
impress 2020-08-26
liuqipao 2020-07-07
淡风wisdon大大 2020-06-06
yoohsummer 2020-06-01
chenjia00 2020-05-29
baike 2020-05-19
扭来不叫牛奶 2020-05-08
hxmilyy 2020-05-11
黎豆子 2020-05-07
xiongweiwei00 2020-04-29
Cypress 2020-04-25
冰蝶 2020-04-20