![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250730052246-6889ac26eb5bd.png\")
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250730052247-6889ac27e990f.png\")
<\/p>\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u672c\u6587\u5c06\u901a\u8fc7epoll\u5b8c\u6210\u5bf9\u5ba2\u6237\u7aef\u8bf7\u6c42\u7684\u5904\u7406，\u901a\u8fc7\u591a\u7ebf\u7a0b\u5b8c\u6210\u5bf9\u5ba2\u6237\u7aef\u53d1\u9001\u6570\u636e\u7684\u5904\u7406，\u5e76\u63d0\u4ea4\u5230\u8fdc\u7aefmysql<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u9700\u8981\u7684\u4f7f\u7528\u5230\u7684\u4e00\u4e9b\u6280\u672f\u6709：socket\u7f51\u7edc\u5957\u63a5\u5b57\u7f16\u7a0b\u3001IO\u591a\u8def\u8f6c\u63a5\u7684epoll\u3001\u591a\u7ebf\u7a0b（\u5305\u62ec\u4e92\u65a5\u9501\u548c\u6761\u4ef6\u53d8\u91cf）<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5f00\u53d1\u73af\u5883\u4e3a：ubuntu20.04\u3001C++11\u3001Mysq5.7.42<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 epoll\u7684\u63a5\u53e3\u76f4\u63a5\u4f7f\u7528\u8f83\u4e3a\u9ebb\u70e6，\u6240\u4ee5\u8fd9\u91cc\u535a\u4e3b\u5c06\u8fd9\u5757\u5185\u5bb9\u5c01\u88c5\u6210\u4e00\u4e2a\u5185\u65b9\u4fbf\u540e\u7eed\u7684\u8c03\u7528<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5305\u62ecepoll_create\u3001epoll_ctl\u3001epoll_wait\u8fd9\u4e09\u4e2a\u63a5\u53e3，\u8fd9\u4e9b\u63a5\u53e3\u5728\u535a\u4e3b\u524d\u9762\u7684\u5185\u5bb9\u4e2d\u8be6\u7ec6\u8bb2\u8fc7，\u6240\u4ee5\u8fd9\u91cc\u5c31\u76f4\u63a5\u5c55\u793a\u5c01\u88c5\u7684\u7c7b<\/p>\n
#pragma once
\n#include <iostream>
\n#include <unistd.h>
\n#include <sys\/epoll.h><\/p>\n
class Epoll
\n{
\n const int size = 128;<\/p>\n
public:
\n Epoll() : _timeout(3000)
\n {
\n _epfd = epoll_create(size);
\n if (_epfd < 0)
\n {
\n std::cout<<"epoll_create fail…"<<std::endl;
\n close(_epfd);
\n }
\n }
\n ~Epoll() { close(_epfd); }<\/p>\n
public:
\n void Epoll_Ctl(int op, int fd, uint32_t event)
\n {
\n if (op == EPOLL_CTL_DEL)
\n {
\n int n = epoll_ctl(_epfd, op, fd, nullptr);
\n if (n != 0)
\n std::cout << "epoll_ctl delete fail…" << std::endl;
\n }
\n else
\n {
\n struct epoll_event ev;
\n ev.data.fd = fd;
\n ev.events = event;
\n int n = epoll_ctl(_epfd, op, fd, &ev);
\n if (n != 0)
\n std::cout << "epoll_ctl add epoll_event fail…" << std::endl;
\n }
\n }<\/p>\n
int Epoll_Wait(struct epoll_event *events, int maxevents)
\n {
\n int n = epoll_wait(_epfd, events, maxevents, _timeout);
\n if (n == 0)
\n std::cout << "epoll_wait timeout…" << std::endl;
\n else if (n < 0)
\n std::cout << "epoll_wait fail…" << std::endl;
\n return n;
\n }<\/p>\n
private:
\n int _epfd;
\n int _timeout;
\n};<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5305\u62ec\u521b\u5efa\u5957\u63a5\u5b57\u3001\u7ed1\u5b9a\u3001\u76d1\u542c\u3001\u8bf7\u6c42\u8fde\u63a5\u3001\u63a5\u53d7\u8fde\u63a5\u8fd9\u4e94\u4e2a\u4e3b\u8981\u7684\u63a5\u53e3\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u76f8\u5173\u7684\u63a5\u53e3\u5728\u524d\u9762\u7684\u6587\u4ef6\u8bb2\u8fc7，\u5e76\u8fdb\u884c\u4e86\u5c01\u88c5\u8fd9\u91cc\u5c31\u5bb9\u6613\u5fd8\u8bb0\u548c\u5bb9\u6613\u641e\u9519\u7684\u5730\u65b9\u8bb2\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5bf9\u4e8esocket\u63a5\u53e3\u7684\u5c01\u88c5，\u6211\u5728\u6700\u540e\u4f7f\u7528\u4e86setsockopt\u8fd9\u4e2a\u63a5\u53e3\u76ee\u7684\u662f\u4e3a\u4e86\u8ba9\u670d\u52a1\u5668\u80fd\u591f\u5feb\u901f\u91cd\u542f，\u5982\u679c\u6ca1\u6709\u8fd9\u4e2a\u63a5\u53e3\u7684\u5904\u7406，\u5728tcp\u534f\u8bae\u4e2d\u5982\u679c\u670d\u52a1\u7aef\u4e3b\u52a8\u5173\u95ed，\u5957\u63a5\u5b57\u4f1a\u8fdb\u5165TIEM_WAIT\u72b6\u6001\u7b49\u5f85（2*MSL）,\u4f46\u662f\u5728\u8fd9\u6bb5\u65f6\u95f4\u5185\u670d\u52a1\u5668\u4f9d\u65e7\u5360\u636e\u7740\u8fd9\u4e2a\u7aef\u53e3\u53f7，\u5982\u679c\u57282*MSL\u8fd9\u6bb5\u65f6\u95f4\u5185，\u5c1d\u8bd5\u91cd\u542f\u670d\u52a1\u5668\u4f1a\u63d0\u793a\u5bf9\u5e94\u7684\u7aef\u53e3\u5e76\u7ed1\u5b9a\u4e86\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 bind\u6ca1\u4ec0\u4e48\u597d\u8bf4\u7684\u4e3b\u8981\u5c31\u662f\u6ce8\u610f\u5728\u7ed1\u5b9a\u7aef\u53e3\u53f7\u7684\u65f6\u5019\u5c06\u4e3b\u673a\u5b57\u8282\u5e8f\u8f6c\u6362\u6210\u7f51\u7edc\u5b57\u8282\u5e8f，\u5728\u7ed1\u5b9aip\u5730\u5740\u7684\u65f6\u5019\u6ce8\u610f\u5c06\u5b57\u7b26\u4e32\u7c7b\u578bip\u5730\u5740\u8f6c\u6210\u4e8c\u8fdb\u5236\u7c7b\u578b\u7684ip\u5730\u5740（\u6211\u8fd9\u91cc\u91c7\u7528INADDR_ANY\u6765\u7ed1\u5b9a\u4efb\u610f\u53ef\u7528\u7684ip\u5730\u5740）<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 listen\u76f4\u63a5\u8c03\u7528\u5c31\u53ef\u4ee5\u4e86，\u7b2c\u4e8c\u4e2a\u53c2\u6570\u65f6\u6700\u5927\u7684\u8fde\u63a5\u6570<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 accpet\u7684\u5c01\u88c5\u9700\u8981\u6211\u4eec\u5c06\u7b49\u5230\u7684\u65b0\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u4f20\u51fa\u6240\u4ee5\u8fd4\u56de\u503c\u7c7b\u578b\u65f6int，\u6b64\u5916\u6211\u4eec\u8fd8\u9700\u8981\u5c06\u5ba2\u6237\u7aef\u7684port\u548cip\u4f20\u51fa，\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u4f20\u5740\u7684\u65b9\u5f0f\u5c06\u4ed6\u4eec\u4f20\u51fa，\u8fd9\u91cc\u4e5f\u9700\u8981\u6ce8\u610f\u4f20\u51fa\u6765\u7684ip\u9700\u8981\u5c06\u4e8c\u8fdb\u5236\u683c\u5f0f\u8f6c\u6210\u5b57\u7b26\u4e32\u683c\u5f0f，\u4f20\u51fa\u6765\u7684port\u9700\u8981\u5c06\u7f51\u7edc\u5b57\u8282\u5e8f\u8f6c\u6210\u4e3b\u673a\u5b57\u8282\u5e8f<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 connect\u6211\u4eec\u9700\u8981\u4f20\u5165\u9700\u8981\u8fde\u63a5\u670d\u52a1\u7aef\u7684ip\u5730\u5740\u548c\u7aef\u53e3\u53f7port，\u5e76\u8fd4\u56de\u8fde\u63a5\u6210\u529f\u8fd8\u662f\u5931\u8d25<\/p>\n
#pragma once<\/p>\n
#include <iostream>
\n#include <string>
\n#include <unistd.h>
\n#include <cstring>
\n#include <sys\/types.h>
\n#include <sys\/stat.h>
\n#include <sys\/socket.h>
\n#include <arpa\/inet.h>
\n#include <netinet\/in.h>
\n#include "Log.hpp"<\/p>\n
enum
\n{
\n SocketErr = 2,
\n BindErr,
\n ListenErr,
\n};<\/p>\n
\/\/ TODO
\nconst int backlog = 10;
\nLog lg;<\/p>\n
class Sock
\n{
\npublic:
\n Sock()
\n {
\n }
\n ~Sock()
\n {
\n }<\/p>\n
public:
\n void Socket()
\n {
\n sockfd_ = socket(AF_INET, SOCK_STREAM, 0);
\n if (sockfd_ < 0)
\n {
\n lg(Fatal, "socker error, %s: %d", strerror(errno), errno);
\n exit(SocketErr);
\n }
\n int opt = 1;
\n setsockopt(sockfd_, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt));
\n }
\n void Bind(uint16_t port)
\n {
\n struct sockaddr_in local;
\n memset(&local, 0, sizeof(local));
\n local.sin_family = AF_INET;
\n local.sin_port = htons(port);
\n local.sin_addr.s_addr = INADDR_ANY;<\/p>\n
if (bind(sockfd_, (struct sockaddr *)&local, sizeof(local)) < 0)
\n {
\n lg(Fatal, "bind error, %s: %d", strerror(errno), errno);
\n exit(BindErr);
\n }
\n }
\n void Listen()
\n {
\n if (listen(sockfd_, backlog) < 0)
\n {
\n lg(Fatal, "listen error, %s: %d", strerror(errno), errno);
\n exit(ListenErr);
\n }
\n }
\n int Accept(std::string *clientip, uint16_t *clientport)
\n {
\n struct sockaddr_in peer;
\n socklen_t len = sizeof(peer);
\n int newfd = accept(sockfd_, (struct sockaddr*)&peer, &len);
\n if(newfd < 0)
\n {
\n lg(Warning, "accept error, %s: %d", strerror(errno), errno);
\n return -1;
\n }
\n char ipstr[64];
\n inet_ntop(AF_INET, &peer.sin_addr, ipstr, sizeof(ipstr));
\n *clientip = ipstr;
\n *clientport = ntohs(peer.sin_port);<\/p>\n
return newfd;
\n }
\n bool Connect(const std::string &ip, const uint16_t &port)
\n {
\n struct sockaddr_in peer;
\n memset(&peer, 0, sizeof(peer));
\n peer.sin_family = AF_INET;
\n peer.sin_port = htons(port);
\n inet_pton(AF_INET, ip.c_str(), &(peer.sin_addr));<\/p>\n
int n = connect(sockfd_, (struct sockaddr*)&peer, sizeof(peer));
\n if(n == -1)
\n {
\n std::cerr << "connect to " << ip << ":" << port << " error" << std::endl;
\n return false;
\n }
\n return true;
\n }
\n void Close()
\n {
\n close(sockfd_);
\n }
\n int Fd()
\n {
\n return sockfd_;
\n }<\/p>\n
private:
\n int sockfd_;
\n};<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728epoll_server\u4e2d\u6211\u4eec\u9700\u8981\u4f7f\u7528socket\u548cepoll\u76f8\u5173\u63a5\u53e3，\u6240\u4ee5\u6211\u4eecepoll_server\u8fd9\u4e2a\u7c7b\u4e2d\u7684\u6210\u5458\u5c31\u6709\u8fd9\u4e24\u4e2a\u7c7b（\u56e0\u4e3a\u6211\u4eec\u5e76\u4e0d\u5e0c\u671b\u7c7b\u5916\u6709\u4eba\u8bbf\u95ee\u8fd9\u4e24\u4e2a\u7c7b，\u6240\u4ee5\u5c06\u8fd9\u4e24\u4e2a\u6210\u5458\u8bbe\u7f6e\u4e3a\u79c1\u6709\u7684）<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728\u8fd9\u4e2a\u7c7b\u4e2d\u9664\u4e86\u6784\u9020\u51fd\u6570\u548c\u6790\u6784\u51fd\u6570\u8fd9\u4e24\u4e2a\u5171\u6709\u51fd\u6570，\u8fd8\u989d\u5916\u63d0\u4f9binit\u548cstart\u8fd9\u4e24\u4e2a\u51fd\u6570，init\u4e3b\u8981\u5b8c\u6210\u5957\u63a5\u5b57\u7684\u521b\u5efa\u3001\u7ed1\u5b9a\u3001\u76d1\u542c，\u800cstart\u4e2d\u9996\u5148\u5c06\u76d1\u542c\u5957\u63a5\u5b57\u8bbe\u7f6e\u5230epoll\u7684\u5173\u5fc3\u4e8b\u4ef6\u4e2d，\u7136\u540e\u8fdb\u5165\u5faa\u73af\u4e0d\u65ad\u7684epoll_wait\u5e76\u5904\u7406\u6709\u54cd\u5e94\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26，\u5728\u5904\u7406\u4e2d\u6709\u5206\u4e3a\u8fde\u63a5\u4e8b\u4ef6\u548c\u8bfb\u53d6\u4e8b\u4ef6，\u8fd9\u91ccstart\u7684\u53c2\u6570\u662f\u6211\u5728\u6574\u5408\u4ee3\u7801\u7684\u65f6\u5019\u52a0\u5165\u7684\u76ee\u7684\u5176\u5b9e\u662f\u5728\u6709\u6570\u636e\u7684\u65f6\u5019\u5524\u9192\u6d88\u8d39\u7ebf\u7a0b（\u8fd9\u91cc\u5c31\u662f\u7ebf\u7a0b\u6c60）<\/p>\n
#pragma once
\n#include <iostream>
\n#include <memory>
\n#include <vector>
\n#include <string>
\n#include "epoll.hpp"
\n#include "Socket.hpp"
\n#include "task.hpp"
\n#include "many_thread.hpp"<\/p>\n
\/\/ std::vector<std::string> strs;<\/p>\n
const uint16_t default_port = 8888;
\nconst int max_event = 64;
\nconst int max_buffer = 1024;<\/p>\n
class epoll_server
\n{
\npublic:
\n epoll_server() :_listen_fd(new Sock),_epoll_fd(new Epoll){}
\n ~epoll_server(){}
\npublic:
\n void init(uint16_t port = default_port)
\n {
\n _listen_fd->Socket();
\n _listen_fd->Bind(port);
\n _listen_fd->Listen();
\n }
\n void start(zkj::many_pthreads* mp)
\n {
\n _epoll_fd->Epoll_Ctl(EPOLL_CTL_ADD,_listen_fd->Fd(),EPOLLIN);
\n for(;;)
\n {
\n struct epoll_event events[max_event];
\n int n = _epoll_fd->Epoll_Wait(events,max_event);
\n for(int i = 0;i<n;i++)
\n {
\n if(events[i].data.fd == _listen_fd->Fd())
\n {
\n \/\/\u5ba2\u6237\u7aef\u8bf7\u6c42\u8fde\u63a5\u4e8b\u4ef6
\n uint16_t client_port;
\n std::string client_ip;
\n int client_fd = _listen_fd->Accept(&client_ip,&client_port);
\n _epoll_fd->Epoll_Ctl(EPOLL_CTL_ADD,client_fd,EPOLLIN);
\n }
\n else{
\n char buffer[max_buffer];
\n memset(buffer,0,sizeof buffer);
\n int len = read(events[i].data.fd,buffer,sizeof buffer);
\n if(len < 0)
\n {
\n std::cout<<"read fail…"<<std::endl;
\n return ;
\n }
\n else if(len == 0)
\n {
\n std::cout<<"read content is 0…"<<std::endl;
\n _epoll_fd->Epoll_Ctl(EPOLL_CTL_DEL,events[i].data.fd,0);
\n }
\n else{
\n \/\/ std::cout<<"client talk#"<<buffer<<std::endl;
\n \/\/\u5c06\u4ece\u5ba2\u6237\u7aef\u83b7\u53d6\u7684\u6570\u636e\u5b58\u50a8\u5230tasks\u4e2d
\n std::string buf_str = buffer;
\n \/\/ std::cout<<buf_str\/*<<std::endl*\/;
\n tasks.push_back(buf_str);
\n mp->Cond_Signal();
\n }
\n }
\n }
\n }
\n }
\nprivate:
\n std::shared_ptr<Sock> _listen_fd;
\n std::shared_ptr<Epoll> _epoll_fd;
\n};<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u8fd9\u4e2a\u5c31\u6bd4\u8f83\u7b80\u5355，\u5c31\u662f\u521b\u5efa\u6570\u636e\u5e93\u3001\u8fde\u63a5\u6570\u636e\u5e93\u3001\u5411\u6570\u636e\u5e93\u8f93\u5165\u8bed\u53e5\u8fd9\u4e09\u4e2a\u63a5\u53e3<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5982\u679c\u4f60\u4eec\u7684\u6570\u636e\u5e93\u7aef\u53e3\u53f7\u6ca1\u6709\u6539\u8fc7，\u5728\u521b\u5efa\u81ea\u5df1\u7684\u7528\u6237\u5e76\u8bbe\u7f6e\u5bc6\u7801\u5c31\u53ef\u4ee5\u4f7f\u7528\u4e86<\/p>\n
#pragma once
\n#include <iostream>
\n#include <string>
\n#include <unistd.h>
\n#include <mysql\/mysql.h>
\n#include "task.hpp"<\/p>\n
namespace zkj
\n{
\n const std::string host = "localhost";
\n const std::string user = "zkj";
\n const std::string passwd = "123456";
\n const std::string db = "text1";
\n const unsigned int port = 3306;<\/p>\n
class Mysql_Class
\n {
\n public:
\n Mysql_Class() : my(mysql_init(nullptr)) {}
\n ~Mysql_Class() { mysql_close(my); }<\/p>\n
public:
\n void Mysql_Real_Connect()
\n {
\n if (my == nullptr)
\n {
\n std::cout << "mysql init fail…" << std::endl;
\n return;
\n }
\n if (mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
\n {
\n std::cerr << "connect MYSQL error" << std::endl;
\n return;
\n }
\n }
\n void Mysql_Query(const std::string &sqlstr)
\n {
\n int n = mysql_query(my, sqlstr.c_str());
\n if (n == 0)
\n std::cout << sqlstr << " success" << std::endl;
\n else
\n std::cout << sqlstr << " fail" << std::endl;
\n }
\n private:
\n MYSQL *my;
\n };
\n}<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 task\u5185\u7684\u63a5\u53e3\u5305\u62ec\u89e3\u6790\u83b7\u5f97\u7684\u5b57\u7b26\u4e32，\u5e76\u5c06\u89e3\u6790\u5f97\u5230\u7684\u5c5e\u6027\u7ec4\u7ec7\u6210sql\u8bed\u53e5\u5e76\u8fd4\u56de，\u7528\u5230\u7684\u64cd\u4f5c\u5c31\u662fsubstr\u548cfind<\/p>\n
#pragma once
\n#include <iostream>
\n#include <vector><\/p>\n
namespace zkj{
\n class task{
\n public:
\n task(){}
\n ~task(){}
\n public:
\n task(const std::string &str) :_taskstr(str){}
\n void Analysis_Str()
\n {
\n \/\/1 zhangsan 99 99 99 str\u7684\u683c\u5f0f
\n auto pos = _taskstr.find(" ");
\n id = std::stoi(_taskstr.substr(0,pos));
\n auto pos2 = _taskstr.find(" ",pos+1);
\n name = _taskstr.substr(pos+1,pos2-pos-1);
\n auto pos3 = _taskstr.find(" ",pos2+1);
\n chinese = std::stoi(_taskstr.substr(pos2+1,pos3-pos2-1));
\n auto pos4 = _taskstr.find(" ",pos3+1);
\n math = std::stoi(_taskstr.substr(pos3+1,pos4-pos3-1));
\n auto pos5 = _taskstr.find(" ",pos4+1);
\n englisg = std::stoi(_taskstr.substr(pos4+1));
\n \/\/"insert into exam_result values (11,'zhangsan',8,9,8)" \u8fd9\u662f\u5411\u6570\u636e\u5e93\u63d2\u5165\u7684\u8bed\u53e5
\n sql_insert_str = "insert into exam_result values (" + std::to_string(id) + "," + "'"+ name + "'" +"," +std::to_string(chinese)+ "," +std::to_string(math)+ "," +std::to_string(englisg)+")";
\n }
\n void Print_Analysis_Str()
\n {std::cout<<sql_insert_str<<std::endl;}<\/p>\n
std::string Ret_Sql_str()
\n {return sql_insert_str;}
\n private:
\n std::string _taskstr;
\n int id;
\n std::string name;
\n int chinese;
\n int math;
\n int englisg;
\n std::string sql_insert_str;
\n };
\n}<\/p>\n
extern std::vector<zkj::task> tasks;<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728\u7ebf\u7a0b\u6c60\u4e2d\u6211\u8bbe\u8ba1\u7684\u7c7b\u5185\u6210\u5458\u6709mutex\u3001cond（\u6761\u4ef6\u53d8\u91cf）\u3001sql\u3001\u4ee5\u53ca\u7528vector\u7ec4\u7ec7\u7684\u7ebf\u7a0b\u5c5e\u6027pthreads<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u7ebf\u7a0b\u7684\u5c5e\u6027\u901a\u8fc7pthread_info\u6765\u8bb0\u5f55<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0\u5728\u7ebf\u7a0b\u6c60\u7684\u6784\u9020\u51fd\u6570\u4e2d\u5b8c\u6210_pthread\u548csql\u7684\u521d\u59cb\u5316，\u901a\u8fc7new\u4e3a\u8fd9\u4e24\u4e2a\u667a\u80fd\u6307\u9488\u521d\u59cb\u5316，\u5e76\u5b8c\u6210mutex\u548ccond\u7684\u521d\u59cb\u5316\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5bf9\u4e8emutex\u548ccond\u7684\u76f8\u5173\u63a5\u53e3\u6211\u90fd\u8fdb\u884c\u4e86\u5c01\u88c5\u4ee5\u65b9\u4fbf\u540e\u7eed\u7684\u8c03\u7528<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5728start\u4e2d\u4e3b\u8981\u4efb\u52a1\u5c31\u662f\u521b\u5efa\u4e00\u6279\u7ebf\u7a0b，\u6bcf\u4e2a\u7ebf\u7a0b\u7684\u4efb\u52a1\u90fd\u662f\u5224\u65ad\u6709\u6ca1\u6709\u5185\u5bb9\u9700\u8981\u5904\u7406，\u5982\u679c\u6709\u5c31\u5904\u7406，\u6ca1\u6709\u5c31\u7b49\u5f85\u5e76\u91ca\u653e\u9501\u3002<\/p>\n
#pragma once
\n#include <iostream>
\n#include <string>
\n#include <vector>
\n#include <map>
\n#include <memory>
\n#include <pthread.h>
\n#include <unistd.h>
\n#include "task.hpp"
\n#include "mysql.hpp"<\/p>\n
namespace zkj
\n{
\n#define PTHREAD_MAX 10
\n#define START_FLAG true
\n#define PRODUCE_THREAD true
\n#define MAX_STR 100000<\/p>\n
struct pthread_info
\n {
\n pthread_info(){}
\n pthread_info(pthread_t thread_id) : _thread_id(thread_id) {
\n std::string name = "thread – " + std::to_string(thread_id);
\n _thread_name = name;
\n }
\n pthread_t _thread_id;
\n std::string _thread_name;
\n };<\/p>\n
class many_pthreads
\n {
\n public:
\n many_pthreads() :sql(new zkj::Mysql_Class())
\n {
\n sql->Mysql_Real_Connect();
\n _pthreads.resize(PTHREAD_MAX);
\n pthread_mutex_init(&_mutex, nullptr);
\n pthread_cond_init(&_cond, nullptr);
\n }
\n ~many_pthreads()
\n {
\n pthread_mutex_destroy(&_mutex);
\n pthread_cond_destroy(&_cond);
\n for(int i = 0;i<PTHREAD_MAX;i++)
\n pthread_join(_pthreads[i]._thread_id,nullptr);
\n }<\/p>\n
public:
\n void Lock() { pthread_mutex_lock(&_mutex); }
\n void UnLock() { pthread_mutex_unlock(&_mutex); }
\n void Cond_Wait() { pthread_cond_wait(&_cond, &_mutex); }
\n void Cond_Signal() { pthread_cond_signal(&_cond); }
\n bool empty() { return tasks.empty(); }
\n void Push_Task(std::string str) { tasks.push_back(str); }
\n int Get_Pthread_id(pthread_t pid)
\n {
\n for (int i = 0; i < PTHREAD_MAX; i++)
\n {
\n if (_pthreads[i]._thread_id == pid)
\n return i;
\n }
\n return -1;
\n }
\n zkj::task Get_Task_Front()
\n {
\n zkj::task ret = tasks.front();
\n tasks.erase(tasks.begin());
\n return ret;
\n }
\n std::shared_ptr<zkj::Mysql_Class>& Get_Sql_ptr()
\n {return sql;}
\n public:
\n static void *thread_test(void *argc)
\n {
\n many_pthreads *pthreads = static_cast<many_pthreads *>(argc);
\n while (1)
\n {
\n pthreads->Lock();
\n while (pthreads->empty())
\n {
\n pthreads->Cond_Wait();
\n }
\n zkj::task client_I = pthreads->Get_Task_Front();
\n \/\/ std::cout << "pthread_t : " << pthreads->Get_Pthread_id(pthread_self()) << "server say -> " << client_I << std::endl;
\n client_I.Analysis_Str();
\n client_I.Print_Analysis_Str();
\n pthreads->Get_Sql_ptr()->Mysql_Query(client_I.Ret_Sql_str());
\n pthreads->UnLock();
\n sleep(1);
\n }
\n }
\n void start()
\n {
\n std::cout<<"GDB–"<<"many thread stary chenge"<<std::endl;
\n for (int i = 0; i < PTHREAD_MAX; i++)
\n {
\n pthread_t t;
\n pthread_info t_info(t);
\n _pthreads[i] = t_info;
\n pthread_create(&t, nullptr, thread_test, this);
\n }
\n }<\/p>\n
private:
\n std::vector<pthread_info> _pthreads;
\n \/\/ std::vector<std::string> tasks;
\n std::shared_ptr<zkj::Mysql_Class> sql;
\n pthread_cond_t _cond;
\n pthread_mutex_t _mutex;
\n };<\/p>\n
}<\/p>\n
#include <pthread.h>
\n#include "epoll_server.hpp"
\n#include "many_thread.hpp"<\/p>\n
std::vector<zkj::task> tasks;<\/p>\n
void *Server_Thread(void *argc)
\n{
\n \/\/ std::cout<<"GDB–"<<"epoll server create \u6210\u529f"<<std::endl;
\n zkj::many_pthreads* mp = static_cast<zkj::many_pthreads*>(argc);
\n std::shared_ptr<epoll_server> ev(new epoll_server());
\n ev->init();
\n ev->start(mp);
\n}<\/p>\n
void *Many_Thread(void* argc)
\n{
\n \/\/ std::shared_ptr<zkj::many_pthreads> mp(new zkj::many_pthreads());
\n zkj::many_pthreads* mp = static_cast<zkj::many_pthreads*>(argc);
\n mp->start();
\n}<\/p>\n
int main()
\n{
\n zkj::many_pthreads mp;
\n pthread_t server_id;
\n pthread_create(&server_id,nullptr,Server_Thread,&mp);
\n pthread_t many_threads_id;
\n pthread_create(&many_threads_id,nullptr,Many_Thread,&mp);
\n pthread_join(server_id,nullptr);
\n pthread_join(many_threads_id,nullptr);
\n return 0;
\n}<\/p>\n
<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5230\u8fd9\u91cc\u6574\u4e2a\u5c0f\u9879\u76ee\u5c31\u7ed3\u675f\u4e86，\u603b\u4f53\u6765\u8bf4\u96be\u5ea6\u4e0d\u5927，\u7528\u5230\u7684\u4e1c\u897f\u6bd4\u8f83\u591a，\u73af\u5883\u65b9\u9762\u53ef\u80fd\u914d\u7f6e\u6bd4\u8f83\u9ebb\u70e6\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1k\u6b21\uff0c\u70b9\u8d5e23\u6b21\uff0c\u6536\u85cf10\u6b21\u3002\u672c\u6587\u4ecb\u7ecd\u4e86\u4e00\u4e2a\u57fa\u4e8eC++\u7684\u670d\u52a1\u5668\u5f00\u53d1\u9879\u76ee\uff0c\u91c7\u7528epoll\u5904\u7406\u5ba2\u6237\u7aef\u8bf7\u6c42\uff0c\u591a\u7ebf\u7a0b\u5904\u7406\u6570\u636e\u5e76\u5b58\u50a8\u5230MySQL\u6570\u636e\u5e93\u3002\u9879\u76ee\u4f7f\u7528socket\u7f51\u7edc\u7f16\u7a0b\u3001epoll I\/O\u591a\u8def\u590d\u7528\u3001\u591a\u7ebf\u7a0b\u540c\u6b65\u7b49\u6280\u672f\uff0c\u5f00\u53d1\u73af\u5883\u4e3aUbuntu 20.04\/C++11\/MySQL5.7\u3002\u4e3b\u8981\u6a21\u5757\u5305\u62ec\uff1a1) \u5c01\u88c5epoll\u63a5\u53e3\u5b9e\u73b0\u4e8b\u4ef6\u9a71\u52a8\uff1b2) \u5c01\u88c5socket\u63a5\u53e3\u5904\u7406\u7f51\u7edc\u901a\u4fe1\uff1b3) \u8bbe\u8ba1epoll\u670d\u52a1\u5668\u6838\u5fc3\u903b\u8f91\uff1b4) \u5b9e\u73b0\u7ebf\u7a0b\u6c60\u5904\u7406\u4efb\u52a1\u961f\u5217\uff1b5) \u5c01\u88c5MySQL\u63a5\u53e3\u8fdb\u884c\u6570\u636e\u5b58\u50a8\u3002\u9879\u76ee\u901a\u8fc7\u6761\u4ef6\u53d8\u91cf\u5b9e\u73b0\u7ebf\u7a0b\u540c\u6b65\uff0c\u4f7f\u7528\u667a\u80fd\u6307\u9488\u7ba1\u7406\u8d44\u6e90\uff0c\u6700\u7ec8\u6784\u5efa\u4e86<\/p>\n","protected":false},"author":2,"featured_media":48779,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,58,205,43,78,191],"topic":[],"class_list":["post-48781","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-c","tag-linux","tag-tcp-ip","tag-43","tag-78","tag-191"],"yoast_head":"\n