高性能并发网络服务器设计与实现1课件

高性能并发网络服务器

设计与实现网络服务器开发协议设计(网络协议和应用协议)语法(报文格式)语义(指令的处理,交互时序等)只要涉及到交互(即使不是网络交互),就需要协议网络实现(IO)网络开发的基础是socket任何对网络的封装,在三度关系之内必然是socket(最多三层封装)第一节–网络IO重复服务serv=newTcpSocket();serv.listen();while(1){sock=serv.accept();while(1){//重复服务单用户sock.read(buf);sock.write(buf);}sock.close()}

一次服务没有并发短连接socketIOread/write是可阻塞的阻塞是并发和高性能的死敌实现并发和高性能的途径就是解阻塞太简单了!后面继续讲解read/write...并发服务serv=newTcpSocket();serv.listen();while(1){sock=serv.accept();newThread(){

while(1){//重复服务单用户

sock.read(buf);

sock.write(buf);

}sock.close()}}

一次服务

没有并发

短连接IO多路复用专业地解决一个问题select/poll/epoll/kqueue的API几乎一样,实现不同,性能不同IO多路复用接口的作用,就是测试accept/read/write等IO调用会不会阻塞IO多路复用示例serv=newTcpSocket();serv.listen();select.add(serv,READ);//READ表示只测试可读(读不阻塞)while(1){readable,writable=select.wait();foreach(readableassock){if(sock==serv){sock=serv.accept();select.add(sock,READ);}else{sock.read(buf);sock.write(buf);sock.close();}}//writable为空,因为我们不测试可写}还不完善write也可能阻塞,修改...sock.read(buf);sock.write(buf);sock.close();select.add(sock,WRITE);foreach(writableassock){sock.write(buf);sock.close();}报文设计最重要的TCP协议是流式协议,但几乎所有的应用协议都是基于报文的协议报文分隔用连接关闭来表示报文结束.如,HTTP/1.0的响应固定长度的报文.如,TFTP的数据报文.带自描述长度的固定长度首部的变长报文.如IP包,TCP分段.带结束符.如,行协议,HTTP协议.逐字节解析和数据转义的影响.高层文本,带结束符底层二进制,固定长度SSDB的报文格式Packet:=Block+'\n'Block:=SizeDataSize:=literal_integer'\n'Data:=size_bytes_of_data'\n'示例:3get3key<回车>优点简单带长度字段,支持二进制数据同时对人和对机器友好,报文数据文本化效果好.可以telnet到服务器进行交互解析器非常简单,

PHP代码不过几十行同时兼容LF和CRLF(惯例)带有报文解析的服务器serv=newTcpSocket();serv.listen();sock=serv.accept();client=newClient(sock);client.recv(packet);client.send(packet);client.close()packet一般是编程语言中的对象序列化和反序列化read收到的是字节数组,要进行反序列化转成编程语言的对象反序列化的过程就是报文解析解析报文bytes=[];while(1){bytes+=sock.read();if(try_parse(bytes,&len)==READY){//已经解析出了一个报文,报文的长度是len//从字节数组中清除掉已解析的bytes.remove(len);}}第三节–业务处理网络服务器=协议处理+网络IO+业务处理业务处理的位置serv=newTcpSocket();serv.listen();sock=serv.accept();client=newClient(sock);request=client.recv();resp