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

高性能并发网络服务器设计与实现网络服务器开发协议设计(网络协议和应用协议)语法(报文格式)语义(指令的处理,交互时序等)只要涉及到交互(即使不是网络交互),就需要协议网络实现(IO)网络开发的基础是socket任何对网络的封装,在三度关系之内必然是socket(最多三层封装)第一节–网络IOTalkischeap,showmethecodeserv=newTcpSocket();serv.listen();sock=serv.accept();sock.read(buf);sock.write(buf);sock.close()一次服务没有并发短连接有没有协议?最简单的TCP服务器重复服务serv=newTcpSocket();serv.listen();while(1){sock=serv.accept();while(1){//重复服务单用户sock.read(buf);sock.write(buf);}sock.close()}一次服务没有并发短连接socketIOread/write是可阻塞的阻塞是并发和高性能的死敌实现并发和高性能的途径就是解阻塞太简单了!后面继续讲解read/write...并发服务serv=newTcpSocket();serv.listen();while(1){sock=serv.accept();newThread(){while(1){//重复服务单用户sock.read(buf);sock.write(buf);}sock.close()}}一次服务没有并发短连接优缺点优点:简单易用,一般工作得很好多线程,可以利用CPU多核缺点:启动线程也有成本,很可能占大头线程的数量不受控制,危险!问题在于IO...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(惯例)socketio2read/write读取/发送的是字节数组.C语言的char[],PHP的stringread返回时读取的准确字节数无法预计导致粘包,断包write返回时不表示数据已到达对方机器所以,即便基于可靠传输的TCP协议,也需要应用层协议进行确认来保证真正意义上的可靠带有报文解析的服务器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和报文解析将上例中的read和try_parse分离作业...第三节–业务处理网络服务器=协议处理+网络IO+业务处理业务处理的位置serv=newTcpSocket();serv.listen();sock=serv.accept();client=newClient(sock);request=client.recv();response=process(request);client.send(response);client.close()对于SSDB,LevelDB相关的操作封装在process中.剩下的...就是看代码写代码...FINThanksSSDB: