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

贵阳网站app制作找哪个公司做网站推广最好

贵阳网站app制作,找哪个公司做网站推广最好,wordpress登录后转到wp首页,硅谷网站开发薪酬前言 本篇博客旨在使用Linux系统接口进行网络通信, 帮助我们更好的熟悉使用socket套接字网络通信, 学会了socket网络通信, 就能发现所谓网络, 不过都是套路而已, 话不多说, 让我们直接进入代码编写部分. 1. 事先准备 今天我们先来模拟实现一个echo demo, 也就是客户端向服务…

前言

本篇博客旨在使用Linux系统接口进行网络通信, 帮助我们更好的熟悉使用socket套接字网络通信, 学会了socket网络通信, 就能发现所谓网络, 不过都是套路而已, 话不多说, 让我们直接进入代码编写部分.

1. 事先准备

今天我们先来模拟实现一个echo demo, 也就是客户端向服务器发送信息, 服务器能接收信息, 并且进行回显, 为了代码的可读性和可调试性, 我们在其中使用日志信息, 接下来我会带领大家手撕一个日志代码, 之后运用到我们的echo demo中, 在日志中, 如果想访问临界资源, 我们需要进行加锁和解锁, 这里我也会带领大家, 基于linux系统调用进行锁的封装, 使得我们的锁使用起来更加方便.

1.1 Mutex.hpp

想要进行锁的封装, 那我们首先需要了解一下锁, 这里就不过多赘述锁的定义, 简单来说锁是原子性的, 当操作系统在时间片的作用下进行进程间轮转调度时, 会发生进程间切换,多线程同步访问共享资源时, 可能导致我们的数据不安全, 为了保护临界资源所采取的一种措施就是锁.

锁的定义的方式有两种, 一种是全局使用宏进行初始化, 不需要手动释放, 由操作系统进行释放, 一种是局部定义使用init进行初始化,我们这里使用init初始化, 第一个参数是锁, 第二个参数为锁的属性, 默认为nullptr就行了, 然后销毁就是用destory系统调用, 我们对这些进行封装, 下面创建了一个LockGuard类, 我们利用对象的特性, 出了局部作用域会自动释放的特点, 进一步简化了锁的使用.

#pragma once
#include <iostream>
#include <pthread.h>namespace LockMoudle
{class Mutex{public:Mutex(const Mutex&) = delete;const Mutex& operator=(const Mutex&) = delete;Mutex(){int n = ::pthread_mutex_init(&_lock, nullptr);(void)n;}~Mutex(){int n = ::pthread_mutex_destroy(&_lock);(void)n;}void Lock(){//加锁int n = pthread_mutex_lock(&_lock);(void)n;}//获取锁pthread_mutex_t *LockPtr(){return &_lock;}//解锁void Unlock(){int n = ::pthread_mutex_unlock(&_lock);(void)n;}private:pthread_mutex_t _lock;};class LockGuard{public:LockGuard(Mutex &mtx):_mtx(mtx){_mtx.Lock();}~LockGuard(){_mtx.Unlock();}private:Mutex &_mtx;};
}

1.2 Log.hpp

在日志类里, 如果使用文件策略, 为了防止多线程并发访问, 创建多个文件, 我们可以进行加锁, 一次只能有一个线程进行访问

首先明确日志策略, 刷新到文件缓冲区, 还是命令行缓冲区, 定义基类, 使用子类继承基类的虚方法, 实现多态, 使用内部类进行日志消息的创建, 并且调用外部类的策略方法进行打印.

在这里插入图片描述
在这里插入图片描述

#pragma once#include <iostream>
#include <cstdio>
#include <string>
#include <fstream>
#include <sstream>
#include <memory>
#include <filesystem> //C++17
#include <unistd.h>
#include <time.h>
#include "Mutex.hpp"namespace LogModule
{using namespace LockMoudle;//获取当前系统时间std::string CurrentTime(){time_t time_stamp = ::time(nullptr);struct tm curr;localtime_r(&time_stamp, &curr); //时间戳, 获取可读性较强的时间信息char buffer[1024];snprintf(buffer, sizeof(buffer), "%4d-%02d-%02d %02d:%02d:%02d",curr.tm_year + 1900,curr.tm_mon + 1,curr.tm_mday,curr.tm_hour,curr.tm_min,curr.tm_sec);return buffer;}//构成: 1. 构建日志字符串 2.刷新落盘//落盘策略(screen, file)//1.日志文件的默认路径和文件名const std::string defaultlogpath = "./log/";const std::string defaultlogname = "log.txt";//2.日志等级enum class LogLevel{DEBUG = 1,INFO,WARNING,ERROR,FATAL};//枚举类型转字符串std::string Level2String(LogLevel level){switch (level){case LogLevel::DEBUG:return "DEBUG";case LogLevel::INFO:return "INFO";case LogLevel::WARNING:return "WARNING";case LogLevel::ERROR:return "ERROR";case LogLevel::FATAL:return "FATAL";default:return "None";}}//3.刷新策略class LogStrategy{public:virtual ~LogStrategy() = default; //虚析构函数,多态,能够正确调用对象进行析构, 编译器自动生成virtual void SyncLog(const std::string &message) = 0;//纯虚函数,子类必须手动实现};//3.1控制台策略class ConsoleLogStrategy : public LogStrategy{public:ConsoleLogStrategy(){}~ConsoleLogStrategy(){}//向控制台打印日志信息messagevoid SyncLog(const std::string &message){LockGuard lockguard(_lock);std::cout << message << std::endl;}private:Mutex _lock;};//文件级策略class FileLogStrategy : public LogStrategy{public:FileLogStrategy(const std::string &logpath = defaultlogpath, const std::string &logname = defaultlogname): _logpath(logpath),_logname(logname){//确定_logpath是否存在LockGuard lockguard(_lock);if(std::filesystem::exists(_logpath)){return ;}try{//不存在进行创建std::filesystem::create_directories(_logpath);}catch(std::filesystem::filesystem_error &e){std::cerr << e.what() << "\n";}}~FileLogStrategy(){}//重写基类虚方法void SyncLog(const std::string &message){LockGuard lockguard(_lock);std::string log = _logpath + _logname;std::ofstream out(log, std::ios::app);if(!out.is_open()) {return;}out << message << "\n";out.close(); }private:std::string _logpath;std::string _logname;Mutex _lock;};//日志类: 构建日志字符串, 根据策略, 进行写入class Logger{public:Logger(){//默认采用控制台策略_strategy = std::make_shared<ConsoleLogStrategy>();}void EnableConsolelog(){_strategy = std::make_shared<ConsoleLogStrategy>();}void EnableFileLog(){_strategy = std::make_shared<FileLogStrategy>();}~Logger(){}//一条完整的信息[2024-08-04 12:27:03] [DEBUG] [202938] [main.cc] [16] + 日志的可变部分(<< "hello world" << 3.14 << a << b;)//外部类实现策略, 内部类实现信息class LogMessage{public:LogMessage(LogLevel level, const std::string &filename, int line, Logger &logger): _currtime(CurrentTime()),_level(level),_pid(::getpid()),_filename(filename),_line(line),_logger(logger){std::stringstream ssbuffer;ssbuffer << "[" << _currtime << "] "<< "[" << Level2String(_level) << "] "<< "[" << _pid << "] "<< "[" << _filename << "] "<< "[" << _line << "] - ";_loginfo = ssbuffer.str();}template <typename T>LogMessage &operator<<(const T &info){std::stringstream ss;ss << info;_loginfo += ss.str();return *this;}~LogMessage(){if (_logger._strategy){_logger._strategy->SyncLog(_loginfo);}}private:std::string _currtime; //当前日志的时间LogLevel _level; //日志等级pid_t _pid; //进程pidstd::string _filename; //源文件int _line; //行号Logger &_logger; //策略std::string _loginfo; //日志信息};  //重载operator(), 故意的拷贝LogMessage operator()(LogLevel level, const std::string &filename, int line){return LogMessage(level, filename, line, *this);}private:std::shared_ptr<LogStrategy> _strategy;};Logger logger;#define LOG(Level) logger(Level, __FILE__, __LINE__)#define ENABLE_CONSOLE_LOG() logger.EnableConsolelog()#define ENABLE_FILE_LOG() logger.EnableFileLog()
}

2. 编写Echo demo代码

2.1 UdpServer.hpp 和 UdpServer.cc

这里使用套接字进行通信, 套接字可以简单理解为一个文件流, 创建套接字之后填写网络信息, 进行和内核的绑定, 这里我使用的是云服务器, 默认不需要绑定ip, 所以这里我只需绑定端口号, 从命令行获取.

#include "UdpServer.hpp"int main(int argc, char *argv[])
{if(argc != 2){std::cerr << "Usage: " << argv[0] << "localport" << std::endl;Die(USAGE_ERR);}uint16_t port = std::stoi(argv[1]);ENABLE_CONSOLE_LOG();std::unique_ptr<UdpServer> svr_uptr = std::make_unique<UdpServer>(port);svr_uptr->InitServer();svr_uptr->Start();return 0;
}
#pragma once#include <iostream>
#include <string>
#include <memory>
#include <cstring>
#include <cerrno>#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>#include "IntAddr.hpp"
#include "Log.hpp"
#include "Common.hpp"using namespace LogModule;const static int gsockfd = -1;
//const static std::string gdefaultip = "127.0.0.1" //表示本地主机
const static uint16_t gdefaultport = 8080;class UdpServer
{
public://命令行输入ip + 端口号进行绑定, 虚拟机无需绑定ip, 只需指定端口号进行绑定即可UdpServer(uint16_t port = gdefaultport): _sockfd(gsockfd), _addr(port), _isrunning(false){}//都是套路void InitServer(){//1.创建套接字_sockfd = ::socket(AF_INET, SOCK_DGRAM, 0); //指定网络通信模式. 面向数据包, 标记为设置为0if(_sockfd < 0){LOG(LogLevel::FATAL) << "socket: " << strerror(errno);Die(SOCKET_ERR);}LOG(LogLevel::INFO) << "socket success, sockfd is" << _sockfd;//2.1填充网络信息并绑定, 网络信息都在sockaddr_in里面, 这里我们封装一下//2.2bindint n = ::bind(_sockfd, _addr.Netaddr(), _addr.NetAddrlen());if(n < 0){LOG(LogLevel::FATAL) << "bind" << strerror(errno);Die(BIND_ERR);}LOG(LogLevel::INFO) << "bind success";}//启动, cs模式,进行接受消息, 并且回显回去void Start(){_isrunning = true;while(true){char inbuffer[1024];struct sockaddr_in peer; //客户端信息, 输出型参数socklen_t len = sizeof(peer);ssize_t n = ::recvfrom(_sockfd, inbuffer, sizeof(inbuffer) - 1, 0, CONV(&peer), &len);if(n > 0){InetAddr cli(peer);inbuffer[n] = 0;std::string clientinfo = cli.Ip() + ":" + std::to_string(cli.Port()) + '#' + inbuffer;LOG(LogLevel::DEBUG) << clientinfo;std::string echo_string = "echo#";echo_string += inbuffer;::sendto(_sockfd, echo_string.c_str(), echo_string.size(), 0, CONV(&peer), sizeof(peer));}}_isrunning = false;} ~UdpServer(){if(_sockfd > gsockfd)::close(_sockfd);}
private:int _sockfd;InetAddr _addr;bool _isrunning;
};

2.2 IntAddr.hpp 和 Commm.hpp

这里对IntAddr进行了封装, IntAddr这里包含了网络信息, 网络通信IntAddr_in, 我们需要对他进行强转, C语言版多态

#pragma once#include <iostream>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "Common.hpp"class InetAddr
{
private:void PortNet2Host(){_port = ::ntohs(_net_addr.sin_port);}void IpNet2Host(){char ipbuffer[64];const char *ip = ::inet_ntop(AF_INET,&_net_addr.sin_addr,ipbuffer, sizeof(ipbuffer));(void)ip;}
public:InetAddr(){}//如果传进来的是一个sockaddr_in, 网络转主机InetAddr(const struct sockaddr_in &addr) : _net_addr(addr){PortNet2Host();IpNet2Host();}//如果传进来的是端口号, 就转化为网络, 服务器不需要自己绑定ipInetAddr(uint16_t port) : _port(port), _ip(""){_net_addr.sin_family = AF_INET;_net_addr.sin_port = htons(_port);_net_addr.sin_addr.s_addr = INADDR_ANY;}struct sockaddr* Netaddr() {return CONV(&_net_addr); }socklen_t NetAddrlen() {return sizeof(_net_addr); }std::string Ip() {return _ip; }uint16_t Port() {return _port; }~InetAddr(){}
private:struct sockaddr_in _net_addr;std::string _ip;uint16_t _port;
};

Comman.hpp

#pragma once#include<iostream>#define Die(code) do {exit(code); } while(0)
#define CONV(v) (struct sockaddr *)(v)enum
{USAGE_ERR = 1,SOCKET_ERR,BIND_ERR
};

2.3 Client.cc

客户端进行标准输入获取信息, 并且发送到服务器, 然后接受服务器回显的内容, 并且打印

#include "UdpClient.hpp"
#include "Common.hpp"
#include <iostream>
#include <cstring>
#include <string>
#include <cstdlib>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>//csint main(int argc, char *argv[])
{if(argc != 3){std::cerr << "Usage: " << argv[0] << "serverip serverport" << std::endl;Die(USAGE_ERR);}std::string serverip = argv[1];uint16_t serverport = std::stoi(argv[2]);//1.创建socketint sockfd = ::socket(AF_INET, SOCK_DGRAM, 0);if(sockfd < 0){std::cerr << "socket error" << std::endl;Die(SOCKET_ERR);}//1.1填充网络信息struct sockaddr_in server;memset(&server, 0, sizeof(server));server.sin_family = AF_INET;server.sin_port = ::htons(serverport);server.sin_addr.s_addr = ::inet_addr(serverip.c_str());//客户端不需要进行绑定, 端口号由系统进行分配while(true){std::cout << "Place Enter# ";std::string message;std::getline(std::cin, message);int n = ::sendto(sockfd, message.c_str(), message.size(), 0, CONV(&server), sizeof(server));(void)n;struct sockaddr_in temp;socklen_t len = sizeof(temp);char buffer[1024];n = ::recvfrom(sockfd, buffer, sizeof(buffer) - 1, 0, CONV(&temp), &len);if(n > 0){buffer[n] = 0;std::cout << buffer << std::endl;}}return 0;
}

3. 运行结果

在这里插入图片描述



文章转载自:

http://OKo3BOrx.gpwmj.cn
http://2yW9wKSO.gpwmj.cn
http://xiseQovI.gpwmj.cn
http://LJa88syD.gpwmj.cn
http://FD7AiPTO.gpwmj.cn
http://4MJlqv6F.gpwmj.cn
http://wRiCtwJ6.gpwmj.cn
http://SBZHLbuT.gpwmj.cn
http://YKKLFF0H.gpwmj.cn
http://EaiBCqCV.gpwmj.cn
http://8VXHraHM.gpwmj.cn
http://FZyM5Lhr.gpwmj.cn
http://4ZgexoKo.gpwmj.cn
http://w9wGbHax.gpwmj.cn
http://pRDQs8Ha.gpwmj.cn
http://JXEKMfVx.gpwmj.cn
http://UoGTAYix.gpwmj.cn
http://j5tYN09J.gpwmj.cn
http://R2PppvDu.gpwmj.cn
http://Ppiujeyd.gpwmj.cn
http://k5AVlyWx.gpwmj.cn
http://rKtmbAXw.gpwmj.cn
http://ubPrDOgb.gpwmj.cn
http://beC5z3aj.gpwmj.cn
http://VUMG3xzd.gpwmj.cn
http://0dR4RsZ0.gpwmj.cn
http://VVOkpznn.gpwmj.cn
http://WE8VVfPn.gpwmj.cn
http://pmVwiQhA.gpwmj.cn
http://OXd1tRU0.gpwmj.cn
http://www.dtcms.com/wzjs/774625.html

相关文章:

  • 台北网站建设从零开始学习网络营销
  • 网站培训班做网站方面
  • 南宁比优建站抖音开放平台注册
  • namecheap建站wordpress创建网站的网站
  • 重庆网领网站建设公司门户网站制作服务
  • asp.net 网站开发 教程完整网站源码下载
  • 建设门户网站 业务模板商城网站建设实例需求
  • 江阴网站建设微信公众号微网站开发
  • 织梦网站怎么建设想学网页设计报考什么专业
  • 做婚恋网站多少钱网页开发软件哪个好用
  • 网站设计作业平台旅游网站开发方案百度文库
  • 电子商务网站环境建设wordpress自动回复
  • 成都网站建设六六重庆平台网站建设工作
  • 遵义网站建设公司成都seo服务
  • 手机网站开发与pc网站开发的不同品牌seo培训
  • 网站建站六个目标烟台网页公司联系方式
  • 企业网站无锡工业设计完整作品集
  • flash建网站教程俄语学习网站
  • 专业网站定制公司企业查询信息平台官网
  • 建设银行 u盾不弹出网站北京 网站建设 知乎
  • 工程管理毕业设计代做网站网站开发项目计划书ppt
  • 做视频网站盈利多少wordpress还原安装
  • 房山建站公司门户网站开发技术
  • 百度网站主要提供的服务源码商城网站源码
  • php网站实例教程百度手机seo
  • 网站推广策略怎么写电商在线官方
  • 钢管网站模板国际服务器
  • 一个域名可以做几个网站吗论坛网站如何建设
  • 合肥响应式网站建设方案软件定制为什么不给源码
  • 哪些网站是.net开发的电子商务网站开发的流程图