Linux项目:音乐播放器

╰半夏微凉° 2022-09-11 10:20 217阅读 0赞

### 文章目录 ###

*  1.项目介绍
 *  2.前端代码
 *   *   *  1.httplib快速搭建一个http服务器
         *  2.B/S双方的数据交互选择JSON数据格式，http请求和响应的正文中采用jsoncpp开源库
         *  3.前段的js代码向发送ajax请求
 *  三、服务端代码
 *   *   *  1.搭建一个music\_player这样的一个类
         *  2.增加注册按钮，并且点击注册按钮跳转到注册界面
         *  3.服务端代码当中调用mysql-c api连接数据库，进行操作
         *  4.登录查询用户是否存在校验邮箱和密码
         *  5.通过命令行参数获取ip地址和端口号信息
         *  6.保存登录的会话信息session，使用md5摘要保护登录信息，否则造成直接跳转list.html界面
         *  7.用哈希表保存多个用户的信息
         *  8.数据库存放音乐相关信息，通过json串返回给浏览器
         *  9.查询音乐、喜欢的音乐、添加喜欢的音乐

# 1.项目介绍 #

**音乐播放器拥有注册登录功能，查看所有的音乐列表，也可以听音乐，也可以将音乐添加到自己的喜欢列表。**

# 2.前端代码 #

### 1.httplib快速搭建一个http服务器 ###

![在这里插入图片描述][1f10af117c7c49f7a083a57a3076a24f.png]

1	#include<stdio.h>
         2	#include<iostream>
         3	
         4	#include<string.h>
         5	#include"httplib.h"
         6	
         7	using namespace httplib;
         8	using namespace std;
         9	
        10	int g_val=100;
        11	
        12	void Get_CallBackFunc(const Request& req, Response& resp)
        13	{ 
        14	    printf("%d\n",g_val);
        15	    cout<<req.method<<endl;
        16	    printf("i am Get_CallBackFunc\n");
        17	    
        18	    const char* lp="<html><h2>hello world!</h2></html>";
        19	    resp.set_content(lp,strlen(lp),"text/html");
        20	}
        21	
        22	
        23	
        24	int main()
        25	{ 
        26	    Server http_svr;
        27	    int a=10;
        28	
        29	    http_svr.Get("/abc",Get_CallBackFunc);
        30	    http_svr.Post("/111",[a](const Request& req,Response& resp){ 
        31	            printf("a:%d\n",a);
        32	
        33	    });
        34	    //直接访问web里面的文件
        35	    //逻辑根目录指定为web文件夹
        36	    http_svr.set_mount_point("/","./web");
        37	    http_svr.listen("0.0.0.0",21010);
        38	
        39	    return 0;
        40	}

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_15_color_FFFFFF_t_70_g_se_x_16]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_14_color_FFFFFF_t_70_g_se_x_16]

### 2.B/S双方的数据交互选择JSON数据格式，http请求和响应的正文中采用jsoncpp开源库 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_13_color_FFFFFF_t_70_g_se_x_16]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_17_color_FFFFFF_t_70_g_se_x_16]

1	#include<stdio.h>
         2	#include<iostream>
         3	#include<jsoncpp/json/json.h>
         4	
         5	using namespace std;
         6	
         7	int main()
         8	{ 
         9	
        10	    Json::Value v1;
        11	    v1["id"]=1;
        12	    v1["name"]="yyw";
        13	    cout<<v1<<endl;
        14	
        15	    Json::Value v2;
        16	    v2["id"]=2;
        17	    v2["name"]="yy";
        18	    cout<<v2<<endl;
        19	
        20	    Json::Value v3;
        21	    v3["v1"]=v1;
        22	    v3["v2"]=v2;
        23	    cout<<v3<<endl;
        24	
        25	    Json::Value v4;
        26	    v4.append(v1);
        27	    v4.append(v2);
        28	    cout<<v4<<endl;
        29	
        30	    for(int i=0;i<2;i++)
        31	    { 
        32	        cout<<v4[i]["id"]<<":"<<v4[i]["name"]<<endl;
        33	    }
        34	
        35	    //序列化
        36	    Json::FastWriter w;
        37	    string json_str=w.write(v4);
        38	    cout<<json_str<<endl;
        39	    //反序列化
        40	    Json::Reader r;
        41	    Json::Value vv;
        42	    r.parse(json_str,vv);
        43	    cout<<vv<<endl;
        44	    return 0;
        45	}

**JSON数据格式有三种显示方法:平铺、嵌套、数组形式。**  
![在这里插入图片描述][d23212fdc04c41f38c8138674c8893b3.png]  
![在这里插入图片描述][d13d5a89baa9435fb0de5ae7fe0495b8.png]  
![在这里插入图片描述][0e8997d7d72e4ac5beb57147dceb86b3.png]  
**序列化和反序列化:**  
![在这里插入图片描述][a0226d9b7a7c409fbb06eedc1f35e885.png]

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_17_color_FFFFFF_t_70_g_se_x_16 1]

### 3.前段的js代码向发送ajax请求 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_17_color_FFFFFF_t_70_g_se_x_16 2]

#include<stdio.h>
    #include<iostream>
    
    #include<jsoncpp/json/json.h>
    #include<string.h>
    #include"httplib.h"
    
    using namespace httplib;
    using namespace std;
    
    int g_val=100;
    
    void Get_CallBackFunc(const Request& req, Response& resp)
    { 
        printf("%d\n",g_val);
        cout<<req.method<<endl;
        printf("i am Get_CallBackFunc\n");
        
        const char* lp="<html><h2>hello world!</h2></html>";
        resp.set_content(lp,strlen(lp),"text/html");
    }
    
    
    
    int main()
    { 
        Server http_svr;
    
        http_svr.Get("/abc",Get_CallBackFunc);
        //发送post请求/login，回调这个表达式
        http_svr.Post("/login",[](const Request& req,Response& resp){ 
                cout<<req.body<<endl; //打印正文信息
    
                Json::Value resp_json;
                resp_json["login_status"]=true;  //浏览器返回登录状态
                
                //序列化
                //系列化成完整的字符串的内容放到响应的正文中
                Json::FastWriter w;
                resp.body= w.write(resp_json);
                //告诉浏览器返回的内容就是json串，对json解析
                resp.set_header("Content-Type","application/json");
        });
        //直接访问web里面的文件
        //逻辑根目录指定为web文件夹
        http_svr.set_mount_point("/","./web");
        http_svr.listen("0.0.0.0",21010);
    
        return 0;
    }

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
![在这里插入图片描述][9a3301e424e04fbbb8a56742fb533257.png]

# 三、服务端代码 #

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_15_color_FFFFFF_t_70_g_se_x_16 1]

### 1.搭建一个music\_player这样的一个类 ###

![在这里插入图片描述][b82c3a3c52254ffd8ecf5af258ab997b.png]

1	#pragma once
         2	#include"database.hpp"
         3	#include<stdio.h>
         4	#include<iostream>
         5	#include<string>
         6	#include"httplib.h"
         7	
         8	#include<jsoncpp/json/json.h>
         9	
        10	using namespace std;
        11	
        12	using namespace httplib;
        13	
        14	#define MUSIC_SVR_IP "0.0.0.0"
        15	#define MUSIC_SVR_PORT 18989
        16	
        17	class MusicServer
        18	{ 
        19	    public:
        20	        MusicServer()
        21	        { 
        22	            svr_ip_=MUSIC_SVR_IP;
        23	            svr_port_=MUSIC_SVR_PORT;
        24	            db_svr_=NULL;
        25	        }
        26	        ~MusicServer()
        27	        { 
        28	
        29	        }
        30	
        31	        //1.初始化当前类接
        32	        int InitMusicServer(string ip=MUSIC_SVR_IP,uint16_t port=MUSIC_SVR_PORT)
        33	        { 
        34	            svr_ip_=ip;
        35	            svr_port_=port;
        36	
        37	            db_svr_=new DataBaseSvr("1.14.165.138","yy","123","music_svr");
        38	            if(db_svr_==NULL)
        39	            { 
        40	                return -1;
        41	            }
        42	            return 0;
        43	        }
        44	        //2.启动服务的接口
        45	        int StartMusicServer()
        46	        { 
        47	            //1.注册个若干个http请求的对应的回调函数
        48	            /* 49 *请求:{"name":"yy","passwd":"123","email":"123@qq.com","phonenum":"1231"} 50 *响应:{"register_status":"xxxx"} 51 * 52 * 53 * */
        54	            http_svr_.Post("/register",[this](const Request& req,Response& resq){ 
        55	                    cout<<req.body<<endl;
        56	                    //1.需要将浏览器中的数据持久化(保存在数据库中) 
        57	                    //
        58	                    //1.将用户提交的数据进行反序列化，拿到一个json对象
        59	                    Json::Reader r;
        60	                    Json::Value v;
        61	                    r.parse(req.body,v);
        62	
        63	                    cout<<v["name"]<<endl;
        64	                    cout<<v["passwd"]<<endl;
        65	                    cout<<v["email"]<<endl;
        66	                    cout<<v["phonenum"]<<endl;
        67	
        68	                    db_svr_->InsertUserInfo(v);
        69	                    });
        70	
        71	            http_svr_.Post("/login",[](const Request& req,Response& resq){ 
        72	                /* 73 *1. 74 *2. 75 *3. 76 * */
        77	            cout<<req.body<<endl;
        78	
        79	            });
        80	
        81	            //2.设置http服务器静态路径(逻辑根目录)
        82	            http_svr_.set_mount_point("/","./web");
        83	            //3.监听起来
        84	            http_svr_.listen(svr_ip_.c_str(),svr_port_);
        85	        }
        86	    private:
        87	        //httplib 当中的server对象
        88	        Server http_svr_;
        89	
        90	        string svr_ip_;
        91	        uint16_t svr_port_;
        92	
        93	        //数据库操作模块
        94	        DataBaseSvr* db_svr_;
        95	};

### 2.增加注册按钮，并且点击注册按钮跳转到注册界面 ###

54	            http_svr_.Post("/register",[this](const Request& req,Response& resq){ 
        55	                    cout<<req.body<<endl;
        56	                    //1.需要将浏览器中的数据持久化(保存在数据库中) 
        57	                    //
        58	                    //1.将用户提交的数据进行反序列化，拿到一个json对象
        59	                    Json::Reader r;
        60	                    Json::Value v;
        61	                    r.parse(req.body,v);
        62	
        63	                    cout<<v["name"]<<endl;
        64	                    cout<<v["passwd"]<<endl;
        65	                    cout<<v["email"]<<endl;
        66	                    cout<<v["phonenum"]<<endl;
        67	
        68	                    db_svr_->InsertUserInfo(v);
        69	                    });

### 3.服务端代码当中调用mysql-c api连接数据库，进行操作 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_12_color_FFFFFF_t_70_g_se_x_16]

1	#pragma once
         2	#include<stdio.h>
         3	#include<unistd.h>
         4	#include<iostream>
         5	#include<string>
         6	
         7	#include<mysql/mysql.h>
         8	#include<jsoncpp/json/json.h>
         9	using namespace std;
        10	class DataBaseSvr
        11	{ 
        12	    public:
        13	        DataBaseSvr(const string& db_host,const string& db_user,const string& db_password,const string& db_name,unsigned int db_port=3306)
        14	        { 
        15	            mysql_init(&mysql_);
        16	            db_host_=db_host;
        17	            db_user_=db_user;
        18	            db_password_=db_password;
        19	            db_port_=db_port;
        20	            db_name_=db_name;
        21	        }
        22	        ~DataBaseSvr()
        23	        { 
        24	
        25	        }
        26	
        27	        int ConnectToMysql()
        28	        { 
        29	            if(!mysql_real_connect(&mysql_,db_host_.c_str(),db_user_.c_str(),db_password_.c_str(),db_name_.c_str(),db_port_,NULL,CLIENT_FOUND_ROWS))
        30	            { 
        31	                cout<<mysql_error(&mysql_)<<endl;
        32	                return -1;
        33	            }
        34	            return 0;
        35	        }
        36	
        37	        //提交上来的对象
        38	        int InsertUserInfo(const Json::Value& v)
        39	        { 
        40	            //1.连接数据库
        41	            if(ConnectToMysql()<0)
        42	            { 
        43	                return -1;
        44	            }
        45	            //2.组织sql语
        46	            
        47	            string name=v["name"].asString();
        48	            string password=v["password"].asString();
        49	            string email=v["email"].asString();
        50	            string phonenum=v["phonenum"].asString();
        51	
        52	#define INSERT_USER_INFO  "insert into sys_user(user_name,password,email,phone_num) values('%s','%s','%s','%s');"
        53	
        54	            char sql[1024]={ 0};
        55	            snprintf(sql,sizeof(sql)-1,INSERT_USER_INFO,name.c_str(),password.c_str(),email.c_str(),phonenum.c_str());
        56	            cout<<"sql:"<<sql<<endl;
        57	
        58	            //3.继续执行sql
        59	            //4.返回插入结果给调用者
        60	        }
        61	    private:
        62	        MYSQL mysql_;
        63	
        64	        string db_host_;
        65	        string db_user_;
        66	        string db_password_;
        67	        string db_name_;
        68	        unsigned int db_port_;
        69	};

### 4.登录查询用户是否存在校验邮箱和密码 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_13_color_FFFFFF_t_70_g_se_x_16 1]

//查询用户是否存在
       105	       int QueryUserExist(const Json::Value& v)
       106	        { 
       107	           /* //0 链接 108 if(ConnectToMysql()<0) 109 { 110 return -1; 111 }*/
       112	            //1.从json对象当中解析出来 邮箱和密码
       113	
       114	            string email = v["email"].asString();
       115	            string password = v["password"].asString();
       116	
       117	            //2.使用邮箱作为查询条件在sys_user表当中进行查询（如果没有查找到用户，则返回）
       118	#define QUERY_USER "select * from sys_user where email='%s';"
       119	            char sql[1024] = { 0};
       120	            snprintf(sql, sizeof(sql) - 1, QUERY_USER, email.c_str());
       121	            cout << sql << endl;
       122	                    
       123	       		 //3.针对查询的结果当中的密码， 进行比对
       124	            MYSQL_RES* res = NULL;
       125	            if(ExecuteSql(sql, &res) == false)
       126	            { 
       127	                return -2;
       128	            }
       129	            
       130	            //3.1 针对结果集进行操作， 判断下，结果集当中的行数是否等于1
       131	            // 等于1， 继续往下执行
       132	            // 不等1 ， 直接返回
       133	            //my_ulonglong STDCALL mysql_num_rows(MYSQL_RES *res);
       134	            if(mysql_num_rows(res) != 1)
       135	            { 
       136	                cout << "No Data for sql!, sql is " << sql <<endl;
       137	                mysql_free_result(res);
       138	                return -3;
       139	            }
       140	
       141	            //3.2 在结果集当中获取一行数据
       142	            //MYSQL_ROW STDCALL mysql_fetch_row(MYSQL_RES *result);
       143	            // 如果重复调用msyql_fetch_row这个函数， 默认是取下一行的数据
       144	            MYSQL_ROW row = mysql_fetch_row(res);
       145	
       146	            //3.3 比对密码
       147	            string db_password = row[2];
       148	            if(db_password != password )
       149	            { 
       150	                return -4;
       151	            }
       152	            
       153	            mysql_free_result(res);
       154	            //4.返回查询结果
       155	            return atoi(row[0]); 
       156	 		}

### 5.通过命令行参数获取ip地址和端口号信息 ###

1	#include"music_player.hpp"
         2	void Usage()
         3	{ 
         4	    cout << "./MusicServer [command key] [command value] ..." << endl;
         5	    cout << " " << "-ip : svr listen ip" << endl;
         6	    cout << " " << "-port : svr listen port" << endl;
         7	    cout << " " << "-db_ip : msyql server ip address" << endl;
         8	    cout << " " << "-db_port : mysql port" << endl;
         9	    cout << " " << "-db_user : mysql user" << endl;
        10	    cout << " " << "-db_passwd : mysql password" << endl;
        11	    cout << " " << "-db_db : which database " << endl;
        12	    cout << " " << "-h : show usage" << endl;
        13	}
        14	
        15	//通过命令行参数获取ip地址和端口号之类的信息
        16	int main(int argc, char* argv[])
        17	{ 
        18	    if(argc == 2 && strcmp(argv[1], "-h") == 0)
        19	    { 
        20	        Usage();
        21	        exit(1);
        22	    }
        23	    string svr_ip, db_ip, db_user, db_db, db_passwd;
        24	    uint16_t svr_port, db_port;
        25	    for(int i = 0; i < argc; i++)
        26	    { 
        27	        if(strcmp(argv[i], "-ip") == 0 && i + 1 < argc)
        28	        { 
        29	            svr_ip = argv[i + 1];
        30	        }
        31	        else if(strcmp(argv[i], "-port") == 0 && i + 1 < argc)
        32	        { 
        33	            svr_port = atoi(argv[i + 1]);
        34	        }
        35	        else if(strcmp(argv[i], "-db_ip") == 0 && i + 1 < argc)
        36	        { 
        37	            db_ip = argv[i + 1];
        38	        }
        39	        else if(strcmp(argv[i], "-db_port") == 0 && i + 1 < argc)
        40	        { 
        41	            db_port = atoi(argv[i + 1]);
        42	        }
        43	        else if(strcmp(argv[i], "-db_user") == 0 && i + 1 < argc)
        44	        { 
        45	            db_user = argv[i + 1];
        46	        }
        47	        else if(strcmp(argv[i], "-db_db") == 0 && i + 1 < argc)
        48	        { 
        49	            db_db = argv[i + 1];
        50	        }
        51	        else if(strcmp(argv[i], "-db_passwd") == 0 && i + 1 < argc)
        52	        { 
        53	            db_passwd = argv[i + 1];
        54	        }
        55	}
        56		cout<<"please check info:"<<endl;
        57	    cout << "svr_ip: " << svr_ip << endl;
        58	    cout << "svr_pot: " << svr_port << endl;
        59	    cout << "db_ip: " << db_ip << endl;
        60	    cout << "db_port: " << db_port << endl;
        61	    cout << "db_user: " << db_user << endl;
        62	    //cout << "db_passwd: " << db_passwd << endl;
        63	    cout << "db_db: " << db_db << endl;
        64	
        65	    //重新输出ip
        66		int select  = 0;
        67	    cout << "enter check result: currect input 1, error input 0;" << endl;
        68	    cout << "[input select]: ";
        69	    cin >> select;
        70	    switch(select)
        71	    { 
        72	        case 0:
        73	            cout << "plase retry start server.." << endl;
        74	            break;
        75	        case 1:
        76	            { 
        77	                MusicServer* ms = new MusicServer();
        78	                if(ms == NULL)
        79	                { 
        80	                    return -1;
        81	                }
        82	
        83	                if(ms->InitMusicServer(db_ip, db_port, db_user, db_passwd, db_db, svr_ip, svr_port) < 0)
        84	                { 
        85	                    return -2;
        86	                }
        87	                ms->StartMusicServer();
        88	                delete ms;
        89	                break;
        90	            }
        91	        default:
        92	            printf("input select num error, please input 1(currect) or 0(error)\n");
        93	            break;
        94	    }
        95	
        96	    return 0;
        97	}

### 6.保存登录的会话信息session，使用md5摘要保护登录信息，否则造成直接跳转list.html界面 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_13_color_FFFFFF_t_70_g_se_x_16 2]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_14_color_FFFFFF_t_70_g_se_x_16 1]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 2]

1	#pragma once
         2	#include <stdio.h>
         3	#include <unistd.h>
         4	#include <string.h>
         5	#include <openssl/md5.h>
         6	#include <iostream>
         7	#include <string>
         8	#include <unordered_map>
         9	
        10	#include <jsoncpp/json/json.h>
        11	#include "httplib.h"
        12	
        13	using namespace std;
        14	using namespace httplib;
        15	
        16	typedef enum UserStatus
        17	{ 
        18	    //不在线
        19	    OFFLINE = 0,
        20	    //在线状态
        21	    ONLINE,
        22	}USER_STATUS;
        23	
        24	
        25	//针对与登录的用户创建的会话信息
        26	
        27	class Session
        28	{ 
        29	    public:
        30	        Session()
        31	        { 
        32	
        33	        }
        34	
        35	        Session(const Json::Value& v, int user_id)
        36	        { 
        37	            user_id_ = user_id;
        38	
        39	            real_str_ += v["email"].asString();
        40	            real_str_ += v["password"].asString();
        41	
        42	            us_status_ = ONLINE;
        43	        }
        44	
        45	        ~Session()
        46	        { 
        47	
        48	        }
        49	
        50	
        51	        bool CalcMd5()
        52	        { 
        53	            MD5_CTX ctx;
        54	            MD5_Init(&ctx);
        55	
        56	            //int MD5_Update(MD5_CTX *c, const void *data, unsigned long len);
        57	            if(MD5_Update(&ctx, real_str_.c_str(), real_str_.size()) != 1)
        58	            { 
        59	                return false;
        60	            }
        61	
        62	            //int MD5_Final(unsigned char *md, MD5_CTX *c);
        63	            //md ==> 16字节
        64	            unsigned char md5[16] = {  0 };
        65	            if(MD5_Final(md5, &ctx) != 1)
        66	            { 
        67	                return false;
        68	            }
        69	
        70	            char tmp[2] = { 0};
        71	            char buf[32] = { 0};
        72	            for(int i = 0; i < 16; i++)
        73	            { 
        74	                sprintf(tmp, "%02x", md5[i]);
        75	                strncat(buf, tmp, 2);
        76	            }
        77	
        78	            session_id_ = buf;
        79	            cout << "session_id_" << session_id_ << endl;
        80	            return true;
        81	        }
        82	
        83	        string& GetSessionID()
        84	        { 
        85	            //1.计算sessionID
        86	            CalcMd5();
        87	            //2.返回session_id
        88	            return session_id_;
        89	        }
        90	
        91	        int GetUserId()
        92	        { 
        93	            return user_id_;
        94	        }
        95	
        96	    private:
        97	        string session_id_;
        98	
        99	        //生成会话ID的源字符串
       100	        string real_str_;
       101	
       102	        int user_id_;
       103	
       104	        UserStatus us_status_;
       105	};

### 7.用哈希表保存多个用户的信息 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_14_color_FFFFFF_t_70_g_se_x_16 2]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_15_color_FFFFFF_t_70_g_se_x_16 2]

107	//哈希查找多用户的时刻更快
       108	class AllSessionInfo
       109	{ 
       110	    public:
       111	        AllSessionInfo()
       112	        { 
       113	            all_sess_map_.clear();
       114	            pthread_mutex_init(&map_lock_, NULL);
       115	        }
       116	
       117	        ~AllSessionInfo()
       118	        { 
       119	            pthread_mutex_destroy(&map_lock_);
       120	        }
       121	
       122	        void InsertSessionInfo(const string session_id, const Session sess)
       123	        { 
       124	            pthread_mutex_lock(&map_lock_);
       125	            all_sess_map_.insert(make_pair(session_id, sess));
       126	            pthread_mutex_unlock(&map_lock_);
       127	        }
       128	
       129	        int CheckSession(const Request& req)
       130	        { 
       131	            /* 132 * 1.通过http请求头当中的 Cookie字段， 获取对应的value(会话ID) 133 * 2.通过会话ID， 在all_sess_map_当中查找， 是否有对应的会话信息 134 * */
       135	            string sess_id = req.get_header_value("Cookie");
       136	
       137	            pthread_mutex_lock(&map_lock_);
       138	            auto iter = all_sess_map_.find(sess_id);
       139	            if(iter == all_sess_map_.end())
       140	            { 
       141	                pthread_mutex_unlock(&map_lock_);
       142	                return -1;
       143	            }
       144	            int user_id = iter->second.GetUserId();
       145	            pthread_mutex_unlock(&map_lock_);
       146	            return user_id;
       147	        }
       148	    private:
       149	        unordered_map<string, Session> all_sess_map_;
       150	        pthread_mutex_t map_lock_;
       151	};

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_19_color_FFFFFF_t_70_g_se_x_16]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 3]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 4]

### 8.数据库存放音乐相关信息，通过json串返回给浏览器 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 5]

int GetMusic(string sql, Json::Value& resp_json)
       161	        { 
       162	            MYSQL_RES* res = NULL;
       163	            if(ExecuteSql(sql, &res) == false)
       164	            { 
       165	                return -2;
       166	            }
       167	
       168	            int row_nums = mysql_num_rows(res);
       169	            if(row_nums <= 0)
       170	            { 
       171	                printf("No data: sql is \"%s\"", sql.c_str());
       172	                mysql_free_result(res);
       173	                return -3;
       174	            }
       175	
       176	            MYSQL_ROW row = mysql_fetch_row(res);
       177	            Json::Value music_value;
       178	            while(row != NULL)
       179	            { 
       180	                //1.保存数据到json当中
       181	                Json::Value tmp;
       182	                tmp["id"] = row[0];
       183	                tmp["title"] = row[1];
       184	                tmp["singer"] = row[2];
       185	                tmp["url"] = row[3];
       186	
       187	                music_value.append(tmp);
       188	                row = mysql_fetch_row(res);
       189	            }
       190	
       191	            resp_json["music"] = music_value;
       192	            mysql_free_result(res);
       193	            return 0;
       194	        }
       195	
       196	
       197	        int GetAllMusic(Json::Value& resp_json)
       198	        { 
       199	            /* 200 * 1.组织查询的sql语句 201 * 2.调用ExecuteSql函数执行sql语句 202 * 3.检查结果集当中的行数 203 * 4.将获取到的结果集， 进行遍历操作 204 * 4.组织json对象 205 * */
       206	            const char* sql = "select * from music;";
       207	            return GetMusic(sql, resp_json);
       208	        }
       209	
       210	       
       211	
       212	        int InsertLoveMusic(const Request& req, int user_id)
       213	        { 
       214	            /* 215 * 1.通过req当中的正文信息， 获取music_id 216 * 2.使用music_id, user_id组织sql语句 217 * 3.执行sql语句 218 * */
       219	            Json::Reader r;
       220	            Json::Value v;
       221	            r.parse(req.body, v);
       222	
       223	            int music_id = v["music_id"].asInt();
       224	
       225	#define INSERT_LOVE_MUSIC "insert into love_music(user_id, music_id) values(%d, %d);"
       226	            char sql[1024] = { 0};
       227	            snprintf(sql, sizeof(sql) - 1, INSERT_LOVE_MUSIC, user_id, music_id);
       228	
       229	            if(ExecuteSql(sql) == false)
       230	            { 
       231	                return -1;
       232	            }
       233	            return 1;
       234	        }
       235	
       236	        int GetLoveMusic(int user_id, Json::Value& resp_json)
       237	        { 
       238	            /* 239 * 1.组织查询sql 240 * 2.调用GetMusic函数 241 * */
       242	#define GET_LOVE_MUSIC "select * from music where music_id in(select music_id from love_music where user_id=%d);"
       243	            char sql[1024] = { 0}; 
       244	            snprintf(sql, sizeof(sql) - 1, GET_LOVE_MUSIC, user_id);
       245	            return GetMusic(sql, resp_json);
       246	        }

### 9.查询音乐、喜欢的音乐、添加喜欢的音乐 ###

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 6]

http_svr_.Get("/findMusic", [this](const Request& req, Response& resp){ 
       137						/* 138 * 1.会话校验， 从当前http请求的请求体当中拿到 Cookie对应的value值， 会话ID 139 * 1.1 通过会话ID， 在all_sess_当中查找是否有对应的会话 140 * 找到了， 则认为该用户是登录用户， 就可以做后续查找音乐的操作 141 * 没有找到， 则认为该用户是非登录用户， 则返回status为-1 142 * 2.通过数据库模块在数据表music当中查找音乐信息， 则将查找到的音乐信息组织成为json串 143 * 3.组织应答 144 * */
       145						Json::Value resp_json;
       146						int user_id = all_sess_->CheckSession(req);
       147						resp_json["status"] = user_id;
       148						if(user_id > 0)
       149						{ 
       150						/* 1.会话校验成功的逻辑 151 * 2.访问数据库， 获取到数据表music的音乐信息 152 */
       153						db_svr_->GetAllMusic(resp_json); 
       154						}
       155	
       156						Json::FastWriter w;
       157						resp.body = w.write(resp_json);
       158						resp.set_header("Content-Type", "application/json");
       159				});	 
       160	
       161				http_svr_.Post("/loveMusic", [this](const Request& req, Response& resp){ 
       162						Json::Value resp_json;
       163						int user_id = all_sess_->CheckSession(req);
       164						resp_json["status"] = user_id;
       165						if(user_id > 0)
       166						{ 
       167						cout << "user_id: " << user_id << ", req正文信息：" <<  req.body << endl;
       168						resp_json["status"] = db_svr_->InsertLoveMusic(req, user_id);
       169						}
       170	
       171						Json::FastWriter w;
       172						resp.body = w.write(resp_json);
       173						resp.set_header("Content-Type", "application/json");
       174						});
       175	
       176				http_svr_.Get("/findLoveMusic", [this](const Request& req, Response& resp){ 
       177						/* 178 * 1.会话校验，通过会话校验， 如果成功就能获取当前请求的用户ID 179 * 2.查数据库， 当前用户喜欢的音乐 180 * 3.组织json， 将用户喜欢的音乐返回给浏览器 181 * */
       182						Json::Value resp_json;
       183						int user_id = all_sess_->CheckSession(req);
       184						resp_json["status"] = user_id;
       185						if(user_id > 0)
       186						{ 
       187						//去数据库当中查询喜欢的音乐
       188						db_svr_->GetLoveMusic(user_id, resp_json);
       189						}
       190	
       191						Json::FastWriter w;
       192						resp.body = w.write(resp_json);
       193						resp.set_header("Content-Type", "application/json");
       194						}); 
       195				//2.设置http服务器静态路径(逻辑根目录)
       196				http_svr_.set_mount_point("/","./web");
       197				//3.监听起来
       198				http_svr_.listen(svr_ip_.c_str(),svr_port_);
       199			}

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 7]

[1f10af117c7c49f7a083a57a3076a24f.png]: /images/20220828/bdda7d36fc85471d84bd31a388181f37.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_15_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/0c7bf684ddd7451aba3e3bb38e62207a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_14_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/e82689d79de846c5865aed5acf859d2c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_13_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/6c5e384c3c5a40038453a9181bc455b1.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_17_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/b15ab939dcc34eb193d56596434ca64d.png
[d23212fdc04c41f38c8138674c8893b3.png]: /images/20220828/574d47b5dce8400285d3509ff7ecd745.png
[d13d5a89baa9435fb0de5ae7fe0495b8.png]: /images/20220828/93afed2be565484ba164bd83a2b7a919.png
[0e8997d7d72e4ac5beb57147dceb86b3.png]: /images/20220828/f2dd5943a60a43ebac95399f48ccc227.png
[a0226d9b7a7c409fbb06eedc1f35e885.png]: /images/20220828/65a7ae492a2d4e0b982f6656fdf3bfec.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_17_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/a8c527fab05f49d5aad0f0b1e0be216a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_17_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/197377b392db4e6da83f3175a4c83bf2.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/22f50ed57ba64ca6912f745b0e44267a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/ac2db6ab498e4147a1f75fe1f7308622.png
[9a3301e424e04fbbb8a56742fb533257.png]: /images/20220828/6658323a6f224eb898bdd7041d97a604.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_15_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/aad3f5f24cbe40589e4f476f0daf9efe.png
[b82c3a3c52254ffd8ecf5af258ab997b.png]: /images/20220828/a3d95264de7a44b5b2b1ad7eef7d3acf.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_12_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/535b0f914a2b44a3924c76145d0d00fa.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_13_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/a9322d2caaad440183fbc2437b972697.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_13_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/2ff9bd8bf22d4c9086f1e5263e0a88be.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_14_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/0a1245300a6d4329954587d6270a9d77.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/68a902c5e6b54bc8ad0f4d63ef60a8e7.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_14_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/26412995393f469d902e43611b50ca68.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_15_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/9649b973949748b09b97888a9f8490f0.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_19_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/6d459353e4fd4f6d90b3131bee54eed3.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220828/432b8486e0254e11a0ad7188f48f7c09.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220828/eebdd5cbe5f34ba588ed93f1a163ca9c.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220828/75c50c25a6404259a41184d8b94edca6.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 6]: /images/20220828/605c865620be46c4938ec596ed0105a7.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5qOu5piO5biu5aSn5LqO6buR6JmO5biu_size_20_color_FFFFFF_t_70_g_se_x_16 7]: /images/20220828/669f24a924ed4dbdb8a62285bb67c013.png