erlang套接字

Erlang的套接字可以有三种打开模式:主动(active)、单次主动(active once)或被动(passive)。
这是通过在gen_tcp:connect(Address, Port, Options)或gen_tcp:listen(Port, Options)
的Options参数里加入{active, true | false | once}选项实现的。

如果指定{active, true}就会创建一个主动套接字,指定{active, false}则是被动套接
字。{active, once}创建的套接字只会主动接收一个消息,接收完之后必须重新启用才能接收
下一个消息。

一、主动型

当一个主动套接字被创建后,它会在收到数据时向控制进程发送{tcp, Socket, Data}
消息。控制进程无法控制这些消息流。恶意的客户端可以向系统发送成千上万的消息,
而它们都会被发往控制进程。控制进程无法阻止这些消息流。

进程无法控制通往服务器循环的消息流。如果客户端生成数据的速度快于服务器处理数
据的速度,系统就会遭受数据洪流的冲击:消息缓冲区会被塞满,系统可能会崩溃或表现异常。

{ok,Listen} = gen_tcp:listen(Port,[...,{active,true},...]),
{ok,Socket} = gen_tcp:accapt(Listen),
loop(Socket).
loop(Socket) ->receive{tcp,Socket,Data} ->对数据进行操作{tcp_closed,Socket} ->....end.

 

二、被动型

如果一个套接字是用被动模式打开的,控制进程就必须调用gen_tcp:recv(Socket, N)
来从这个套接字接收数据。然后它会尝试从套接字接收N个字节。如果N = 0,套接字就
会返回所有可用的字节。在这个案例里,服务器可以通过选择何时调用gen_tcp:recv来
控制客户端所发的消息流

{ok,Listen} = gen_tcp:listen(Port,[...,{active,true},...]),
{ok,Socket} = gen_tcp:accapt(Listen),
loop(Socket).
loop(Socket) ->case gen_tcp:recv(Socket,N) of{Ok, B} ->...对数据进行操作...loop(Socket);{error,closed}...end.

 

三、混合型

既不是阻塞也不是非阻塞。用{active, once}选项打开套接字。套接字在这个模式下虽然是主动的,但只针对一个消息。当控制进程收到一个消
息后,必须显式调用inet:setopts才能重启下一个消息的接收,在此之前系统会处于阻塞状态。这种方法集合了前两种模式的优点

{ok,Listen} = gen_tcp:listen(Port,[...,{active,once},...]),
{ok,Socket} = gen_tcp:accapt(Listen),
loop(Socket).
loop(Socket) ->receive{tcp,Socket,Data} ->对数据进行操作准备接收下一个消息inet:setopts(Socket,[{active,once}]),loop(Socket);{tcp_closed,Socket} ->....end.

 

转载于:https://www.cnblogs.com/yanwei-wang/p/4710436.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/419686.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

php 类学习,php的类学习(一)

function __autoload($class_name){//require_once语句在脚本执行期间包含并运行指定文件。此行为和 require()语句完全相同,唯一区别是如果该文件中的代码已经被包含了,则不会再次包含require_once $class_name . .php;}$obj new testAAA();$obj2new ty…

前端学习(1575):复习todoMVC

系统再演示一下angular的实现原理流程 分装实现 两个文件 js和html

蛋疼的中文编码及其计算机编码历史

更好的博客:http://my.oschina.net/goldenshaw/blog?catalog536953 一:编码发展: 1 ANSI编码:计算机在美国出现,使用单字节8位编码,共可以表示255个状态。(0-32(0x00-0x20&#xff…

java异常处理机简答题,【简答题】JAVA 语言如何进行异常处理,关键字: throws,throw,try,catch,finally 分别代表什么意义?...

【简答题】JAVA 语言如何进行异常处理,关键字: throws,throw,try,catch,finally 分别代表什么意义?更多相关问题用蒸汽进行设备管线吹扫时,应将被吹扫的设备管线,相应部位仪表引线阀关闭,防止损坏仪表。()铝壶内装有2.5kg的水,其温…

阐述linux IPC(五岁以下儿童):system V共享内存

【版权声明:尊重原创。转载请保留源:blog.csdn.net/shallnet 要么 .../gentleliu,文章学习交流,不用于商业用途】system V共享内存和posix共享内存类似,system V共享内存是调用shmget函数和shamat函数。 shmget函数创…

php io select,Python IO多路复用之——select方案服务端和客户端代码【python源码详解】...

准备文件:IO.py 服务端代码tcp_c.py 客户端代码IO.py 代码:from select import * #引入 select 模块from socket import * #引入 socket 模块s socket() #实例化一个socket 对象s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #设置端口可重用s.bind((0.0.0…

NDK和项目依赖

NDK使用 JDK:Java Development KitSDK:Software Development KitNDK:Native Development KitJNI: Java Nattive InterfaceNDK开发流程: 下载NDK并配置NDK路径新建项目 修改build.gradle文件 替换classpath:com.android.tools.build:gradle-experimental:0.4.0 替换a…

java创建树形子目录,Java之File类及递归树形展示目录_20150804

Java之File类及递归树形展示目录20150804下面的构造函数可以用来生成File 对象:File(String directoryPath)File(String directoryPath, String filename)File(File dirObj, String filename)这里,directoryPath是文件的路径名,filename 是文…

使用PDFBox解析PDF文件

今天在Nutch源码中准备增加一个PDF处理方面的功能,其中要做的一步是提取出PDF文档中的文本信息。考虑了一下,还是准备使用PDFBox。看了一下,Nutch源码中的parse-tika插件下有一个PDFBox,不过是1.1.0版本,很多PDF文档都…

matlab 数字图像滤波,数字图像处理 (基于Matlab) 滤波

《数字图像处理》实验报告一、实验目的(不少于200字)一、第一个实验用的是各种空间域的方式来滤波,也就是直接把图像和空间滤波器的模板做卷积,当然图像处理很重要的一个部分还有频域的处理。这就涉及到图像的傅里叶变换,通过将空域内的图像傅…

myelicpes怎么导入PHP项目,利用PHP执行SQL文件,将SQL文件导入到数据库

引用如何利用php自动执行 sql文件。其实很简单,就是获取sql文件中的内容,然后将每一句sql语句一次执行就行啦。//读取文件内容$_sql file_get_contents(test.sql);$_arr explode(;, $_sql);$_mysqli new mysqli(DB_HOST,DB_USER,DB_PASS);if (mysqli_…

atitit. 分销系统规划p8k

atitit. 分销系统规划p8k 1. 商户平台管理 overview2 1.1. 分销业务管理2 1.2. 文案管理2 1.3. 订单管理3 1.4. 统计报表3 1.5. 财务结算3 1.6. 自身信息管理4 2. 商户后台详细5 3. 推广人后台6 3.1. 产品及文案6 3.2. 订单与结算6 3.3. 下线邀请与奖励6 3.4. 订单统计6 3.5. 资…

php数据访问层设计,php - Zend框架数据访问层(DAL) - 堆栈内存溢出

好吧,在处理Data Access Layer ,您必须考虑的第一件事是该层还具有子层 ,在现代框架中很难找到名为“ dal”的文件夹(我以Zend为基础框架和Symfony)。其次,关于ActiveRecord ,您必须知道默认情况下Zend Frameworks 不会…

matlab 8.4,《DSP using MATLAB》Problem 8.42

代码:%% ------------------------------------------------------------------------%% Output Info about this m-filefprintf(‘\n***********************************************************\n‘);fprintf(‘ Problem 8.42 \n\n‘);banner();%% ------------…

lua的string.gsub初使用

今天在学习lua,熟悉项目代码的过程中,发现string.gsub好高级,所以在此mark下。 以下是lua5.1的官方文档介绍。 string.gsub (s, pattern, repl [, n])Returns a copy of s in which all occurrences of the pattern have been replaced by a …

php对象比较大小,PHP 面向对象:对象的比较

简明现代魔法 -> PHP服务器脚本 -> PHP 面向对象:对象的比较PHP 面向对象:对象的比较2010-04-07在PHP中有 赋值符号、 等于符号 和 全等于符号, 这些符号代表什么意思?当使用比较操作符()时,对象以一种很简单的规则比较&a…