简单的TcpServer(英译中)

目录

  • 一、TCP socket API 详解
    • 1.1 socket()
    • 1.2 bind()
    • 1.3 listen()
    • 1.4 accept()
    • 1.5 connect
  • 二、TcpServer(英译中)
    • 2.1 TcpServer.hpp
    • 2.2 TcpClient.cc
    • 2.3 Task.hpp
    • 2.4 Thread.hpp
    • 2.5 ThreadPool.hpp
    • 2.6 makefile
    • 2.7 Main.cc
    • 2.8 log.hpp
    • 2.9 Init.hpp
    • 2.10 dict.txt
    • 2.11 Daemon.hpp

一、TCP socket API 详解

实现一个简单的英译汉的功能。
下面介绍程序中用到的socket API,这些函数都在sys/socket.h中。

1.1 socket()

在这里插入图片描述

socket()打开一个网络通讯端口,如果成功的话,就像open()一样返回一个文件描述符;
应用程序可以像读写文件一样用read/write在网络上收发数据;
如果socket()调用出错则返回-1;
对于IPv4, family参数指定为AF_INET;
对于TCP协议,type参数指定为SOCK_STREAM, 表示面向流的传输协议;
protocol参数的就不做介绍了,指定为0即可。

1.2 bind()

在这里插入图片描述
服务器程序所监听的网络地址和端口号通常是固定不变的,客户端程序得知服务器程序的地址和端口号后就可以向服务器发起连接; 服务器需要调用bind绑定一个固定的网络地址和端口号;

bind()成功返回0,失败返回-1。

bind()的作用是将参数sockfd和myaddr绑定在一起, 使sockfd这个用于网络通讯的文件描述符监听myaddr所描述的地址和端口号;

前面讲过,struct sockaddr *是一个通用指针类型,myaddr参数实际上可以接受多种协议的sockaddr结构体,而它们的长度各不相同,所以需要第三个参数addrlen指定结构体的长度;

我们的程序中对myaddr参数是这样初始化的:
在这里插入图片描述

  1. 将整个结构体清零;
  2. 设置地址类型为AF_INET;
  3. 网络地址为INADDR_ANY, 这个宏表示本地的任意IP地址,因为服务器可能有多个网卡,每个网卡也可能绑定多个IP 地址, 这样设置可以在所有的IP地址上监听,直到与某个客户端建立了连接时才确定下来到底用哪个IP 地址;
  4. 端口号为SERV_PORT, 我们定义为8080;

1.3 listen()

在这里插入图片描述
listen()声明sockfd处于监听状态, 并且最多允许有backlog个客户端处于连接等待状态, 如果接收到更多的连接请求就忽略, 这里设置不会太大(一般是5),listen()成功返回0,失败返回-1;

1.4 accept()

在这里插入图片描述
1、三次握手完成后, 服务器调用accept()接受连接;
2、如果服务器调用accept()时还没有客户端的连接请求,就阻塞等待直到有客户端连接上来;addr是一个传出参数,
accept()返回时传出客户端的地址和端口号;
3、如果给addr 参数传NULL,表示不关心客户端的地址;
4、addrlen参数是一个传入传出参数(value-result argument), 传入的是调用者提供的, 缓冲区addr的长度以避免缓冲区溢出问题, 传出的是客户端地址结构体的实际长度(有可能没有占满调用者提供的缓冲区);

1.5 connect

在这里插入图片描述
1、客户端需要调用connect()连接服务器;
2、connect和bind的参数形式一致, 区别在于bind的参数是自己的地址, 而connect的参数是对方的地址;
3、connect()成功返回0,出错返回-1;

二、TcpServer(英译中)

2.1 TcpServer.hpp

#pragma once#include <iostream>
using namespace std;#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include "log.hpp"
#include <strings.h>
#include <functional>
#include <cstring>
#include <unordered_map>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include "ThreadPool.hpp"
#include "Task.hpp"
#include "Daemon.hpp"const static int NUM = 1024;
const static string DEFAULT_IP = "0.0.0.0";
const static uint16_t DEFAULT_PORT = 8080;using func_t = function<string(string)>;enum
{SOCKET_ERROR = 3,BIND_ERROR,LISTEN_ERROR,ACCEPT_ERRNO,READ_ERROR
};extern Log log;// class ThreadData
// {
// public:
//     ThreadData(int sockfd, string clientip, uint16_t clientport, void *argv)
//         : _sockfd(sockfd), _clientip(clientip), _clientport(clientport), _argv(argv)
//     {
//     }// public:
//     int _sockfd;
//     string _clientip;
//     uint16_t _clientport;
//     void *_argv;
// };class TcpServer
{
public:TcpServer(func_t func, const uint16_t &port = DEFAULT_PORT, const string &ip = DEFAULT_IP): _port(port), _ip(ip), _func(func){}~TcpServer(){if (_listen_sockfd > 0){close(_listen_sockfd);}}void Init(){// 创建套接字_listen_sockfd = socket(AF_INET, SOCK_STREAM, 0);if (_listen_sockfd < 0){log(Fatal, "create _listen_socket failed,errno code:%d,error code string:%s", errno, strerror(errno));exit(SOCKET_ERROR);}log(Info, "create _listen_socket successed,_listen_sockfd:%d", _listen_sockfd);//设置端口复用int opt=1;setsockopt(_listen_sockfd,SOL_SOCKET,SO_REUSEADDR|SO_REUSEPORT,&opt,sizeof(opt));// 绑定struct sockaddr_in local;bzero(&local, sizeof(local));local.sin_family = AF_INET;local.sin_port = htons(_port);local.sin_addr.s_addr = INADDR_ANY;if (bind(_listen_sockfd, (struct sockaddr *)(&local), sizeof(local)) < 0){log(Fatal, "bind failed,errno code:%d,error code string:%s", errno, strerror(errno));exit(BIND_ERROR);}log(Info, "bind successed...,_listen_socket:%d",_listen_sockfd);// 监听if (listen(_listen_sockfd, 5) < 0){log(Fatal, "set _listen_sockfd failed,errno code:%d,error code string:%s", errno, strerror(errno));exit(LISTEN_ERROR);}log(Info, "set _listen_sockfd successed...,_listen_socket:%d",_listen_sockfd);}// static void* Service(void* argv)// {//     pthread_detach(pthread_self());//     ThreadData* td=static_cast<ThreadData*>(argv);//     char buffer[NUM];//     bzero(buffer, sizeof(buffer));//     while (true)//     {//         ssize_t s = read(td->_sockfd, buffer, sizeof(buffer) - 1);//         if (s > 0)//         {//             buffer[s] = '\0';//             cout << "client[ip:" << td->_clientip << " port:" << td->_clientport << "]# " << buffer << endl;//             // string message = _func(buffer);//             // write(sockfd, message.c_str(), message.size());//             write(td->_sockfd, buffer, sizeof(buffer));//             cout << "write done..." << endl;//         }//         else if (s == 0)//         {//             close(td->_sockfd);//             log(Info, "client exit... close sockfd:%d", td->_sockfd);//             break;//         }//         else//         {//             close(td->_sockfd);//             log(Fatal, "read failed,errno code:%d,error code string:%s,close sockfd:%d",//                 errno, strerror(errno), td->_sockfd);//             break;//         }//     }//     close(td->_sockfd);//     log(Info,"close sockfd:%d\n",td->_sockfd);// }// void Service(const int &sockfd, const string &clientip, const uint16_t &clientport)// {//     char buffer[NUM];//     bzero(buffer, sizeof(buffer));//     while (true)//     {//         ssize_t s = read(sockfd, buffer, sizeof(buffer) - 1);//         if (s > 0)//         {//             buffer[s] = '\0';//             //cout << "client[ip:" << clientip << " port:" << clientport << "]# " << buffer << endl;//             cout << "client[ip:" << clientip << " port:" << clientport << " sockfd:"<<sockfd<<"]# " << buffer << endl;//             // string message = _func(buffer);//             // write(sockfd, message.c_str(), message.size());//             // 这里不能写sizeof(buffer),不然可能会因为缓冲区问题导致client端不能正确打印//             write(sockfd, buffer, strlen(buffer));//             cout << "write done..." << endl;//         }//         else if (s == 0)//         {//             close(sockfd);//             log(Info, "client exit... ");//             break;//         }//         else//         {//             close(sockfd);//             log(Fatal, "read failed,errno code:%d,error code string:%s",//                 errno, strerror(errno));//             break;//         }//     }//     close(sockfd);//     log(Info, "close sockfd:%d", sockfd);// }// static void *Rontiue(void *argv)// {//     pthread_detach(pthread_self());//     ThreadData *td = static_cast<ThreadData *>(argv);//     TcpServer *p = static_cast<TcpServer *>(td->_argv);//     p->Service(td->_sockfd, td->_clientip, td->_clientport);//     delete td;// }void Run(){//守护进程化Daemon();//启动线程池ThreadPool<Task>::GetThreadPool()->Run();while (true){// 获取连接struct sockaddr_in client;bzero(&client, sizeof(client));socklen_t len = sizeof(client);int sockfd = accept(_listen_sockfd, (struct sockaddr *)(&client), &len);if (sockfd < 0){log(Warning, "accept sockfd failed,errno code:%d,error code string:%s", errno, strerror(errno));sleep(1);continue;}//不建议用inet_ntoa,因为inet_ntoa用的是一个静态的缓冲区,多次调用可能会导致覆盖问题char clientip[32];inet_ntop(AF_INET, &(client.sin_addr), clientip, sizeof(client));uint16_t clientport = ntohs(client.sin_port);log(Info, "accept sockfd successed,get a new link...[clientip:%s,clientport:%d],sockfd:%d", clientip, clientport, sockfd);//============================================================// // 单进程版// Service(sockfd, clientip, clientport);//=============================================================//=============================================================// // 多进程版// pid_t id = fork();// if (id == 0)// {//     close(_listen_sockfd);//     // 子进程//     if (fork() > 0)//     {//         exit(0);//     }//     Service(sockfd, clientip, clientport);//     exit(5);// }// // 这里必须关闭,因为在上面的子进程已经拿到了文件描述符了,所以父进程// // 就要关闭这个文件描述符,其实父进程关闭的时候这个文件描述符并不会真正// // 地被释放,因为只是引用计数减一,只有子进程结束的时候释放该文件描述符// // 才会真正地被释放// close(sockfd);// // 这里不会被阻塞住,因为是孙子进程执行任务,儿子进程一下子就退出啦,即waitpid不会阻塞很久// waitpid(id, nullptr, 0);//=================================================================//=================================================================// // 多线程版// pthread_t tid;// ThreadData *td = new ThreadData(sockfd, clientip, clientport, this);// pthread_create(&tid, nullptr, Rontiue, td);//==================================================================//线程池版Task t(sockfd, clientip, clientport);ThreadPool<Task>::GetThreadPool()->Push(t);//===================================================================}}private:int _listen_sockfd;    //监听套接字uint16_t _port;        //服务器端口号string _ip;            //服务器ip地址func_t _func;          //回调函数,服务器处理客户需求的方法可以自定义
};

2.2 TcpClient.cc


#include <iostream>
using namespace std;#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <strings.h>
#include <pthread.h>
#include <cstring>
#include "log.hpp"const static int NUM = 1024;enum
{SOCKET_ERROR = 3,CONNECT_ERROR
};void Usage(string argv)
{cout << "\n\t"<< "Usage:" << argv << " ServerIp ServerPort" << endl<< endl;
}Log log;// int main(int argc, char *argv[])
// {
//     if (argc != 3)
//     {
//         Usage(argv[0]);
//         exit(1);
//     }//     string ServerIp = argv[1];
//     string str = argv[2];
//     uint16_t ServerPort = (uint16_t)stoi(str.c_str());//     // 创建套接字
//     int sockfd = socket(AF_INET, SOCK_STREAM, 0);
//     if (sockfd < 0)
//     {
//         log(Fatal, "create socket failed,errno code:%d,error code string:%s", errno, strerror(errno));
//         exit(SOCKET_ERROR);
//     }
//     log(Info, "create socket successed,sockfd:%d", sockfd);//     struct sockaddr_in server;
//     server.sin_family = AF_INET;
//     server.sin_addr.s_addr = inet_addr(ServerIp.c_str());
//     server.sin_port = htons(ServerPort);
//     socklen_t len = sizeof(server);//     // 建立连接
//     if (connect(sockfd, (struct sockaddr *)&server, len) < 0)
//     {
//         log(Fatal, "connect failed,errno code:%d,error code string:%s", errno, strerror(errno));
//         exit(CONNECT_ERROR);
//     }
//     log(Info, "connect successed...");//     string buffer;
//     while (true)
//     {
//         cout << "Please Enter# ";
//         getline(cin, buffer);//         write(sockfd, buffer.c_str(), buffer.size());//         //这里的message缓冲区的大小不能少于1024,否则会出错,具有原因有待查明,
//         //原因找到了,是服务端write的时候写了sizeof(buffer),导致缓冲区出现了问题
//         char message[1024];
//         bzero(message,sizeof(message));
//         ssize_t s = read(sockfd, message, sizeof(message)-1);
//         cout<<"read done..."<<endl;
//         if (s > 0)
//         {
//             message[s]='\0';
//             cout << "Server say# " << message << endl;
//         }
//         else if (s == 0)
//         {
//             log(Info, "server exit,close sockfd:%d", sockfd);
//             break;
//         }
//         else
//         {
//             log(Info, "read failed,close sockfd:%d", sockfd);
//             break;
//         }
//     }//     close(sockfd);
// }//带入了重连机制
int main(int argc, char *argv[])
{if (argc != 3){Usage(argv[0]);exit(1);}string ServerIp = argv[1];string str = argv[2];uint16_t ServerPort = (uint16_t)stoi(str.c_str());//初始化服务器的结构体信息struct sockaddr_in server;server.sin_family = AF_INET;server.sin_addr.s_addr = inet_addr(ServerIp.c_str());server.sin_port = htons(ServerPort);socklen_t len = sizeof(server);while (true){bool isreconnect = false;// 创建套接字int sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){log(Fatal, "create socket failed,errno code:%d,error code string:%s", errno, strerror(errno));}log(Info, "create socket successed,sockfd:%d", sockfd);int cnt = 10;do{// 建立连接if (connect(sockfd, (struct sockaddr *)&server, len) < 0){//如果连接失败,那么isreconnect就会被置为true,然后就进入重连状态cnt--;isreconnect = true;log(Warning, "connect failed,errcode:%d,errstring:%s,reconnect:%d", errno, strerror(errno), cnt);sleep(2);}else{//连接成功就跳出do while循环break;}} while (cnt && isreconnect);//最多重连cnt次,当cnt变为0的时候,就会自动跳出do while循环if (cnt == 0){//重连失败log(Warning, "connect failed,errcode:%d,errstring:%s,reconnect fail...", errno, strerror(errno));break;}log(Info, "connect successed...");string buffer;// while (true)// {cout << "Please Enter# ";getline(cin, buffer);write(sockfd, buffer.c_str(), buffer.size());// 这里的message缓冲区的大小不能少于1024,否则会出错,具有原因有待查明,// 原因找到了,是服务端write的时候写了sizeof(buffer),导致缓冲区出现了问题char message[1024];bzero(message, sizeof(message));ssize_t s = read(sockfd, message, sizeof(message) - 1);// cout << "read done..." << endl;if (s > 0){message[s] = '\0';cout << "Server say# " << message << endl;}else if (s == 0){log(Info, "server exit,close sockfd:%d", sockfd);// break;}else{log(Info, "read failed,close sockfd:%d", sockfd);// break;}// }close(sockfd);}
}

由于客户端不需要固定的端口号,因此不必调用bind(),客户端的端口号由内核自动分配。
注意:
客户端不是不允许调用bind(), 只是没有必要调用bind()固定一个端口号. 否则如果在同一台机器上启动多个客户端, 就会出现端口号被占用导致不能正确建立连接;
服务器也不是必须调用bind(), 但如果服务器不调用bind(), 内核会自动给服务器分配监听端口, 每次启动服务器时端口号都不一样, 客户端要连接服务器就会很麻烦了。

2.3 Task.hpp

#pragma once#include <stdio.h>
#include "log.hpp"
#include "Init.hpp"
#include <cstring>
#include <strings.h>Log log;//定义一个全局变量,在main函数之前就定义好了,即初始化好了
Init dict;class Task
{
public:Task(int sockfd, const std::string &clientip, const uint16_t &clientport): _sockfd(sockfd), _clientip(clientip), _clientport(clientport){}Task(){}void run(const string& threadName){// // 测试代码// char buffer[4096];// ssize_t n = read(sockfd_, buffer, sizeof(buffer));// if (n > 0)// {//     buffer[n] = 0;//     std::cout << "client key# " << buffer << std::endl;//     std::string echo_string = buffer;//     // sleep(5);//     // // close(sockfd_);//     // lg(Warning, "close sockfd %d done", sockfd_);//     // sleep(2);//     n = write(sockfd_, echo_string.c_str(), echo_string.size()); // 100 fd 不存在//     if(n < 0)//     {//         lg(Warning, "write error, errno : %d, errstring: %s", errno, strerror(errno));//     }// }// else if (n == 0)// {//     lg(Info, "%s:%d quit, server close sockfd: %d", clientip_.c_str(), clientport_, sockfd_);// }// else// {//     lg(Warning, "read error, sockfd: %d, client ip: %s, client port: %d", sockfd_, clientip_.c_str(), clientport_);// }// close(sockfd_);char buffer[4096];bzero(buffer, sizeof(buffer));ssize_t s = read(_sockfd, buffer, sizeof(buffer) - 1);if (s > 0){// buffer[s] = '\0';// // cout << "client[ip:" << clientip << " port:" << clientport << "]# " << buffer << endl;// cout <<threadName<< "收到一条信息:client[ip:" << _clientip << " port:" << _clientport << " sockfd:" << _sockfd << "]# " << buffer << endl;// // string message = _func(buffer);// // write(sockfd, message.c_str(), message.size());// // 这里不能写sizeof(buffer),不然可能会因为缓冲区问题导致client端不能正确打印// write(_sockfd, buffer, strlen(buffer));// cout << "write done..." << endl;cout <<threadName<< "收到一条信息:client[ip:" << _clientip << " port:" << _clientport << " sockfd:" << _sockfd << "]# " << buffer << endl;string resp=dict.translation(buffer);// 这里不能写sizeof(buffer),不然可能会因为缓冲区问题导致client端不能正确打印write(_sockfd, resp.c_str(), resp.size());}else if (s == 0){close(_sockfd);log(Info, "client exit... ");}else{close(_sockfd);log(Fatal, "read failed,errno code:%d,error code string:%s",errno, strerror(errno));}close(_sockfd);log(Info, "close sockfd:%d", _sockfd);}void operator()(const string& threadName){run(threadName);}~Task(){}private:int _sockfd;std::string _clientip;uint16_t _clientport;
};

2.4 Thread.hpp

#pragma once#include <iostream>
using namespace std;
#include <functional>typedef void *(*fun_t)(void *);struct ThreadData
{
public:ThreadData(int num, void *args): _args(args){_name = "Thread-" + to_string(num);}public:string _name;void *_args;
};class Thread
{
public:Thread(int num, fun_t cb, void *args): _cb(cb), _data(num, args){}void Start(){pthread_create(&_tid, nullptr, _cb, &_data);}private:pthread_t _tid;fun_t _cb;ThreadData _data;
};

2.5 ThreadPool.hpp

#pragma once#include <iostream>
using namespace std;#include <vector>
#include <queue>
#include <mutex>
#include <unistd.h>
#include "Thread.hpp"// const static int default_num = 5;// template <class T>
// class ThreadPool
// {
// private:
//     void Lock()
//     {
//         pthread_mutex_lock(&_mtx);
//     }
//     void UnLock()
//     {
//         pthread_mutex_unlock(&_mtx);
//     }
//     void WakeUp()
//     {
//         pthread_cond_signal(&_cond);
//     }
//     void ThreadSleep()
//     {
//         pthread_cond_wait(&_cond, &_mtx);
//     }
//     bool IsQueueEmpty()
//     {
//         return _q.empty();
//     }// private:
//     ThreadPool(const int num = default_num)
//         : _num(num)
//     {
//         pthread_mutex_init(&_mtx, nullptr);
//         pthread_cond_init(&_cond, nullptr);
//     }// public:
//     static ThreadPool<T>* GetInstance()
//     {
//         if(nullptr==_Inst)
//         {
//             pthread_mutex_lock(&_Inst_mtx);
//             if(nullptr==_Inst)
//             {
//                 _Inst=new ThreadPool<T>();
//             }
//             pthread_mutex_unlock(&_Inst_mtx);
//         }
//         return _Inst;
//     }//     ~ThreadPool()
//     {
//         pthread_mutex_destroy(&_mtx);
//         pthread_cond_destroy(&_cond);
//     }//     static void *Routine(void *args)
//     {
//         ThreadPool<T> *tp = static_cast<ThreadPool<T> *>(args);
//         pthread_detach(pthread_self());
//         while (true)
//         {
//             // cout<<"进入routine"<<endl;//             //pop的锁必须在这里加,不能在pop函数中加,因为这里的ThreadSleep函数等待时需要先释放锁
//             //如果锁在pop函数中加的话,这里的ThreadSleep函数将无法释放锁,导致进程卡死
//             tp->Lock();
//             while (tp->IsQueueEmpty())
//             {
//                 tp->ThreadSleep();
//             }//             usleep(1000);
//             T t=tp->Pop();
//             tp->UnLock();//             //cout << "从任务队列中消费了一个数据:" << t << endl;
//             t();
//         }//         return nullptr;
//     }//     void Run()
//     {
//         for (int i = 0; i < _num; i++)
//         {
//             pthread_t tid;
//             // cout<<"Run"<<endl;
//             pthread_create(&tid, nullptr, Routine, this);
//             _threads.push_back(tid);
//         }
//     }//     void Push(const T &in)
//     {
//         Lock();
//         _q.push(in);
//         WakeUp();
//         UnLock();
//     }//     T Pop()
//     {
//         T out=_q.front();
//         _q.pop();
//         return out;
//     }// private:
//     vector<pthread_t> _threads;
//     queue<T> _q;
//     int _num;
//     pthread_mutex_t _mtx;
//     pthread_cond_t _cond;
//     static ThreadPool<T>* _Inst;
//     static pthread_mutex_t _Inst_mtx;
// };// template<class T>
// ThreadPool<T>* ThreadPool<T>::_Inst=nullptr;// template<class T>
// pthread_mutex_t ThreadPool<T>::_Inst_mtx=PTHREAD_MUTEX_INITIALIZER;const static int default_num = 5;template <class T>
class ThreadPool
{
private:void Lock(){pthread_mutex_lock(&_mtx);}void UnLock(){pthread_mutex_unlock(&_mtx);}void WakeUp(){pthread_cond_signal(&_cond);}void ThreadSleep(){pthread_cond_wait(&_cond, &_mtx);}bool IsQueueEmpty(){return _q.empty();}private:ThreadPool(const int num = default_num): _num(num){//构造函数中必须把所有的线程对象先创建好,否则程序会崩溃for(int i=0;i<_num;i++){Thread thread(i+1,Routine,this);_threads.push_back(thread);}pthread_mutex_init(&_mtx, nullptr);pthread_cond_init(&_cond, nullptr);}public:static ThreadPool<T>* GetThreadPool(){if(nullptr==_Inst){pthread_mutex_lock(&_Inst_mtx);if(nullptr==_Inst){_Inst=new ThreadPool<T>();}pthread_mutex_unlock(&_Inst_mtx);}return _Inst;}~ThreadPool(){pthread_mutex_destroy(&_mtx);pthread_cond_destroy(&_cond);}static void *Routine(void *args){//ThreadPool<T> *tp = static_cast<ThreadPool<T> *>(args);ThreadData* ptd=static_cast<ThreadData*>(args);ThreadPool<T> *tp = static_cast<ThreadPool<T> *>(ptd->_args);pthread_detach(pthread_self());while (true){//cout<<"进入routine"<<endl;//pop的锁必须在这里加,不能在pop函数中加,因为这里的ThreadSleep函数等待时需要先释放锁//如果锁在pop函数中加的话,这里的ThreadSleep函数将无法释放锁,导致进程卡死tp->Lock();while (tp->IsQueueEmpty()){tp->ThreadSleep();}//cout<<"进入routine"<<endl;usleep(1000);T t=tp->Pop();tp->UnLock();//cout << "从任务队列中消费了一个数据:" << t << endl;//cout<<ptd->_name<<":";t(ptd->_name);}return nullptr;}void Run(){for (int i = 0; i < _num; i++){//pthread_t tid;// cout<<"Run"<<endl;//pthread_create(&tid, nullptr, Routine, this);_threads[i].Start();}}void Push(const T &in){Lock();_q.push(in);WakeUp();UnLock();}T Pop(){T out=_q.front();_q.pop();return out;}private:vector<Thread> _threads;queue<T> _q;int _num;pthread_mutex_t _mtx;pthread_cond_t _cond;static ThreadPool<T>* _Inst;static pthread_mutex_t _Inst_mtx;
};template<class T>
ThreadPool<T>* ThreadPool<T>::_Inst=nullptr;template<class T>
pthread_mutex_t ThreadPool<T>::_Inst_mtx=PTHREAD_MUTEX_INITIALIZER;

2.6 makefile

.PHONY:all
all:Client ServerClient:TcpClient.ccg++ -o $@ $^ -std=c++11 -lpthreadServer:Main.ccg++ -o $@ $^ -std=c++11 -lpthread.PHONY:clean
clean:rm -f Client Server

2.7 Main.cc

#include "TcpServer.hpp"
#include <memory>string func(string s)
{return s + " already handled\n";
}void Usage(string argv)
{cout << "\n\t"<< "Usage:" << argv << " ServerPort" << endl<< endl;
}
int main(int argc, char* argv[]) 
{srand((unsigned int)time(nullptr));if (argc != 2){Usage(argv[0]);exit(1);}string str = argv[1];uint16_t ServerPort = (uint16_t)stoi(str.c_str());unique_ptr<TcpServer> svr(new TcpServer(func,ServerPort));//unique_ptrsvr->Init();svr->Run();return 0;
}

2.8 log.hpp

#pragma once#include <iostream>
using namespace std;
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <string>
#include <time.h>
#include <stdarg.h>// 日志等级
#define Info 0
#define Debug 1
#define Warning 2
#define Error 3
#define Fatal 4#define Screen 1
#define OneFile 2
//向多个文件打印
#define Classfile 3
#define SIZE 1024#define LogFile "log.txt"class Log
{
public:Log(){printMethod = Screen;path = "./log/";}void Enable(int mothod){printMethod = mothod;}string LevelToString(int level){switch (level){case Info:{return "Info";}case Debug:{return "Debug";}case Warning:{return "Warning";}case Error:{return "Error";}case Fatal:{return "Fatal";}default:{return "None";}}}void printlog(int level,const string& logtxt){switch(printMethod){case Screen:{cout<<logtxt<<endl;break;}case OneFile:{PrintOneFile(LogFile,logtxt);break;}case Classfile:{PrintClassfile(level,logtxt);break;}default:{break;}}}void PrintOneFile(const string& logname,const string& logtxt){string _logname=path+logname;int fd=open(_logname.c_str(),O_WRONLY|O_CREAT|O_APPEND,0666);if(fd<0){perror("open fail");return;}write(fd,logtxt.c_str(),logtxt.size());close(fd);}void PrintClassfile(int level,const string& logtxt){string filename=LogFile;filename+='.';filename+=LevelToString(level);PrintOneFile(filename,logtxt);}void operator()(int level,const char* format,...){time_t t=time(nullptr);struct tm* ctime=localtime(&t);char leftbuffer[SIZE];snprintf(leftbuffer,SIZE,"[%s][%d-%d-%d %d:%d:%d]",LevelToString(level).c_str(),ctime->tm_year+1900,ctime->tm_mon+1,ctime->tm_mday,ctime->tm_hour,ctime->tm_min,ctime->tm_sec);va_list s;va_start(s,format);char rightbuffer[SIZE]={0};vsnprintf(rightbuffer,SIZE,format,s);va_end(s);char logtxt[SIZE*2];snprintf(logtxt,sizeof(logtxt),"%s %s",leftbuffer,rightbuffer);printlog(level,logtxt);}~Log(){}private:// 打印方法int printMethod;string path;
};

2.9 Init.hpp

#pragma once#include <iostream>
using namespace std;#include <unordered_map>
#include <fstream>
#include "log.hpp"const string dictname = "./dict.txt";
const string sep = ":";extern Log log;//把字符串分成key和val
static bool Split(const string &line, string &part1, string &part2)
{size_t pos = line.find(sep);if (pos == string::npos){return false;}part1 = line.substr(0, pos);part2 = line.substr(pos + 2);return true;
}class Init
{
public:Init(){//创建对象就会自动打开对应的文件ifstream in(dictname);if (!in.is_open()){log(Fatal, "open the dict failed...");exit(1);}log(Info, "open the dict successed...");string line;while (getline(in, line)){string part1, part2;if (Split(line, part1, part2)){//把所有的英文单词及其中文都映射到哈希表中_dict[part1] = part2;}else{log(Warning, "format error: %s", line.c_str());}}log(Info,"load dict success...");//关闭文件in.close();}string translation(const string& key){auto it=_dict.find(key);if(it!=_dict.end()){return it->second;}else{return "Unknown this word";}}private:unordered_map<string, string> _dict;
};

2.10 dict.txt

word: 单词
sentence: 句子
paragraph: 段落
book: 书
chapter: 章节
page: 页
article: 文章
dictionary: 字典
thesaurus: 同义词词典
encyclopedia: 百科全书
novel: 小说
short story: 短篇小说
poem: 诗
play: 剧本
film: 电影
song: 歌曲
painting: 画作
sculpture: 雕塑
computer: 电脑
phone: 手机
TV: 电视
radio: 收音机
car: 汽车
bus: 公交车
train: 火车
plane: 飞机
ship: 船
sun: 太阳
moon: 月亮
planet: 行星
star: 星星
sky: 天空
cloud: 云彩
rainbow: 彩虹
snow: 雪
wind: 风
fire: 火
water: 水
ice: 冰
mountain: 山峰
hill: 小山丘
forest: 森林
tree: 树木
flower: 花儿
grass: 草地
bird: 鸟类
cat: 猫科动物
dog: 狗科动物
fish: 鱼类动物
human being: 人类
happiness: 幸福
sadness: 悲伤
love: 爱意
fear: 恐惧感
joy: 喜悦感
anger: 愤怒感
surprise: 惊讶感
disgust: 厌恶感
guilt: 内疚感
shame: 自卑感
pride: 自尊感
hope: 希望感
disappointment: 失望感
excitement: 兴奋感
boredom: 厌倦感
trust: 信任感
surprise: 惊讶感
gratitude: 感激感
friendship: 友谊感
family love: 亲情爱意
romantic love: 浪漫爱情
school: 学校教育场所
workplace: 工作场所地
market place: 市场场所地

2.11 Daemon.hpp

#pragma once#include <iostream>
#include <cstdlib>
#include <unistd.h>
#include <signal.h>
#include <string>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>//这是系统提供的一个类似于垃圾桶的文件,当我们向这
//个文件写入的时候,该文件就会把内容自动地丢弃
const std::string nullfile="/dev/null";//守护进程化
void Daemon(const std::string& cmd="")
{//1、忽略其它异常信号signal(SIGPIPE,SIG_IGN);signal(SIGCHLD,SIG_IGN);signal(SIGSTOP,SIG_IGN);//2、先创建子进程,子进程再将自己变成独立的会话if(fork()>0){exit(0);}setsid();//将自己变成独立的会话//3、更改当前调用进程的工作目录if(!cmd.empty()){chdir(cmd.c_str());}//4、标准输入,标准输出,标准错误重定向到 /dev/nullint fd=open(nullfile.c_str(),O_RDWR);if(fd>0){dup2(fd,0);dup2(fd,1);dup2(fd,2);}}

以上就是简单的用于中英文翻译的TCP服务器的代码实现,你学会了吗?如果感觉到有所收获,那就点点赞,点点关注呗,后期还会持续更新网络编程的相关知识哦,我们下期见!!!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/669805.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

瑞萨RA6M3开发实践指南-UART实践

1.背景说明 本文是参考瑞萨RA6M3开发实践指南文章教程&#xff0c;基于瑞萨HMI-Board BSP :1.1.1 版本 RT-Thread 5.0.1 版本操作步骤进行记录&#xff0c;整理成的文档。 1.1 本章内容 使用RT-Thread Studio创建开发板的程序&#xff0c;编写UART的程序&#xff0c;实现串口…

Springboot+vue的企业财务管理系统(有报告)。Javaee项目,springboot vue前后端分离项目

演示视频&#xff1a; Springbootvue的企业财务管理系统&#xff08;有报告&#xff09;。Javaee项目&#xff0c;springboot vue前后端分离项目 项目介绍&#xff1a; 本文设计了一个基于Springbootvue的前后端分离的企业财务管理系统&#xff0c;采用M&#xff08;model&…

【Java安全】ysoserial-URLDNS链分析

前言 Java安全中经常会提到反序列化&#xff0c;一个将Java对象转换为字节序列传输&#xff08;或保存&#xff09;并在接收字节序列后反序列化为Java对象的机制&#xff0c;在传输&#xff08;或保存&#xff09;的过程中&#xff0c;恶意攻击者能够将传输的字节序列替换为恶…

第二篇:MySQL安装与配置(基于小皮面板(phpstudy))

在第一篇中介绍了数据库的相关概念&#xff0c;了解到SQL是用来操作数据库管理系统的语言&#xff0c;因此要学习数据库技术&#xff0c;数据库管理系统的配备是必不可少的&#xff01; 并且出于流行性与实惠性的双考量而选择MySQL这款数据库管理系统软件 一&#xff0c;工具推…

JVM工作原理与实战(三十六):GraalVM虚拟机

专栏导航 JVM工作原理与实战 RabbitMQ入门指南 从零开始了解大数据 目录 专栏导航 前言 一、GraalVM介绍 二、GraalVM的两种运行模式 三、GraalVM应用场景 1.GraalVM存在的问题 2.GraalVM企业级应用-Serverless架构 3.Serverless架构-函数计算 4.Serverless架构-Serve…

zabbix配置自动发现

1.准备一台新的主机&#xff0c;安装相关软件包。 [rootsishi ~]# rpm -Uvh https://repo.zabbix.com/zabbix/5.0/rhel/7/x86_64/zabbix-release-5.0-1.el7.noarch.rpm [rootsishi ~]# yum -y install zabbix-agent2.修改zabbix-agent端的配置文件 [rootsishi ~]# vim /etc/z…

TS项目实战二:网页计算器

使用ts实现网页计算器工具&#xff0c;实现计算器相关功能&#xff0c;使用tsify进行项目编译&#xff0c;引入Browserify实现web界面中直接使用模块加载服务。   源码下载&#xff1a;点击下载 讲解视频 TS实战项目四&#xff1a;计算器项目创建 TS实战项目五&#xff1a;B…

当AGI遇到人形机器人

为什么人类对人形机器人抱有执念 人形机器人是一种模仿人类外形和行为的机器人&#xff0c;它的研究和开发有着多方面的目的和意义。 人形机器人可以更好地适应人类的环境和工具。人类的生活和工作空间都是根据人的尺寸和动作来设计的&#xff0c;例如门、楼梯、桌椅、开关等…

【数据分享】1929-2023年全球站点的逐月平均能见度(Shp\Excel\免费获取)

气象数据是在各项研究中都经常使用的数据&#xff0c;气象指标包括气温、风速、降水、能见度等指标&#xff0c;说到气象数据&#xff0c;最详细的气象数据是具体到气象监测站点的数据&#xff01; 之前我们分享过1929-2023年全球气象站点的逐月平均气温数据、逐月最高气温数据…

【征稿已开启】第五大数据、人工智能与软件工程国际研讨会(ICBASE 2024)

第五大数据、人工智能与软件工程国际研讨会&#xff08;ICBASE 2024&#xff09; 2024 5th International Conference on Big Data & Artificial Intelligence & Software Engineering 2024年09月20-22日 | 中国温州 第五届大数据、人工智能与软件工程国际研讨会&…

年假作业4

AACBB DACBDD DACBC DBDCA ADBAD #include <stdio.h> #include <string.h> int main(int argc, const char *argv[]) { int i,j; int temp; int arr[10]; for( i0;i<10;i) { printf("请输入第%d个数",i1); …

【lvgl】esp32移植lvgl

文章目录 一、环境二、抓取代码三、切换分支四、配置芯片信息五、编译异常问题1: 未定义宽高问题2: 修改接口问题3: lv_mem_size问题4&#xff1a;头文件命名打开配置问题5&#xff1a;缺少font12 六、配置引脚问题6&#xff1a;显示花屏&#xff0c;字符不清 七、测试demo八、…

vscode连接ssh报错

关于vscode更新版本至1.86后&#xff0c;导致无法连接服务器问题的记录 原因&#xff1a;vscode1.86更新了对glibc的要求&#xff0c;需要最低2.28版本&#xff0c;导致各种旧版本的linux发行版&#xff08;比如最常见的centos 7&#xff09;都无法用remote-ssh来连接了&#…

Windows11安装运行Linux(Ubuntu)

一、安装windows支持 输入windows打开界面 选择虚拟机监控程序平台、适用于linux的子系统、虚拟机平台 在 Windows 系统中&#xff0c;"虚拟机平台"和"虚拟机监控程序平台"是两个与虚拟化相关的功能&#xff0c;但它们各自有着不同的作用和用途。 虚拟机…

【ArcGIS微课1000例】0101:删除冗余节点或折点

文章目录 一、实验描述二、实验数据三、实验过程1. 手动删除2. 简化线工具四、注意事项一、实验描述 矢量数据获取通常来源于手动或者ArcScan自动采集,其基本存储方式就是记录每个要素的点坐标,如点要素就是一个坐标、线要素由多个点要素连接形成。当某段线要素被过多的节点…

thinkphp数据批量提交(群发消息)

<form id="edit-form" class="form-horizontal" role="form" data-toggle<

LeetCode、1137. 第 N 个泰波那契数【简单,动态规划】

文章目录 前言LeetCode、1137. 第 N 个泰波那契数【简单&#xff0c;动态规划】题目与分类思路一维动态规划 资料获取 前言 博主介绍&#xff1a;✌目前全网粉丝2W&#xff0c;csdn博客专家、Java领域优质创作者&#xff0c;博客之星、阿里云平台优质作者、专注于Java后端技术…

2024/2/5总结

微信小程序 监听对象中所有属性的变化 如果某个对象中需要被监听的属性太多&#xff0c;为了方便&#xff0c;可以使用 通配符 ** 来监听 对象中所有属性的变化 什么是纯数字字段 概念&#xff1a;纯数字字段指的是那些不用于界面渲染的 data 字段。 好处&#xff1a;提升界面…

敏捷开发中的用户故事

用户故事 drawio是一款强大的图表绘制软件&#xff0c;支持在线云端版本以及windows, macOS, linux安装版。 如果想在线直接使用&#xff0c;则直接输入网址drawon.cn或者使用drawon(桌案), drawon.cn内部完整的集成了drawio的所有功能&#xff0c;并实现了云端存储&#xff0c…

transformers重要组件(模型与分词器)

1、模型&#xff1a; from transformers import AutoModelcheckpoint "distilbert-base-uncased-finetuned-sst-2-english" model AutoModel.from_pretrained(checkpoint) 除了像之前使用 AutoModel 根据 checkpoint 自动加载模型以外&#xff0c;我们也可以直接…