当前位置: 首页 > news >正文

海阳市建设局网站如何引流与推广

海阳市建设局网站,如何引流与推广,wordpress 函数 应用,在线制作网站源码TCP网络模型的封装 最近学习了TCP网络模型的封装,其中运用的封装技术个人感觉有点绕 在反复读代码、做思维导图下初步理解了这套封装模型,不禁感叹原来代码还能这样写?神奇! 为此将源码分享出来并将流程图画出,方便…

TCP网络模型的封装

最近学习了TCP网络模型的封装,其中运用的封装技术个人感觉有点绕

在反复读代码、做思维导图下初步理解了这套封装模型,不禁感叹原来代码还能这样写?神奇!

为此将源码分享出来并将流程图画出,方便理解和复习

PS:下列思维导图仅代表个人理解,如有误恳请指出纠正

模型继承关系图

要理解该模型,我认为首先要画图理解类的继承关系,下面是我画的一个简单关系图
在这里插入图片描述

模型流程图

下面是我画的该模型的大致流程图,仅供参考,有误恳请指出
在这里插入图片描述

具体代码实现

EventLoop.hpp

#ifndef _EVENTLOOP_H_
#define _EVENTLOOP_H_#include <list>
#include <WinSock2.h>enum class E_Event_Type
{Recv,Send,
};class IEventCallback
{
public:virtual void OnNetEvent(E_Event_Type e) = 0;virtual void OnClose() = 0;
};struct sSelectEvent
{SOCKET sock;IEventCallback* event;
};class EventLoop
{
private:std::list<sSelectEvent*> _events;std::list<sSelectEvent*> _delEventCaches;public:void LoopOnce();void AddEvent(sSelectEvent* e){_events.push_back(e);}void DelEvent(sSelectEvent* e);
};
#endif

EventLoop.cpp

#include "EventLoop.hpp"void EventLoop::LoopOnce()
{fd_set reads;FD_ZERO(&reads);do{auto begin = _events.begin();auto end = _events.end();for (; begin != end; ++begin)FD_SET((*begin)->sock, &reads);//(*begin)->event->NeedWrite()} while (false);int nSeclect = select(0, &reads, nullptr, nullptr, nullptr);if (0 == nSeclect)return;if (nSeclect < 0)return;do{auto begin = _events.begin();auto end = _events.end();for (; begin != end; ++begin){if (FD_ISSET((*begin)->sock, &reads)){(*begin)->event->OnNetEvent(E_Event_Type::Recv);}}} while (false);do{auto begin = _delEventCaches.begin();auto end = _delEventCaches.end();for (; begin != end; ++begin){sSelectEvent* p = *begin;_events.remove_if([p](sSelectEvent* a){return a == p;});p->event->OnClose();}_delEventCaches.clear();} while (false);}void EventLoop::DelEvent(sSelectEvent* e)
{_delEventCaches.push_back(e);
}

TcpListen.hpp

#ifndef _TCPLISTEN_H_
#define _TCPLISTEN_H_
#define _WINSOCK_DEPRECATED_NO_WARNINGS #include "EventLoop.hpp"
#include <WinSock2.h>
#include <iostream>
#include <functional>
class TcpSocket;
class TcpListen :public IEventCallback
{
protected:SOCKET _sock;sSelectEvent _event;EventLoop* _loop;std::function<TcpSocket* ()> _sockCB;
public:TcpListen();void Init(EventLoop* loop, std::function<TcpSocket* ()> sockCB){_loop = loop; _sockCB = sockCB;}bool Listen(unsigned short port, const char* const ip = "0.0.0.0");// 通过 IEventCallback 继承virtual void OnNetEvent(E_Event_Type e) override;virtual void OnClose() override;
public:virtual void OnAccpet(TcpSocket* sock) = 0;};
#endif

TcpListen.cpp

#include "TcpListen.h"
#include "TcpSocket.h"
TcpListen::TcpListen()
{_event.event = this;_sock = _event.sock = INVALID_SOCKET;_loop = nullptr;
}bool TcpListen::Listen(unsigned short port, const char* const ip)
{_sock = socket(AF_INET, SOCK_STREAM, 0);if (INVALID_SOCKET == _sock){std::cout << "create SOCKET fail!\n" << std::endl;return false;}std::cout << "1.create SOCKET OK!\n" << std::endl;// 2.绑定IP和端口
//  bind(SOCKET,绑定的IP端口结构体,结构体大小)SOCKADDR_IN serverAddr;serverAddr.sin_family = AF_INET;//SOCKADDR_IN6*serverAddr.sin_port = htons(port);// 127.0.0.1 本机回环地址// 0.0.0.0  绑定所有IPserverAddr.sin_addr.s_addr = inet_addr(ip);//SOCKADDR_IN6 serverAddr6;if (SOCKET_ERROR== bind(_sock, (SOCKADDR*)&serverAddr, sizeof(serverAddr))){std::cout << "bind SOCKET fail!\n" << std::endl;return false;}std::cout << "2.bind SOCKET OK!\n" << std::endl;listen(_sock, 5);std::cout << "3.listen SOCKET OK!\n" << std::endl;_event.sock = _sock;_loop->AddEvent(&_event);return true;
}void TcpListen::OnNetEvent(E_Event_Type e)
{SOCKADDR_IN clientAddr;int addrlen = sizeof(SOCKADDR_IN);SOCKET clientSock = accept(_sock, (SOCKADDR*)&clientAddr, &addrlen);if (INVALID_SOCKET == clientSock){std::cout << "4.ACCEPT ERROR!!\n" << std::endl;return;}std::cout << "4.ACCEPT ip:" << inet_ntoa(clientAddr.sin_addr)<< "  Port:" << ntohs(clientAddr.sin_port) << "   " << clientSock<< std::endl;TcpSocket* sock = _sockCB();sock->OnAccept(clientSock, &clientAddr);OnAccpet(sock);}void TcpListen::OnClose()
{
}

TcpSocket.hpp

#ifndef _TCPSOCKET_H_
#define _TCPSOCKET_H_
#define _WINSOCK_DEPRECATED_NO_WARNINGS #include "EventLoop.hpp"const unsigned int RECV_MAX_BUF = 4096 * 2;class TcpSocket :public IEventCallback
{
private:SOCKET _sock;SOCKADDR_IN _addr;sSelectEvent _event;EventLoop* _loop;char _recvBuff[RECV_MAX_BUF];int _recvLen;bool _bClose;
public:TcpSocket();virtual ~TcpSocket();void Init(EventLoop* loop);void OnAccept(SOCKET sock, SOCKADDR_IN* addr);void Close();public:// 通过 IEventCallback 继承virtual void OnNetEvent(E_Event_Type e) override;virtual void OnClose() override;public:virtual int OnNetMsg(const char* const msg, int msgLen) = 0;void Send(const char* msg, int msgLen);};#endif

TcpSocket.cpp

#include "TcpSocket.h"TcpSocket::TcpSocket()
{_sock = _event.sock = INVALID_SOCKET;_event.event = this;_recvLen = 0;_bClose = false;
}TcpSocket::~TcpSocket()
{
}void TcpSocket::Init(EventLoop* loop)
{_loop = loop;_loop->AddEvent(&_event);
}void TcpSocket::OnAccept(SOCKET sock, SOCKADDR_IN* addr)
{_sock = sock;_event.sock = sock;memcpy(&_addr, addr, sizeof(addr));
}void TcpSocket::Close()
{if (_bClose) return;_bClose = true;_loop->DelEvent(&_event);
}void TcpSocket::OnNetEvent(E_Event_Type e)
{if (E_Event_Type::Recv == e){int nRecv = recv(_sock, _recvBuff + _recvLen, RECV_MAX_BUF - _recvLen, 0);if (nRecv <= 0){Close();return;}_recvLen += nRecv;while (_recvLen != 0){int nRet = OnNetMsg(_recvBuff, _recvLen);if (nRet <= 0)break;_recvLen -= nRet;for (int i = 0; i < _recvLen; ++i){_recvBuff[i] = _recvBuff[i + nRet];}}if (_recvLen == RECV_MAX_BUF) Close();}
}void TcpSocket::OnClose()
{closesocket(_sock);delete this;
}void TcpSocket::Send(const char* msg, int msgLen)
{send(_sock, msg, msgLen, 0);
}

EasyTcpServer.cpp

#define  _WINSOCK_DEPRECATED_NO_WARNINGS
#include <iostream>#include <WinSock2.h>
#pragma comment(lib,"ws2_32")
#include <vector>#include "TcpListen.h"
#include "TcpSocket.h"class EasyTcpClient :public TcpSocket
{
public:// 通过 TcpSocket 继承virtual int OnNetMsg(const char* const msg, int msgLen) override{std::cout << msgLen << "接受客户端数据:" << msg << std::endl;return msgLen;}
};class EasyTcpServer :public TcpListen
{
public:void OnAccpet(TcpSocket* sock) override{//sock->Init(_loop)sock->Init(_loop);std::cout << "客户端连接" << std::endl;}};int main()
{// 加载网络环境WSADATA wsaData;WSAStartup(MAKEWORD(2, 2), &wsaData);EventLoop loop;EasyTcpServer listen;listen.Init(&loop, []()->TcpSocket*{return new EasyTcpClient;});listen.Listen(7890);while (true){loop.LoopOnce();}return 0;
}

最后

void OnAccpet(TcpSocket* sock) override
{//sock->Init(_loop)sock->Init(_loop);std::cout << "客户端连接" << std::endl;
}

};

int main()
{
// 加载网络环境
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);

EventLoop loop;EasyTcpServer listen;listen.Init(&loop, []()->TcpSocket*{return new EasyTcpClient;});listen.Listen(7890);while (true)
{loop.LoopOnce();
}return 0;

}

# 最后代码经供参考,如有疑问或者代码有问题欢迎提出
http://www.yayakq.cn/news/381222/

相关文章:

  • 网站建设进展情况汇报厦门同安区建设局网站
  • 免费网站注册 建站查建筑公司网站
  • 肯德基网站建设的目标厦门网站设计推广公司
  • asp资源下载网站wordpress hyper
  • 北京网站建设公司飞沐微信运营公司
  • 内存数据库 网站开发typecho 抄wordpress
  • 便捷网站建设哪家好工程建设分为哪几个阶段
  • 建设企业网站的意义郑大二附院网站建设招标
  • 网站内容建设庆阳市建设局网站
  • 做app还是网站网站建设与管理作业
  • 淮南装饰公司网站建设wordpress首页显示摘要的插件
  • jpress wordpress对比江苏网站关键词优化优化
  • 石碣镇做网站天津做网站企业
  • 在哪里找给公司做网站优化的人黄冈公司网站推广软件首选
  • 小型网站开发开题报告范文广州网站推广哪家强
  • 提高网站排名软件丽水市住房和城乡建设局网站
  • 口碑好的专业网站建设企业官网建设
  • 句容网站制作哪家好博客wordpress模版8.0
  • 网站建设销售话术文本格式photoshop安卓版下载
  • 郑州有哪些搞网站开发的公司网站建设基本知识代码
  • 本地网站建设DW文创产品设计创意
  • 什么是网站镜像如何评价企业网站推广效果?
  • 做网站在哪里买空间域名将公司网站建设成
  • 临西企业做网站网站建设企炬
  • 移动ui设计 网站网站建设博客作业
  • 建设隔热网站鑫牛元网站建设
  • 做蛋糕的企业网站企业网站建设设置那些栏目
  • 品牌形象网站有哪些郑州做公司网站的公司
  • 企业网站建设组织人员可行性分析衡水企业做网站多少钱
  • 网站空间域名费seo如何优化网站步骤