注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

眼睛想旅行

技术就是我的生命与信仰!

 
 
 

日志

 
 
关于我

精通C,C++,python,Erlang。并熟悉各种其他编程语言,用cocos2dx游戏引擎作过几个项目。会MySQL增删改查,了解OpenGL渲染原理。懂单片机,能设计数字电路系统,会画电路图和设计电路板。喜欢了解最新前沿技术,并持续关注和学习新技术。

网易考拉推荐

erlang中socket知识点(转)  

2014-06-23 12:01:20|  分类: Erlang |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
Erlang Socket
a. 最核心的概念 - socket控制进程
b. 基本的C/S结构的例子(服务器只能处理一个客户端连接)
c. 顺序型服务器的例子(服务器顺序的处理客户端的请求,每次只能处理一个,处理完一个处
      理下一个)
d. 并发型服务器的例子(服务器并发的处理多个客户端的请求)

e. 控制逻辑 - 主动型消息接收(非阻塞)
f. 控制逻辑 - 被动型消息接收(阻塞)
g. 控制逻辑 - 混合型消息接收(半阻塞)


1. 最基本的Erlang C/S结构的例子:
<1> 创建一个socket的进程(调用gen_tcp:accept或gen_tcp:connect)也就是socket的
控制进程,这个socket接收到的所有数据都转发给控制进程,如果控制进程消亡,socket也
会自行关闭,可以调用gen_tcp:controlling_process(Socket, NewPid)来把一个socket
的控制进程改为新的进程。

<2> 服务器端和客户端使用的{packet, N}的参数必须一致

<3> 在接收到一个连接的时候,显示的设置socket的属性,是一个好的策略
      {ok, Socket} = gen_tcp:accept(Listen),
       inet:setopts(Socket, [{packet, 4}, {active, true}, {nodelay, true}])

-module(server).
-export([start/0]).

start() ->
    {ok, Listen} = gen_tcp:listen(2345, [binary, {packet, 4},
                  {reuseaddr, true},
                  {active, true}]),
    {ok, Socket} = gen_tcp:accept(Listen),
    gen_tcp:close(Listen),
    loop(Socket).

loop(Socket) ->
    receive
{tcp, Socket, Bin} ->
    io:format("received: ~p~n", [Bin]),
    gen_tcp:send(Socket, iolist_to_binary(["server#",Bin])),
    loop(Socket);
{tcp_closed, Socket} ->
    io:format("[~p] tcp_closed~n", [Socket]);
{tcp_error, Socket, Reason} ->
    io:format("[~p] tcp_error: ~p~n", [Socket, Reason])
    end.


-module(client).
-export([echo/1]).

echo(Data) ->
    {ok, Socket} = gen_tcp:connect("localhost", 2345, [binary, {packet, 4}]),
    ok = gen_tcp:send(Socket, Data),
    receive
{tcp, Socket, Bin} ->
    io:format("~p~n", [Bin]),
    gen_tcp:close(Socket)
    end.

2. 顺序型服务器的例子

start() ->
    {ok, Listen} = gen_tcp:listen(2345, [binary, {packet, 4},
                   {reuseaddr, true},
                   {active, true}]),
    seq_accept(Listen).

seq_accept(Listen) ->
    {ok, Socket} = gen_tcp:accept(Listen),
    loop(Socket),
    seq_accept(Listen).

loop(Socket) … 不变
  
3. 并发型服务器的例子

start() ->
    {ok, Listen} = gen_tcp:listen(2345, [binary, {packet, 4},
 {reuseaddr, true},
 {active, true}]),
    spawn(fun() -> accept(Listen) end).

accept(Listen) ->
    {ok, Socket} = gen_tcp:accept(Listen),
    spawn(fun() -> accept(Listen) end),
    loop(Socket).

loop(Socket) … 不变


4. 控制逻辑
<1> {active, true} – 主动 socket - 非阻塞模式
      当数据到达系统之后,会向控制进程发送{tcp, Socket, Data}的消息,而控制进程无法控制
这些消息,一个独立的客户端可能向系统发送上万条消息,这些消息都会发送到控制进程,控制
进程无法控制挺掉这些消息。

<2> {active, false} – 被动socket - 阻塞模式
      如果是被动socket, 则socket必须调用gen_tcp:recv(Socket, N)来接收数据,它尝试接收
N字节的数据,如果N为0,那么所有可用的字节都会返回。
默认是: gen_tcp:(Socket, N, infinity),也即使无限等待直到有数据可以接收,所以是
      阻塞的模式。

<3> {active, once} – 半主动socket
      会创建一个主动socket,可以接收一条消息,但这个 socket所接收一条消息以后,如果让它接
      收下一条消息,必须激活它。
      inet:setopts(Socket, [{active, once}]) – 激活Socket的方式

5. 主动型接收 - 非阻塞模式- 异步服务器

{ok, Listen} = gen_tcp:listen( … {active, true}  … ),
{ok, Socket} = gen_tcp:accept(Listen),
loop(Socket).

loop(Socket) ->
    receive
{tcp, Socket, Data} ->
         …;
{tcp_closed, Socket} ->
  ...
    end.

6. 被动型接收 - 阻塞模式 – 同步服务器

{ok, Listen} = gen_tcp:listen( … {active, false}  … ),
{ok, Socket} = gen_tcp:accept(Listen),
loop(Socket).

loop(Socket) ->
    case gen_tcp:recv(Socket, 0) of
{ok, Data} ->
   …
   loop(Socket);
{error, closed} ->
   ...
    end.


7. 混合型模式 - 半同步服务器

{ok, Listen} = gen_tcp:listen( … {active, once}  … ),
{ok, Socket} = gen_tcp:accept(Listen),
loop(Socket).

loop(Socket) ->
    receive
{tcp, Socket, Data} ->
         …
  inet:setopts(Socket, [{active, once}]),
  loop(Socket);
{tcp_closed, Socket} ->
  ...
    end.

8. socket的出错处理:
<1> 每个socket都对应一个控制进程,如果控制进程消亡,则socket也会自动关闭
<2> 如果服务器端应为逻辑崩溃,那么服务器端的 socket会自动关闭,同时客户端也会收到
       {tcp_closed, Socket}的消息


转自:http://blog.csdn.net/wangyangkobe/article/details/9124427
下边是我写的一个socket的例子。自已试了,可以连接上。


-module(gameSocketServer).

%% ====================================================================

%% API functions

%% ====================================================================

-export([start/0]).

%% ====================================================================

%% Internal functions

%% ====================================================================

start() ->

{ok,Listen} = gen_tcp:listen(2345, [binary,{packet,0},{reuseaddr,true},{active,once}]),

spawn(fun() -> accept(Listen) end).

accept(Listen) ->

{ok,Socket} = gen_tcp:accept(Listen),

spawn(fun() -> accept(Listen) end),

loop(Socket).

loop(Socket) ->

receive

{tcp,Socket,Bin} ->

io:format("received:~p~n", [Bin]),

gen_tcp:send(Socket, iolist_to_binary(["server#",Bin])),

inet:setopts(Socket, [{active,once}]),

loop(Socket);

{tcp_closed,Socket} ->

io:format("[~p] tcp_closed~n",[Socket]);

{tcp_error,Socket,Reason} ->

io:format("[~p] tcp_error:~p ~n", [Socket,Reason])

end.

  评论这张
 
阅读(329)| 评论(0)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017