ocket编程

重新理解read/write/recv/send及tcp的全双工

Socket封装

我们程序员写的一个个解决我们实际问题满足我们日常需求的网络程序,

Socket编程所传的数据都是字符串类型的的数据但是如果我们想要传输结构化的数据呢什么是结构化的数据其实在我们第一次说计算机网络时就已经提到过结构化的数据就是协议其本质就是

比如我们如果要实现一个网络版的计算器我们需要客户把待计算的两个数发过去由服务器进行计算最后把结果返回给客户端。

如果我们依旧采用传统的Socket编程不论是Tcp还是Udp

Socket编程都无法保证所收到的数据是完整的比如客户端要发送

123

1作为客户端的请求进行处理如此以来就会导致客户端想得到的结果不匹配更有甚者剩下的23后一批发来会不会导致新的客户端数据出现问题呢

方案一

客户端发送一个形如11的字符串这个字符串中有两个操作数都是整形两个数字之间会有一个字符是运算符运算符只能是

方案二

定义结构体来表示我们需要交互的信息发送数据时将这个结构体按照一个规则转换成字符串,

接收到数据的时候再按照相同的规则把字符串转化回结构体。

这个过程我们叫做

序列化

首先先简单理解一下什么是序列化与反序列化我们可以通过下图简单了解

仅仅是上面一张图我认为理解还是不够的要更好的理解序列化和反序列化需要从下面入手

✈️重新理解read/write/recv/send及tcp的全双工

在重新理解这些接口之前我们先来回顾一下进程向发消息到磁盘的过程

首先用户需要发送消息那么OS就会从文件描述符表中把3号文件描述符通过进程pcb返回给用户用户此时通过write()接口对文件进行写数据字符串会从write接口通过文件描述符表找到struct

file对象从而找到内核缓冲区将字符串拷贝到缓冲区当中。

随后缓冲区就会定期的向磁盘文件中刷新数据。

这个我们在系统部分已经说过了但是为什么要说这个呢实际上如果今天我们把磁盘这个外设换为网络实际上就变成了网络通信我们之前说过传输层和网络层协议属于操作系统内核的一部分!

在传输层OS会维护两个缓冲区一个

在应用层我们以双方约定好的协议将数据进行序列化处理成一批字符串。

我们前面在使用Socket编程的时候直观上我们都认为是send/sendto直接将数据发送给了对端recv/recvfrom直接从对端接收数据。

实际上双方的IO系统调用并不会直接作用于网络。

如果是发送端则调用write/send/sendto

write/send

协议自主决定如何发送数据而Tcp通过网络向对端发送数据实际上就是

read/recv

接口本质也是拷贝函数最后将序列化的字符串交给上层上层再根据协议进行反序列化最终拿到相应的数据。

如果对端接收缓冲区内没有数据那么

本质上是因为调用read/recv接口的进程在等待数据的到来才会做下一步动作从而将进程状态从运行态转变为阻塞态当收到数据的时候再从阻塞态转为运行态。

同样如果主机A通过write/send

接口没有数据需要发送也会阻塞等待。

如果我们单单看发送方有人把数据往发送缓冲区内写OS把发送缓冲区的内容发送走这难道不就是一个简单的生产消费者模型吗生产者是用户消费者是OS交易场所是发送缓冲区。

同样对于接收端来说OS将数据通过网络拷贝到了接收缓冲区上层用户需要通过

read/recv

为什么会是同步因为通信双方需要等待数据的发送或者接收而他们接收的过程无非就是发送端将数据拷贝到发送缓冲区tcp再通过网络将将数据拷贝到对方的接收缓冲区中对端用户需要调用

read/recv

在通过发送缓冲区给主机B的接收缓冲区发消息的时候主机B不也可以通过自己的发送缓冲区给主机A的接收缓冲区发消息吗它们之间互不干扰所以这就是Tcp支持全双工的原因!

在Socket编程中我们说一个

也是支持全双工的也是因为sockfd既可以向发送缓冲区中发数据也可以从接收缓冲区中拷贝数据

✈️Socket封装

我们对Socket进行封装使其以后无论是tcp协议还是udp协议变得更加简洁更加有条理性这是因为创建一个套接字的方式方法是比较套路化的所以我们可以对其进行封装我们把创建套接字绑定ip和端口网络监听网络接收发起链接分别封装为五个

纯虚函数将来让子类进行强制重写:

socket通信我们只需要调用不同的虚函数即可当然也可以通过这些虚函数来组成udp

class

创建tcp套接字绑定并监听{CreateSocketOrDie();BindSocketOrDie(addr);ListenSocketOrDie();}bool

addr)//

创建客户端套接字{CreateSocketOrDie();return

Connector(addr);}

};那么我们如果想要建立Tcp连接我们就可以在TcpSocket类当中继承Socket类这样我们就可以对基类成员虚函数进行重写而重写的所有内容实际上就是我们之前写的TcpSocket的内容这里我就不再过多赘述:

const

1,BIND_ERROR,LISTEN_ERROR,USAGE_ERROR,

};class

error);exit(SOCKET_ERROR);}LOG(DEBUG,

socket

sizeof(local));local.sin_family

htons(addr.Port());local.sin_addr.s_addr

inet_addr(addr.IP().c_str());int

::bind(_sockfd,

error);exit(BIND_ERROR);}LOG(DEBUG,

bind

error);exit(LISTEN_ERROR);}LOG(DEBUG,

listen

返回一个智能指针以便于将来可以通过智能指针对基类成员方法进行调用{struct

sockaddr_in

std::make_sharedTcpSocket(sockfd);return

sock;}bool

sizeof(server));server.sin_family

htons(addr.Port());server.sin_addr.s_addr

inet_addr(addr.IP().c_str());int

connect(_sockfd,

};这样写的好处是main函数和客户端的工作量就降低了很多我们可以通过多态式的调用来完成Socket通信

多态式调用

listensock-BuildListenSocket();//

clientsock

clientsock-BuildClientSocket();//

客户端Socket套接字建立这样listensock或者clientsock虽然表面调用的是Socket基类但是由于基类内的纯虚函数都在子类实现所以会间接调用子类对父类纯虚函数的重写这就是多态式调用。

而以上对于Socket的封装内置抽象函数(纯虚函数)需要子类强制重新实现的这种方式是一种设计模式称为

✈️服务器端改写

除此之外我们把Socket进行了封装那么TcpServer也就不需要像Tcp

Socket编程那样进行写了为了松耦合我们把TcpServer类冗余部分全部删除TcpServer帮我们的目的是创建套接字获取客户端链接再去处理请求

三个部分至于如何处理请求就不该是TcpServer类所关心的了。

首先我们不再需要原本的初始化部分因为我们对Socket进行了封装我们只需要在TcpServer构造函数中进行调用即可

TcpServer(int

_listensock(std::make_uniqueTcpSocket())//

_isrunning(false)

{_listensock-BuildListenSocket(_localaddr);//

多态式调用,

_localaddr;std::unique_ptrSocket

_listensock;bool

_isrunning;一个Socket的智能指针就可以实现多态式调用进行初始化Tcp套接字部分对于具体的任务是如何处理的虽然TcpServer不该关心但是如何分配任务以及分配任务的方式是我们需要操心的在上一篇文章中我们有四种分配方式后面三种选择任何一种都可在这里我选择多线程的方式分配任务。

不需要知道具体的任务细节只需要TcpServer其提供一个可调用的任务接口即可我们使用function将Service接口封装为一个新的类型

io_service_t类型在初始化部分与线程回调函数部分我们都可以对其进行调用

using

s):sockfd(fd),clientaddr(addr),self(s){}

public:socket_sptr

TcpServer的目的是为了创建套接字获取链接再去处理具体如何处理就不需要TcpServer关心了

class

_listensock(std::make_uniqueTcpSocket()),

_service(service),

_isrunning(false){_listensock-BuildListenSocket(_localaddr);}//

线程回调函数static

args){pthread_detach(pthread_self());ThreadData*

static_castThreadData*(args);td-self-_service(td-sockfd,

td;return

不能直接收数据必须先获取连链接while(_isrunning){InetAddr

peeraddr;socket_sptr

_listensock-Accepter(peeraddr);//

using

std::shared_ptrSocket;if(normalsock

nullptr)

};在Loop函数中由于在TcpServer中我们重写了Accept()方法所以我们不需要在Loop中写裸的accept()原生接口了我们直接使用_listensock进行调用Accept()方法会返回一个TcpSocket的对象对象中本就存在sockfd。

这样我们就可以成功获取连接了再将其交给线程去处理即可。