这篇文章主要介绍“如何用C++实现简单图书馆管理系统”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“如何用C++实现简单图书馆管理系统”文章能帮助大家解决问题。
功能如下：
1，添加书籍
2，删除书籍（可删除还没外借的书籍）
3，读者借书
4，读者还书
5，按书籍登入号查看信息（每一本书的书籍登入号唯一，如有5本相同书名作者的书，那就有5个不同的书籍登入号）
6，查询所有图书信息（可以直接查看到同本书在图书馆中的剩余和借出情况）
7，查看指定读者的借书详情
8，注册新读者
9，查看所有书籍信息（可以详细到每个登入号和此登入号书籍的借阅情况：如谁借的，借阅日期）
采用客户端和服务器模式，服务器端接收客户端，一旦接收到便启用线程，然后相应来自此客户端的不同请求
server端
serverHead.h
#ifndef SERVERHEAD#define SERVERHEAD#include <iostream>#include <string>#include <cstdlib>#include <list>#include <iterator>#include <fstream>#include <cstring>#include <thread>#include<WINSOCK2.H> #include <mysql.h>#pragma comment(lib,"ws2_32.lib")struct infoData{ int flag; //各种命令 int borFlag; //借阅情况1表示借出，0表示未出借 char enterName[20]; //书籍登入号，一本份 char bookName[50]; //书籍名 char bookNum[20]; //书编号 char bookWriter[50]; //书作者 int remainBook; //最初设置的库存 char readerName[50]; //借书者 char readerNum[50]; //借书证 char borrowTime[30]; //借书时间 int remain; //库中还剩此书数量 int lend; //从库中借出的此书数量};class Book_mysql{public: Book_mysql(); bool connectAndCreate(); //链接创建数据库和表 bool selectWhetherEmpty(); //检测是否为空表 bool testTheBookWhetherExist(const infoData& Data); //判断书籍存在 bool insertTo(infoData & Data); //插入书籍 int deleteFrom(infoData & Data); //删除相应书籍 bool readerBorrowBook(infoData & Data); //读者借书 int readerReturnBook(infoData & Data); //还书 bool whetherSurpass(infoData & Data); //判断是否超过借书上限（上限一本书最多借两本） bool selectBookByEntername(infoData & Data); //通过书籍登入号查询书籍 void displayInformation(infoData & Data, const SOCKET& sClient);//打印（笼统） void showTheReaderBook(infoData & Data, SOCKET & sClient);//打印指定读者借书情况 void DISPLAY(infoData & Data, SOCKET& sClient); //打印（详细）private: char user[30]; //登陆名字 char pswd[10]; //密码 char host[20]; //表示本地数据库 unsigned int port; //端口 MYSQL myCont; MYSQL_RES *result; MYSQL_ROW sql_row; int res;};class Reader_mysql{public: Reader_mysql(); bool connectAndCreate(); bool testTheReaderWhetherExist(infoData & Data);//检测该读者是否已经存在 void insertTo(infoData & Data); //注册 bool readerBorrowBook(); //借书 bool readerReturnBook(); //还书private: char user[30]; //登陆名字 char pswd[10]; //密码 char host[20]; //表示本地数据库 unsigned int port; MYSQL myCont; MYSQL_RES *result; MYSQL_ROW sql_row; int res;};class serverSocket{public: serverSocket(int port); ~serverSocket(); SOCKET serverAccpetSocket();//阻塞acceptprivate: WSADATA wsd; SOCKET sServer; //客户端套接字 用来监听 std::list<SOCKET> listScli; //客户端套接字 用链表来接收，接送一个放一个 SOCKET temp; //用来存放中间值 SOCKADDR_IN addrServ; //服务器地址};void addBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql);void deleteBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql);void borrowBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql, Reader_mysql & reader_mysql);void returnBook(infoData& Data, SOCKET& sClient, Book_mysql & book_mysql, Reader_mysql & reader_mysql);void searchBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql);void displayAllBook(infoData& Data, SOCKET& sClient, Book_mysql & book_mysql);void DISPLAY(infoData& Data, SOCKET& sClient, Book_mysql & book_mysql);void showTheReaderBook(infoData & Data, SOCKET & sClient, Book_mysql & book_mysql, Reader_mysql & reader_mysql);void setNewReader(infoData & Data, const SOCKET & sClient, Reader_mysql & reader_mysql);void clientSocketThreadFunction(SOCKET sClient);#endif套接字类的实现
serverSocket.cpp
#include "serverHead.h"serverSocket::serverSocket(int port){ //初始化套结字动态库 if (WSAStartup(MAKEWORD(2, 2), &wsd) != 0) { std::cout << "WSAStartup failed!" << std::endl; return; } //开始创建服务端socket //创建套接字 AF_INET：ipv4 SOCK_STREAM：使用tcp sServer = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (INVALID_SOCKET == sServer) { std::cout << "socket failed!" << std::endl; return; } //服务器套接字地址 addrServ.sin_family = AF_INET;//IPv4 addrServ.sin_port = htons(port);//设置端口 建议大于1024 addrServ.sin_addr.s_addr = INADDR_ANY; //表示接受任何客户端的请求 //绑定套接字 绑定服务端socket 和 端口 int ret = bind(sServer, (LPSOCKADDR)&addrServ, sizeof(SOCKADDR_IN)); if (SOCKET_ERROR == ret) { std::cout << "bind failed!" << std::endl; return; } //开始监听 ret = listen(sServer, 10); if (SOCKET_ERROR == ret) { std::cout << "listen failed!" << std::endl; return; }}serverSocket::~serverSocket(){ closesocket(sServer); //关闭套接字 WSACleanup(); //释放套接字资源; }SOCKET serverSocket::serverAccpetSocket(){ //接受客户端请求 sockaddr_in addrClient; int addrClientlen = sizeof(addrClient); temp = accept(sServer, (sockaddr FAR*)&addrClient, &addrClientlen); if (INVALID_SOCKET == temp) { std::cout << "accept failed!" << std::endl; return -1; } listScli.push_front(temp); return temp;}MySQL中书籍表的实现
bookMysql.cpp
#include "serverHead.h"Book_mysql::Book_mysql(){ strcpy_s(user, "root"); strcpy_s(pswd, "123456"); strcpy_s(host, "localhost"); port = 3306; mysql_init(&myCont); if (mysql_real_connect(&myCont, host, user, pswd, "mysql", port, NULL, 0))//先链接自带的数据库，以便后面创建专属数据库 { res = mysql_query(&myCont, "create database if not exists zhanghsun"); mysql_query(&myCont, "SET NAMES GBK"); if (res) { std::cout << "创建库失败" << std::endl; system("pause"); exit(-1);; } res = mysql_query(&myCont, "use zhanghsun"); if (res) { std::cout << "use 失败" << std::endl; system("pause"); exit(-1); } char order[1024]; sprintf_s(order, "create table IF NOT EXISTS m_book(书籍登入号 char(10) not null, 书名 char(20) default null, 书编号 char(20) default null, 书作者 char(50) default null, 借阅 int default 0, 读者名 char(20) default '%s', 读者借书号 char(20) default '%s', 借阅时间 char(20) default '%s')", "无", "无", "无"); res = mysql_query(&myCont, order); if (res) { std::cout << "创建表失败" << std::endl; system("pause"); exit(-1); } } else { std::cout << "链接失败" << std::endl; system("pause"); exit(-1); }}//判断指定书籍是否存在bool Book_mysql::testTheBookWhetherExist(const infoData& Data){ char order[1024]; //检测是否存在该书 sprintf_s(order, "SELECT * FROM m_book WHERE 书名='%s' and 书作者 = '%s'", Data.bookName, Data.bookWriter); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { if (sql_row = mysql_fetch_row(result))//如果查询不为空 { return 1;//已有该书 } } } else { std::cout << "查询失败" << std::endl; system("pause"); exit(-1); } return 0;//没有该书 }//插入书籍操作bool Book_mysql::insertTo(infoData & Data){ char order[1024]; sprintf_s(order, "insert into m_book (书籍登入号,书名,书编号,书作者) values('%s','%s','%s','%s')", Data.enterName,Data.bookName, Data.bookNum, Data.bookWriter); res = mysql_query(&myCont, order); if (res) { std::cout << "插入失败" << std::endl; system("pause"); exit(-1); } return 1;}//判断表是否为空bool Book_mysql::selectWhetherEmpty(){ char order[1024]; sprintf_s(order, "SELECT * FROM m_book"); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { if (sql_row = mysql_fetch_row(result))//获取具体的数据 { return 0;//表不为空 } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } return 1;//表为空}//判断该读者要借书籍是否超出上限bool Book_mysql::whetherSurpass(infoData & Data){ char order[1024]; int num = 0; sprintf_s(order, "select 读者名,读者借书号 from m_book where 书名 = '%s' and 书作者 = '%s'", Data.bookName, Data.bookWriter); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { while (sql_row = mysql_fetch_row(result))//获取具体的数据 { if (strcmp(Data.readerName, sql_row[0]) == 0 && strcmp(Data.readerNum, sql_row[1]) == 0) { ++num; } if (num >= 2) { return 1;//已达上限 } } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } return 0;//没超}//删除书籍int Book_mysql::deleteFrom(infoData & Data){ char order[1024]; int flag = 0; sprintf_s(order, "SELECT * FROM m_book WHERE 书名='%s' AND 书作者 = '%s' AND 借阅 = '%d'", Data.bookName, Data.bookWriter, 0); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { while (sql_row = mysql_fetch_row(result))//获取具体的数据 { flag = 1; std::cout << "删除登入号:" << sql_row[0] << std::endl; //根据得到的登入号一一删除 sprintf_s(order, "DELETE FROM m_book WHERE 书籍登入号 = '%s'", sql_row[0]); res = mysql_query(&myCont, order); if (res) { std::cout << "删除failed" << std::endl; system("pause"); exit(-1); } } if (flag == 0) { return -1;//全借出 } else if (flag == 1) { return 1;//删除了相关书籍 } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); }}//读者借阅书籍bool Book_mysql::readerBorrowBook(infoData & Data){ char order[1024]; sprintf_s(order, "SELECT 书籍登入号 FROM m_book WHERE 书名='%s' AND 书作者 = '%s' AND 借阅 = '%d'", Data.bookName, Data.bookWriter, 0); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { if(sql_row = mysql_fetch_row(result))//获取具体的数据 { std::cout << "借的书的登入号:" << sql_row[0] << std::endl; sprintf_s(order, "UPDATE m_book SET 借阅 = '%d',读者名 = '%s',读者借书号 = '%s', 借阅时间 = NOW() WHERE 书籍登入号 = '%s'", 1, Data.readerName,Data.readerNum, sql_row[0]); res = mysql_query(&myCont, order); if (res) { std::cout << "更新failed" << std::endl; system("pause"); exit(-1); } } else { return 0;//书全借光 } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } return 1;//借书成功}//还书int Book_mysql::readerReturnBook(infoData & Data){ char order[1024]; sprintf_s(order, "SELECT * FROM m_book WHERE 书籍登入号='%s'", Data.enterName); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { if (sql_row = mysql_fetch_row(result))//获取具体的数据 { std::cout << "登入号:" << sql_row[0] << std::endl; sprintf_s(order, "UPDATE m_book SET 借阅 = 0, 读者名 = '%s', 读者借书号 = '%s', 借阅时间 = '%s' WHERE 书籍登入号 = '%s'","无", "无", "无", Data.enterName); res = mysql_query(&myCont, order); if (res) { std::cout << "更新failed" << std::endl; system("pause"); exit(-1); } } else { return 0;//没找到该登入号 } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } return 1;//成功}//更具书籍登入号查询书籍信息bool Book_mysql::selectBookByEntername(infoData & Data){ char order[1024]; int flag = 0; sprintf_s(order, "SELECT * FROM m_book WHERE 书籍登入号='%s'", Data.enterName); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { if(sql_row = mysql_fetch_row(result))//获取具体的数据 { flag = 1; strcpy_s(Data.enterName, sql_row[0]); strcpy_s(Data.bookName, sql_row[1]); strcpy_s(Data.bookNum, sql_row[2]); strcpy_s(Data.bookWriter, sql_row[3]); if (atoi(sql_row[4]) == 1) { Data.borFlag = 1; strcpy_s(Data.readerName, sql_row[5]); strcpy_s(Data.readerNum, sql_row[6]); strcpy_s(Data.borrowTime, sql_row[7]); } else { Data.borFlag = 0; } } if (flag == 0) { return 0;//登入号没找到 } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } return 1;}//笼统打印void Book_mysql::displayInformation(infoData & Data, const SOCKET& sClient){ char order[1024]; char tempName[30]; char tempWriter[30]; int lend = 0; int remain = 0; sprintf_s(order, "SELECT 书名,书编号,书作者 FROM m_book"); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { while (sql_row = mysql_fetch_row(result))//获取具体的数据 { strcpy_s(Data.bookName, sql_row[0]); strcpy_s(Data.bookNum, sql_row[1]); strcpy_s(Data.bookWriter, sql_row[2]); if (strcmp(Data.bookName, tempName) == 0 && strcmp(Data.bookWriter, tempWriter) == 0)//相同书籍不予计算 { continue; } lend = 0; remain = 0; char _order[1024];//已借书情况 sprintf_s(_order, "SELECT count(*) FROM m_book where 书名= '%s' and 书作者 = '%s' and 借阅 = 1", Data.bookName, Data.bookWriter); res = mysql_query(&myCont, _order); if (!res) { MYSQL_RES *_result = mysql_store_result(&myCont); if (_result) { MYSQL_ROW _sql_row; while (_sql_row = mysql_fetch_row(_result))//获取具体的数据 { lend = atoi(_sql_row[0]); } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } //剩余没借情况 sprintf_s(_order, "SELECT count(*) FROM m_book where 书名= '%s' and 书作者 = '%s' and 借阅 = 0", Data.bookName, Data.bookWriter); res = mysql_query(&myCont, _order); if (!res) { MYSQL_RES *_result = mysql_store_result(&myCont); if (_result) { MYSQL_ROW _sql_row; while (_sql_row = mysql_fetch_row(_result))//获取具体的数据 { remain = atoi(_sql_row[0]); } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } Data.lend = lend; Data.remain = remain; if (strcmp(Data.bookName, tempName) != 0 && strcmp(Data.bookWriter, tempWriter) != 0) { Data.flag = 0; send(sClient, (char*)&Data, sizeof(Data), 0); } strcpy_s(tempName, Data.bookName); strcpy_s(tempWriter, Data.bookWriter); } } } else { std::cout << "查询failed" << std::endl; system("pause"); exit(-1); } Data.flag = 1; send(sClient, (char*)&Data, sizeof(Data), 0);}//打印指定读者借书情况void Book_mysql::showTheReaderBook(infoData & Data, SOCKET & sClient){ char order[1024]; int flag = 0; sprintf_s(order, "select 书籍登入号,书名,书编号,书作者,借阅时间 from m_book where 读者名 = '%s' and 读者借书号 = '%s';", Data.readerName, Data.readerNum); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { while (sql_row = mysql_fetch_row(result))//如果查询不为空 { flag = 1; strcpy_s(Data.enterName, sql_row[0]); strcpy_s(Data.bookName, sql_row[1]); strcpy_s(Data.bookNum, sql_row[2]); strcpy_s(Data.bookWriter, sql_row[3]); strcpy_s(Data.borrowTime, sql_row[4]); Data.flag = 6; send(sClient, (char*)&Data, sizeof(Data), 0); } } } else { std::cout << "查询失败" << std::endl; system("pause"); exit(-1); } if (flag == 0) { Data.flag = 0;//没有借书 send(sClient, (char*)&Data, sizeof(Data), 0); } Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0);}//打印（详细）void Book_mysql::DISPLAY(infoData & Data, SOCKET& sClient){ char order[1024]; int flag = 0; int i = 0; sprintf_s(order, "select * from m_book"); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { while (sql_row = mysql_fetch_row(result))//如果查询不为空 { flag = 1; strcpy_s(Data.enterName, sql_row[0]); strcpy_s(Data.bookName, sql_row[1]); strcpy_s(Data.bookNum, sql_row[2]); strcpy_s(Data.bookWriter, sql_row[3]); if (atoi(sql_row[4]) == 1) { Data.borFlag = 1; strcpy_s(Data.readerName, sql_row[5]); strcpy_s(Data.readerNum, sql_row[6]); strcpy_s(Data.borrowTime, sql_row[7]); } else { Data.borFlag = 0; } Data.flag = 6; send(sClient, (char*)&Data, sizeof(Data), 0); } } if (flag == 0)//没有结果 { Data.flag = -2; send(sClient, (char*)&Data, sizeof(Data), 0); } } Data.flag = -1;//打印退出flag send(sClient, (char*)&Data, sizeof(Data), 0);}MySQL读者表的实现
readerMysql.cpp
#include "serverHead.h"Reader_mysql::Reader_mysql(){ strcpy_s(user, "root"); strcpy_s(pswd, "123456"); strcpy_s(host, "localhost"); port = 3306; mysql_init(&myCont); if (mysql_real_connect(&myCont, host, user, pswd, "mysql", port, NULL, 0)) { res = mysql_query(&myCont, "create database if not exists zhanghsun"); mysql_query(&myCont, "SET NAMES GBK"); if (res) { std::cout << "创建库失败" << std::endl; system("pause"); exit(-1); } res = mysql_query(&myCont, "use zhanghsun"); if (res) { std::cout << "use 失败" << std::endl; system("pause"); exit(-1); } char order[1024]; sprintf_s(order, "create table IF NOT EXISTS m_reader(读者名 char(20) default null, 读者借书号 char(20) default null)"); res = mysql_query(&myCont, order); if (res) { std::cout << "创建表failed" << std::endl; system("pause"); exit(-1); } } else { std::cout << "链接失败" << std::endl; system("pause"); exit(-1); }}//判断是否重复注册bool Reader_mysql::testTheReaderWhetherExist(infoData & Data){ char order[1024]; sprintf_s(order, "select * from m_reader where 读者名 = '%s' and 读者借书号 = '%s'", Data.readerName, Data.readerNum); res = mysql_query(&myCont, order); if (!res) { result = mysql_store_result(&myCont); if (result) { if (sql_row = mysql_fetch_row(result))//如果查询不为空 { return 1;//有该读者 } } } else { std::cout << "查询失败" << std::endl; system("pause"); exit(-1); } return 0;//没有此人 }//插入新读者void Reader_mysql::insertTo(infoData & Data){ char order[102]; sprintf_s(order, "insert into m_reader (读者名, 读者借书号) values('%s','%s')", Data.readerName, Data.readerNum); res = mysql_query(&myCont, order); if (res) { std::cout << "插入失败" << std::endl; system("pause"); exit(-1); } //else 注册成功}服务器端总实现
server.cpp
#include "serverHead.h"//增加书籍void addBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql){ std::cout << "客户端 " << sClient << " 正在录入书籍 !" << std::endl; if (book_mysql.testTheBookWhetherExist(Data))//数据库中判断该书是否已经存在 { std::cout << "客户端" << sClient << " 添加书籍重复已退回" << std::endl; Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); return; } //按库存随机每本书的登入号并插入 srand((unsigned)time(NULL));//通过时间来随机登入号 for (int i = 0; i < Data.remainBook; i++) { int x = rand() % 1000; _itoa_s(x, Data.enterName, 10); book_mysql.insertTo(Data);//在数据库中插入 } Data.flag = 0; send(sClient, (char*)&Data, sizeof(Data), 0); std::cout << "客户端 " << sClient << " 录入书籍成功 !" << std::endl;}//删除书籍void deleteBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql){ std::cout << "客户端 " << sClient << " 正在删除书籍" << std::endl; int flag = 0; if (!(book_mysql.testTheBookWhetherExist(Data)))//首先判断该书是否存在 { std::cout << "没有该书" << std::endl; Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); return; } //删除 switch (book_mysql.deleteFrom(Data)) { case -1: Data.flag = -2; send(sClient, (char*)&Data, sizeof(Data), 0); std::cout << "该书全部出借，无法进行删除" << std::endl; break; case 1: Data.flag = 0; send(sClient, (char*)&Data, sizeof(Data), 0); std::cout << "已删除此书的所有未出借书籍" << std::endl; break; }}//借阅书籍void borrowBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql, Reader_mysql & reader_mysql){ std::cout << "客户端 " << sClient << " 正在借阅书籍" << std::endl; //判断该读者是否存在 switch (reader_mysql.testTheReaderWhetherExist(Data)) { case 0:Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); return;//没有找到该读者，直接return case 1:Data.flag = 0; send(sClient, (char*)&Data, sizeof(Data), 0); break;//找到该读者，继续操作 } recv(sClient, (char*)&Data, sizeof(Data), 0); if (book_mysql.selectWhetherEmpty()) { std::cout << "未录入任何书籍" << std::endl; Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); return; } if (!(book_mysql.testTheBookWhetherExist(Data))) { Data.flag = -2; std::cout << "没有这本书" << std::endl; send(sClient, (char*)&Data, sizeof(Data), 0); return; } //判断是否多借 if (!(book_mysql.whetherSurpass(Data))) { switch (book_mysql.readerBorrowBook(Data)) { case 1:Data.flag = 0; break;//借书成功 case 0:Data.flag = -3; break;//书全借光 } } else { Data.flag = -4;//借此书已达上限 } send(sClient, (char*)&Data, sizeof(Data), 0);}//归还书籍void returnBook(infoData& Data, SOCKET& sClient, Book_mysql & book_mysql, Reader_mysql & reader_mysql){ std::cout << "客户端 " << sClient << " 正在归还书籍" << std::endl; showTheReaderBook(Data, sClient, book_mysql, reader_mysql); recv(sClient, (char*)&Data, sizeof(Data), 0); switch (book_mysql.readerReturnBook(Data)) { case 0:std::cout << "没有找到该登入号" << std::endl; Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); break; case 1:std::cout << "还书成功" << std::endl; Data.flag = 0; send(sClient, (char*)&Data, sizeof(Data), 0); break; }}//通过登入号搜索书籍void searchBook(infoData& Data, const SOCKET& sClient, Book_mysql & book_mysql){ std::cout << "客户端 " << sClient << " 正在通过登入号搜索书籍" << std::endl; switch(book_mysql.selectBookByEntername(Data)) { case 1:send(sClient, (char*)&Data, sizeof(Data), 0);return; case 0:Data.flag = 3; send(sClient, (char*)&Data, sizeof(Data), 0); return; }}//打印书籍（笼统打印，不打印登入号）void displayAllBook(infoData& Data, SOCKET& sClient, Book_mysql & book_mysql){ std::cout << "客户端 " << sClient << " 正在打印书籍(概括)" << std::endl; if (book_mysql.selectWhetherEmpty()) { std::cout << "还没有录入书籍" << std::endl; Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); return; } book_mysql.displayInformation(Data, sClient);}//打印每一本书籍的信息（打印每一本书的详细信息）void DISPLAY(infoData& Data, SOCKET& sClient, Book_mysql & book_mysql){ std::cout << "客户端 " << sClient << " 正在打印全部书籍信息" << std::endl; book_mysql.DISPLAY(Data, sClient);}//打印指定读者的借书情况void showTheReaderBook(infoData & Data, SOCKET & sClient, Book_mysql & book_mysql,Reader_mysql & reader_mysql){ std::cout << "客户端 " << sClient << " 正在打印指定读者的借书情况" << std::endl; switch (reader_mysql.testTheReaderWhetherExist(Data)) { case 0:Data.flag = -1; send(sClient, (char*)&Data, sizeof(Data), 0); return;//没有找到该读者，直接return case 1:Data.flag = 0; send(sClient, (char*)&Data, sizeof(Data), 0); break;//找到该读者，继续操作 } book_mysql.showTheReaderBook(Data, sClient);}//注册新的读者void setNewReader(infoData & Data, const SOCKET & sClient, Reader_mysql & reader_mysql){ std::cout << "客户端 " << sClient << " 正在注册新读者" << std::endl; switch (reader_mysql.testTheReaderWhetherExist(Data)) { case 1:Data.flag = -1; break;//已有该读者 case 0:Data.flag = 1; reader_mysql.insertTo(Data); break;//注册成功 } send(sClient, (char*)&Data, sizeof(Data), 0);}//线程void clientSocketThreadFunction(SOCKET sClient){ Book_mysql book_mysql; Reader_mysql reader_mysql; //对客户端的数据进行解析 while (true) { infoData Data; int ret = recv(sClient, (char*)&Data, sizeof(Data), 0); if (SOCKET_ERROR == ret) { std::cout << sClient << "可能下线" << std::endl; return; } int flag = 0; switch (Data.flag)//错误：控制传输跳过的实例化，方法，加{} { //增加书籍 case 1:addBook(Data, sClient, book_mysql); break; //删除书籍 case 2:deleteBook(Data, sClient, book_mysql); break; //借书 case 3:borrowBook(Data, sClient, book_mysql, reader_mysql); break; //还书 case 4:returnBook(Data, sClient, book_mysql, reader_mysql); break; //搜索借书者 case 5: searchBook(Data, sClient, book_mysql); break; //浏览所有书籍信息 case 6: displayAllBook(Data, sClient, book_mysql); break; //查看登入读者的借书情况 case 7:showTheReaderBook(Data, sClient,book_mysql, reader_mysql); break; //注册 case 8:setNewReader(Data, sClient,reader_mysql); break; //退出flag case 9: flag = 1; break; //所有书被借情况一览表 case -10:DISPLAY(Data, sClient, book_mysql); break; default:std::cout << "输入错误 请重新输入：" << std::endl; } if (flag == 1) { std::cout << "客户端 " << sClient << " 下线" << std::endl; break; } }}int main(int argc, char* argv[]){ serverSocket mySocket(8888); while (1) { SOCKET sClient = mySocket.serverAccpetSocket(); if (sClient == -1) { continue; } else { std::cout << "接收到一个客户端 :" << sClient << std::endl; } std::thread t1(clientSocketThreadFunction, sClient);//启用线程 t1.detach(); } return 0;}client
头文件
clientHead.h
#ifndef CLIENTHEAH#define CLIENTHEAH#include <WINSOCK2.H> #include <iostream> #include <string> #include <thread>using namespace std;#pragma comment(lib, "ws2_32.lib")struct infoData{ int flag; //各种命令 int borflag; //借阅情况1表示借出，0表示未出借 char enter_name[20]; //书籍登入号，一本份 char book_name[50]; //书籍名 char book_num[20]; //书编号 char book_writer[50]; //书作者 int remain_book; //最初设置的库存 char reader_name[50]; //借书者 char reader_num[50]; //借书证 char borrow_time[30]; //借书时间 int remain; //库中还剩此书数量 int lend; //从库中借出的此书数量};class clientSocket{public: clientSocket(string ipAdress, short port); ~clientSocket(); bool connectToServer(); void receiveData(infoData & data); void sendData(infoData & data);private: WSADATA wsd; //WSADATA变量 SOCKET sClient; //客户端套接字 SOCKADDR_IN servAddr; //服务器地址 int ret; //返回值 };void menu();void tapAnyKeyNext();int addBook(infoData & Data, clientSocket & mySocket);int displayAllbook(infoData Data, clientSocket & mySocket);int deleteBook(infoData & Data, clientSocket & mySocket);int borrowBook(infoData & Data, clientSocket & mySocket);int returnBook(infoData & Data, clientSocket & mySocket);int searchBook(infoData & Data, clientSocket & mySocket);int showTheReaderBook(infoData & Data, clientSocket & mySocket);int setNewReader(infoData & Data, clientSocket & mySocket);void DISPLAY(infoData & Data, clientSocket & mySocket);#endif套接字类的实现
mySocket.cpp
#include "clientHead.h"clientSocket::clientSocket(string ipAdress, short port){ //初始化套结字动态库 if (WSAStartup(MAKEWORD(2, 2), &wsd) != 0) { cout << "WSAStartup failed!" << endl; return; } //创建套接字 sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (INVALID_SOCKET == sClient) { cout << "socket failed!" << endl; return; } servAddr.sin_family = AF_INET; //如果编译通不过 属性 c++ 常规 sdl 改成否 servAddr.sin_addr.s_addr = inet_addr(ipAdress.c_str());//设置服务端地址 这里表示本机 servAddr.sin_port = htons(port); int nServAddlen = sizeof(servAddr);}bool clientSocket::connectToServer(){ //连接服务器 ret = connect(sClient, (LPSOCKADDR)&servAddr, sizeof(servAddr)); if (SOCKET_ERROR == ret) { cout << "connect failed!" << endl; system("pause"); return false; } //成功建立连接 可以开始通信了 return true;}void clientSocket::sendData(infoData & Data){ //向服务器发送数据 ret = send(sClient, (char*)&Data, sizeof(Data), 0); if (SOCKET_ERROR == ret) { cout << "send failed!" << endl; return; }}void clientSocket::receiveData(infoData & Data){ // 接收服务器端的数据 recv(sClient, (char*)&Data, sizeof(Data), 0); }clientSocket::~clientSocket(){ closesocket(sClient); //关闭套接字 WSACleanup(); //释放套接字资源 }客户端总实现
client
#include "clientHead.h"void menu(){ cout << "*****************************" << endl; cout << endl; cout << "1.录入书籍"<<endl; cout << "2.删除书籍" << endl; cout << "3.借书" << endl; cout << "4.还书" << endl; cout << "5.按书籍登入号查看信息" <<endl; cout << "6.查询所有图书信息" << endl; cout << "7.查看你的借书详情" << endl; cout << "8.注册" << endl; cout << "9.退出" << endl; cout << "-10.查看所有书籍信息" << endl; cout << endl; cout << "*****************************" << endl;}//增加书籍int addBook(infoData & Data, clientSocket & mySocket){ Data.flag = 1; cout << "开始录入书籍 !" << endl; cout << "输入书名："; cin >> Data.book_name; cout << "输入书编号："; cin >> Data.book_num; cout << "输入书作者："; cin >> Data.book_writer; cout << "输入书库存："; cin >> Data.remain_book; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == -1) { cout << "已有此书，请勿重复添加" << endl; } if (Data.flag == 0) { cout << "添加成功" << endl; } cout << "是否继续增加书籍操作? 1 : 0 "; while (1) { int x; cin >> x; switch (x) { case 0:return 0;//退出 case 1:return 1;//继续 default:cout << "输入错误 请重新输入："; } }}//删除书籍int deleteBook(infoData & Data, clientSocket & mySocket){ if (displayAllbook(Data, mySocket)) { tapAnyKeyNext(); return 0; } cout << "已经外借的那本无法删除" << endl; cout << "输入书名："; cin >> Data.book_name; cout << "输入作者："; cin >> Data.book_writer; Data.flag = 2; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == -1) { cout << "没有该书" << endl; } else if (Data.flag == -2) { cout << "该书全部出借，无法进行删除" << endl; } else if (Data.flag == 0) { cout << "删除成功" << endl; } cout << "是否继续删除书籍操作? 1 : 0 "; while (1) { int x; cin >> x; switch (x) { case 0:return 0;//退出 case 1:return 1;//继续 default:cout << "输入错误 请重新输入："; } }}//借书int borrowBook(infoData & Data, clientSocket & mySocket){ Data.flag = 3; cout << "输入你的姓名：" << endl; cin >> Data.reader_name; cout << "输入你的借书号：" << endl; cin >> Data.reader_num; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == -1) { cout << "没有找到该读者，是否重新输入？1:2" << endl; char ch[10]; cin >> ch; int x = atoi(ch); switch (x) { case 1:return 1; break; case 2:return 0; break; } } else if (Data.flag == 0) { cout << "登入成功" << endl; } cout << "输入书籍名："; cin >> Data.book_name; cout << "输入书作者："; cin >> Data.book_writer; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == 0) { cout << "借书成功" << endl; } else if (Data.flag == -1) { cout << "未录入任何书籍" << endl; } else if (Data.flag == -2) { cout << "没有这本书" << endl; } else if (Data.flag == -3) { cout << "该书已借光" << endl; } else if (Data.flag == -4) { cout << "借此书此书已达上限" << endl; } cout << "是否继续借书操作? 1 : 0 "; while (true) { while (1) { int x; cin >> x; switch (x) { case 0:return 0;//退出 case 1:return 1;//继续 default:cout << "输入错误 请重新输入："; } } }}//还书int returnBook(infoData & Data, clientSocket & mySocket){ Data.flag = 4; cout << "输入你的姓名：" << endl; cin >> Data.reader_name; cout << "输入你的借书号：" << endl; cin >> Data.reader_num; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == -1) { cout << "没有找到该读者，是否重新输入？1:2" << endl; char ch[10]; cin >> ch; int x = atoi(ch); switch (x) { case 1:return 1; break; case 2:return 0; break; } } else if (Data.flag == 0) { cout << "登入成功" << endl; } cout << "您所借书如下:" << endl; cout << endl; mySocket.receiveData(Data); if (Data.flag == 0) { cout << endl; std::cout << "你没有借书" << std::endl; cout << endl; return 1; } while (Data.flag == 6) { cout << "登入号 ：" << Data.enter_name << endl; cout << "书籍名 ：" << Data.book_name << endl; cout << "书籍号 ：" << Data.book_num << endl; cout << "作者名 : " << Data.book_writer << endl; cout << "借阅时间 ：" << Data.borrow_time << endl; cout << endl; mySocket.receiveData(Data); } cout << "输入登入号还书：" << endl; cin >> Data.enter_name; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == -1) { cout << "没有查询到该登入号" << endl; } else if (Data.flag == 0) { cout << "还书成功" << endl; } cout << "是否继续还书操作? 1 : 0 "; while (true) { while (1) { int x; cin >> x; switch (x) { case 0:return 0;//退出 case 1:return 1;//继续 default:cout << "输入错误 请重新输入："; } } }}//打印（笼统）int displayAllbook(infoData Data, clientSocket & mySocket){ Data.flag = 6; mySocket.sendData(Data); cout << endl; while (true) { mySocket.receiveData(Data); if (Data.flag == -1) { cout << "没有录入书籍" << endl; return -1; } else if (Data.flag == 1) { break; } else if (Data.flag == 0) { cout << "书籍名 ：" << Data.book_name << endl; cout << "书籍号 ：" << Data.book_num << endl; cout << "作者名 ：" << Data.book_writer << endl; cout << "还剩余 ：" << Data.remain << " 本" << endl; cout << "已借出 ：" << Data.lend <<" 本"<< endl; cout << endl; } } return 0;}//通过书籍登入号查找书籍信息int searchBook(infoData & Data, clientSocket & mySocket){ Data.flag = 5; cout << "请输入书籍登入号" << endl; cin >> Data.enter_name; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == 3) { cout << "没有这个登入号" << endl; tapAnyKeyNext(); return 0; } cout << endl; cout << "查询结果如下" << endl; cout << endl; cout << "登入号 ：" << Data.enter_name << endl; cout << "书籍名 ：" << Data.book_name << endl; cout << "书籍号 ：" << Data.book_num << endl; cout << "作者名 : " << Data.book_writer << endl; if (Data.borflag == 1) { cout << "**该书已被借**" << endl; cout << "借书者 ：" << Data.reader_name << endl; cout << "借书证 ：" << Data.reader_num << endl; } else if (Data.borflag == 0) { cout << "**该书没被借**" << endl; } cout << endl; cout << "查询完成" << endl; cout << "是否继续查询操作? 1 : 0 "; while (true) { while (1) { int x; cin >> x; switch (x) { case 0:return 0;//退出 case 1:return 1;//继续 default:cout << "输入错误 请重新输入："; } } }}//查看指定读者借书情况int showTheReaderBook(infoData & Data, clientSocket & mySocket){ Data.flag = 7; cout << "输入你的姓名：" << endl; cin >> Data.reader_name; cout << "输入你的借书号：" << endl; cin >> Data.reader_num; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == -1) { cout << "没有找到该读者，是否重新输入？1:2" << endl; char ch[10]; cin >> ch; int x = atoi(ch); switch (x) { case 1:return 1; break; case 2:return 0; break; } } else if (Data.flag == 0) { cout << "登入成功" << endl; } mySocket.receiveData(Data); if (Data.flag == 0) { cout << "你还没借书" << endl; } else { cout << endl; cout << "查询结果如下" << endl; cout << endl; while (Data.flag == 6) { cout << "登入号 ：" << Data.enter_name << endl; cout << "书籍名 ：" << Data.book_name << endl; cout << "书籍号 ：" << Data.book_num << endl; cout << "作者名 : " << Data.book_writer << endl; cout << "借书时间 ：" << Data.borrow_time << endl; cout << endl; mySocket.receiveData(Data); } } cout << "以上是您所有的借书情况" << endl; cout << "是否继续此查询操作? 1 : 0 "; while (true) { while (1) { int x; cin >> x; switch (x) { case 0:return 0;//退出 case 1:return 1;//继续 default:cout << "输入错误 请重新输入："; } } }}//创建新读者int setNewReader(infoData & Data, clientSocket & mySocket){ Data.flag = 8; cout << "输入你的姓名：" << endl; cin >> Data.reader_name; cout << "输入你的借书号：" << endl; cin >> Data.reader_num; mySocket.sendData(Data); mySocket.receiveData(Data); if (Data.flag == 1) { cout << "注册成功" << endl; tapAnyKeyNext(); return 0; } else if (Data.flag == -1) { cout << "名字借书号重复，是否重新输入？1:2" << endl; char ch[10]; cin >> ch; int x = atoi(ch); switch (x) { case 1:return 1; break; case 2:return 0; break; } }}//遍历每一本书的详情信息void DISPLAY(infoData & Data, clientSocket & mySocket){ Data.flag = -10; int i = 0; mySocket.sendData(Data); cout << endl; while (true) { mySocket.receiveData(Data); if (Data.flag == -2) { cout << "没有录入书籍" << endl; tapAnyKeyNext(); return; } if (Data.flag == -1) { break; } cout << "登入号 ：" << Data.enter_name << endl; cout << "书籍名 ：" << Data.book_name << endl; cout << "书籍号 ：" << Data.book_num << endl; cout << "作者名 : " << Data.book_writer << endl; if (Data.borflag == 1) { cout << "**该书已被借**" << endl; cout << "借书者 ：" << Data.reader_name << endl; cout << "借书证 ：" << Data.reader_num << endl; cout << "借阅时间 ：" << Data.borrow_time << endl; } else if (Data.borflag == 0) { cout << "**该书没被借**" << endl; } cout << endl; } cout << "查询完成" << endl; cout << endl; tapAnyKeyNext();}//按任意键退出void tapAnyKeyNext(){ while (1) { cout << "按任意键返回主菜单" << endl; string x; cin >> x; return; }}int main(){ clientSocket mySocket("127.0.0.1", 8888); if (!mySocket.connectToServer()) { return 0; } //向服务端发送数据 while (true) { menu(); infoData Data; char ch[20]; cout << "输入操作："; cin >> ch; int x = atoi(ch); int flag = 0; switch (x) { case 1: { while (1) { if (addBook(Data, mySocket) == 0) { break; } } } break; case 2: { while (1) { if (deleteBook(Data, mySocket) == 0) { break; } } }break; case 3: { while (1) { if (borrowBook(Data, mySocket) == 0) { break; } } }break; case 4: { while (1) { if (returnBook(Data, mySocket) == 0) { break; } } }break; case 5: { while (1) { if (searchBook(Data, mySocket) == 0) { break; } } }break; case 6:displayAllbook(Data, mySocket); tapAnyKeyNext(); break; case 7: { while (1) { if (showTheReaderBook(Data, mySocket) == 0) { break; } } }break; case 8: { while (1) { if (setNewReader(Data, mySocket) == 0) { break; } } }break; case 9:flag = 1; break; case -10:DISPLAY(Data, mySocket); break; default:cout << "输入错误 请重新输入：" << endl; } if (flag == 1) { Data.flag = 9; mySocket.sendData(Data); break; } } WSACleanup(); return 0;}平台：vs2013
MySQL5.7
关于“如何用C++实现简单图书馆管理系统”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注编程网行业资讯频道，小编每天都会为大家更新不同的知识点。
