Erlang TCP Socket的接收进程的2种方案

简介: 转自:http://blog.csdn.net/summerhust/article/details/8740973   一旦打开了一个使用TCP连接的套接字,它就始终保持打开状态,直至任何一方关闭它或因为一个错误而终止。

转自:http://blog.csdn.net/summerhust/article/details/8740973

 

一旦打开了一个使用TCP连接的套接字,它就始终保持打开状态,直至任何一方关闭它或因为一个错误而终止。在建立一个连接时,一般为每一次请求产生一个新进程,只要有请求被处理,就保持这个进程的存活。

假设有一个监听进程,其任务是等待传入的TCP请求。只要一个请求到达,响应该连接请求的进程就变成了接收进程,有2种方案:

1. 产生新的进程并成为接收进程,而监听者返回并继续监听下一个新的连接请求:

server() ->  

    {ok, ListenSocket} = gen_tcp:listen(1234, [binary, {active, false}]),  

    wait_connect(ListenSocket,0).  

 wait_connect(ListenSocket, Count) ->  

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

    Pid = spawn(?MODULE, get_request, [Socket, [], Count]),  

    %将该套接字的控制进程改为Pid进程  

    gen_tcp:controlling_process(Socket, Pid),  

    wait_connect(ListenSocket, Count+1).  

      

  

get_request(Socket, BinaryList, Count) ->  

    case gen_tcp:recv(Socket, 0, 5000) of  

    {ok, Binary} ->  

        io:format("received data: ~p~n", [binary_to_list(Binary)]),  

        get_request(Socket, [Binary|BinaryList], Count);  

    {error, closed} ->  

        handle(lists:reverse(BinaryList), Count)  

    end.  

 

2. 使监听进程成为接收进程,并使产生的新进程成为新的监听者:

 

server() ->  

    {ok, ListenSocket} = gen_tcp:listen(1234, [binary, {active, false}]),  

    wait_connect(ListenSocket,0). 

 

wait_connect(ListenSocket, Count) ->  

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

    spawn(?MODULE, wait_connect, [ListenSocket, Count+1]),  

    get_request(Socket, [], Count).  

 

说明:

(1)  创建一个套接字的进程(通过调用gen_tcp:accept或gen_tcp:connect)也就是该套接字的控制进程,该套接字所收到的任何消息都会转发给这个控制进程,如果控制进程消亡,那么该套接字也会自行关闭。我们可以通过gen_tcp:controlling_process(Socket, NewPid)函数来把一个套接字的控制进程改为新的控制进程NewPid;

(2) gen_tcp:accept和gen_tcp:recv是阻塞的,可以用prim_inet:async_accept和prim_inet:async_recv实现非阻塞。

相关文章
|
1月前
|
安全 Java 数据处理
Python网络编程基础(Socket编程)多线程/多进程服务器编程
【4月更文挑战第11天】在网络编程中,随着客户端数量的增加,服务器的处理能力成为了一个重要的考量因素。为了处理多个客户端的并发请求,我们通常需要采用多线程或多进程的方式。在本章中,我们将探讨多线程/多进程服务器编程的概念,并通过一个多线程服务器的示例来演示其实现。
|
2天前
|
算法 Linux 调度
xenomai内核解析--xenomai与普通linux进程之间通讯XDDP(一)--实时端socket创建流程
xenomai与普通linux进程之间通讯XDDP(一)--实时端socket创建流程
7 1
xenomai内核解析--xenomai与普通linux进程之间通讯XDDP(一)--实时端socket创建流程
|
18天前
|
网络协议 Linux Go
Go语言TCP Socket编程(下)
Go语言TCP Socket编程
|
18天前
|
网络协议 Ubuntu Unix
Go语言TCP Socket编程(上)
Go语言TCP Socket编程
|
18天前
|
存储 网络协议 关系型数据库
Python从入门到精通:2.3.2数据库操作与网络编程——学习socket编程,实现简单的TCP/UDP通信
Python从入门到精通:2.3.2数据库操作与网络编程——学习socket编程,实现简单的TCP/UDP通信
|
23天前
|
网络协议 Linux Windows
TCP/IP、Http、Socket之间的区别
TCP/IP、Http、Socket之间的区别
|
26天前
|
网络协议 Ubuntu Unix
Linux 下使用 socket 实现 TCP 客户端
Linux 下使用 socket 实现 TCP 客户端
|
2月前
|
网络协议 Linux
TCP 和 UDP 的 Socket 调用
【2月更文挑战第19天】
TCP 和 UDP 的 Socket 调用
|
2月前
|
网络协议 Java
【计算机网络】TCP socket编程
【计算机网络】TCP socket编程
|
3月前
|
监控 Unix Linux
socket监控进程,并对程序执行有关操作。
socket监控进程,并对程序执行有关操作。

相关实验场景

更多