共享文件操作

• 變量定義
• 讀取配置文件
• • cfg.h
  • cfg.c
  • /conf
• 解析前端Json
• 文件下載標志處理
• Main
• 源碼

變量定義

• DEALSHAREFILE_LOG_MODULE—日志模塊的輸出到該模塊

• DEALSHAREFILE_LOG_PROC —該日志模塊輸出的具體目錄

• 定義三個static靜態(tài)字符數(shù)組存放MySQL登錄用戶名密碼和具體使用的數(shù)據(jù)庫

• 定義兩個static靜態(tài)數(shù)組存放Redis的ip+port

• 根據(jù)以上定義判斷MySQL采用本地連接，Redis采用遠程連接

  #define DEALSHAREFILE_LOG_MODULE "cgi"#define DEALSHAREFILE_LOG_PROC "dealsharefile"//mysql 數(shù)據(jù)庫配置信息 用戶名， 密碼， 數(shù)據(jù)庫名稱static char mysql_user[128] = {0};static char mysql_pwd[128] = {0};static char mysql_db[128] = {0};//redis 服務(wù)器ip、端口static char redis_ip[30] = {0};static char redis_port[10] = {0};

讀取配置文件

• 定義該函數(shù)用于讀取配置文件中的參數(shù)包括MySQL和Redis已經(jīng)做日志輸出

  void read_cfg(){//讀取mysql數(shù)據(jù)庫配置信息get_cfg_value(CFG_PATH, "mysql", "user", mysql_user);get_cfg_value(CFG_PATH, "mysql", "password", mysql_pwd);get_cfg_value(CFG_PATH, "mysql", "database", mysql_db);LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "mysql:[user=%s,pwd=%s,database=%s]", mysql_user, mysql_pwd, mysql_db);//讀取redis配置信息get_cfg_value(CFG_PATH, "redis", "ip", redis_ip);get_cfg_value(CFG_PATH, "redis", "port", redis_port);LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "redis:[ip=%s,port=%s]\n", redis_ip, redis_port);}

cfg.h

• #define CFG_PATH “./conf/cfg.json” //配置文件路徑，說明MySQL和Redis的配置信息放放到當(dāng)前目錄上一級下的conf/cfg.json中

  #ifndef _CFG_H_#define _CFG_H_#define CFG_PATH "./conf/cfg.json" //配置文件路徑#define CFG_LOG_MODULE "cgi"#define CFG_LOG_PROC "cfg"/* -------------------------------------------*//*** @brief 從配置文件中得到相對應(yīng)的參數(shù)** @param profile 配置文件路徑* @param tile 配置文件title名稱[title]* @param key key* @param value (out) 得到的value** @returns* 0 succ, -1 fail*//* -------------------------------------------*/extern int get_cfg_value(const char *profile, char *tile, char *key, char *value);//獲取數(shù)據(jù)庫用戶名、用戶密碼、數(shù)據(jù)庫標示等信息extern int get_mysql_info(char *mysql_user, char *mysql_pwd, char *mysql_db);#endif

• extern關(guān)鍵字可以用來聲明變量和函數(shù)作為外部變量或者函數(shù)供其它文件使用

• extern "C"的主要作用就是為了能夠正確實現(xiàn)C++代碼調(diào)用其他C語言代碼。加上extern "C"后，會指示編譯器這部分代碼按C語言的進行編譯，而不是C++的

cfg.c

#include <stdlib.h>#include <string.h>#include "make_log.h"#include "cfg.h"#include "cJSON.h"/* -------------------------------------------*//*** @brief 從配置文件中得到相對應(yīng)的參數(shù)** @param profile 配置文件路徑* @param title 配置文件title名稱[title]* @param key key* @param value (out) 得到的value** @returns* 0 succ, -1 fail*//* -------------------------------------------*/int get_cfg_value(const char *profile, char *title, char *key, char *value){int ret = 0;char *buf = NULL;FILE *fp = NULL;//異常處理if(profile == NULL || title == NULL || key == NULL || value == NULL){return -1;}//只讀方式打開文件fp = fopen(profile, "rb");if(fp == NULL) //打開失敗{perror("fopen");LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "fopen err\n");ret = -1;goto END;}fseek(fp, 0, SEEK_END);//光標移動到末尾long size = ftell(fp); //獲取文件大小fseek(fp, 0, SEEK_SET);//光標移動到開頭buf = (char *)calloc(1, size+1); //動態(tài)分配空間if(buf == NULL){perror("calloc");LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "calloc err\n");ret = -1;goto END;}//讀取文件內(nèi)容fread(buf, 1, size, fp);//解析一個json字符串為cJSON對象cJSON * root = cJSON_Parse(buf);if(NULL == root){LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "root err\n");ret = -1;goto END;}//返回指定字符串對應(yīng)的json對象cJSON * father = cJSON_GetObjectItem(root, title);if(NULL == father){LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "father err\n");ret = -1;goto END;}cJSON * son = cJSON_GetObjectItem(father, key);if(NULL == son){LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "son err\n");ret = -1;goto END;}//LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "son->valuestring = %s\n", son->valuestring);strcpy(value, son->valuestring); //拷貝內(nèi)容cJSON_Delete(root);//刪除json對象END:if(fp != NULL){fclose(fp);}if(buf != NULL){free(buf);}return ret;}//獲取數(shù)據(jù)庫用戶名、用戶密碼、數(shù)據(jù)庫標示等信息int get_mysql_info(char *mysql_user, char *mysql_pwd, char *mysql_db){if( -1 == get_cfg_value(CFG_PATH, "mysql", "user", mysql_user) ){LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "mysql_user err\n");return -1;}if( -1 == get_cfg_value(CFG_PATH, "mysql", "password", mysql_pwd) ){LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "mysql_pwd err\n");return -1;}if( -1 == get_cfg_value(CFG_PATH, "mysql", "database", mysql_db) ){LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "mysql_db err\n");return -1;}return 0;}

/conf

• /conf目錄如下所示，其中redis.conf是配合redis使用的文件而沒有具體的ip+port
  

• 項目部署時，需要先將MySQL和Redis的連接配置信息寫入cfg.json中

解析前端Json

• 前端QT點擊共享文件，則會顯示共享文件列表

• 解析json包（user，md5，filename），拿到用戶名，文件md5碼，文件名字

  //解析的json包int get_json_info(char *buf, char *user, char *md5, char *filename){int ret = 0;/*json數(shù)據(jù)如下{"user": "yoyo","md5": "xxx","filename": "xxx"}*///解析json包//解析一個json字符串為cJSON對象cJSON * root = cJSON_Parse(buf);if(NULL == root){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_Parse err\n");ret = -1;goto END;}//返回指定字符串對應(yīng)的json對象//用戶cJSON *child1 = cJSON_GetObjectItem(root, "user");if(NULL == child1){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_GetObjectItem err\n");ret = -1;goto END;}//LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "child1->valuestring = %s\n", child1->valuestring);strcpy(user, child1->valuestring); //拷貝內(nèi)容//文件md5碼cJSON *child2 = cJSON_GetObjectItem(root, "md5");if(NULL == child2){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_GetObjectItem err\n");ret = -1;goto END;}strcpy(md5, child2->valuestring); //拷貝內(nèi)容//文件名字cJSON *child3 = cJSON_GetObjectItem(root, "filename");if(NULL == child3){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_GetObjectItem err\n");ret = -1;goto END;}strcpy(filename, child3->valuestring); //拷貝內(nèi)容END:if(root != NULL){cJSON_Delete(root);//刪除json對象root = NULL;}return ret;}

文件下載標志處理

• 連接redis拿到redis句柄，連接MySQL拿到句柄

• springf字符串拼接成文件標示fileid（md5+filename）
  -mysql的下載量+1：用md5和filename sql查詢出共享文件pv字段，再將pv+1更新pv字段

• 判斷元素是否再集合中（Redis）：

  ret2 = rop_zset_exit(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret2 == 1) //存在{//===3、如果存在，有序集合score+1ret = rop_zset_increment(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "rop_zset_increment 操作失敗\n");}}else if(ret2 == 0) //不存在{//===4、如果不存在，從mysql導(dǎo)入數(shù)據(jù)//===5、redis集合中增加一個元素(redis操作)rop_zset_add(redis_conn, FILE_PUBLIC_ZSET, pv+1, fileid);//===6、redis對應(yīng)的hash也需要變化 (redis操作)// fileid ------> filenamerop_hash_set(redis_conn, FILE_NAME_HASH, fileid, filename);}else//出錯{ret = -1;goto END;}

• 文件分享，文件下載排行榜通過pv下載字段維護，文件下載pv+1，判斷該文件是否再下載榜中（redis中的一個pv作為score的zset），在則將score加1

  int pv_file(char *md5, char *filename){int ret = 0;char sql_cmd[SQL_MAX_LEN] = {0};MYSQL *conn = NULL;char *out = NULL;char tmp[512] = {0};int ret2 = 0;redisContext * redis_conn = NULL;char fileid[1024] = {0};//連接redis數(shù)據(jù)庫redis_conn = rop_connectdb_nopwd(redis_ip, redis_port);if (redis_conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "redis connected error");ret = -1;goto END;}//文件標示，md5+文件名sprintf(fileid, "%s%s", md5, filename);//connect the databaseconn = msql_conn(mysql_user, mysql_pwd, mysql_db);if (conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "msql_conn err\n");ret = -1;goto END;}//設(shè)置數(shù)據(jù)庫編碼，主要處理中文編碼問題mysql_query(conn, "set names utf8");//===1、mysql的下載量+1(mysql操作)//sql語句//查看該共享文件的pv字段sprintf(sql_cmd, "select pv from share_file_list where md5 = '%s' and filename = '%s'", md5, filename);ret2 = process_result_one(conn, sql_cmd, tmp); //執(zhí)行sql語句int pv = 0;if(ret2 == 0){pv = atoi(tmp); //pv字段}else{LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//更新該文件pv字段，+1sprintf(sql_cmd, "update share_file_list set pv = %d where md5 = '%s' and filename = '%s'", pv+1, md5, filename);if (mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//===2、判斷元素是否在集合中(redis操作)ret2 = rop_zset_exit(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret2 == 1) //存在{//===3、如果存在，有序集合score+1ret = rop_zset_increment(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "rop_zset_increment 操作失敗\n");}}else if(ret2 == 0) //不存在{//===4、如果不存在，從mysql導(dǎo)入數(shù)據(jù)//===5、redis集合中增加一個元素(redis操作)rop_zset_add(redis_conn, FILE_PUBLIC_ZSET, pv+1, fileid);//===6、redis對應(yīng)的hash也需要變化 (redis操作)// fileid ------> filenamerop_hash_set(redis_conn, FILE_NAME_HASH, fileid, filename);}else//出錯{ret = -1;goto END;}END:/*下載文件pv字段處理成功：{"code":"016"}失敗：{"code":"017"}*/out = NULL;if(ret == 0){out = return_status("016");}else{out = return_status("017");}if(out != NULL){printf(out);//給前端反饋信息free(out);}if(redis_conn != NULL){rop_disconnect(redis_conn);}if(conn != NULL){mysql_close(conn);}return ret;}

Main

• 簡化項目過程，不做取消文件分享和轉(zhuǎn)存文件的操作，只做文件下載標志的處理

• 用戶在上傳文件后，可以在QT客戶端選擇可以分享的文件，該文件就會顯示在共享列表這個界面上，對共享文件的下載會改變其中pv字段，這也是維護下載榜單的score

• 通過源碼的閱讀，可知，dealsharefile這個url（對應(yīng)的是前端界面上的分享文件），拿到前端的json包（user/md5/filename）去數(shù)據(jù)庫查詢文件pv字段

• 值得注意的是，前端發(fā)起請求時，獲取URL地址“？”攜帶的內(nèi)容解析，是通過環(huán)境變量獲取的，解析出cmd（該URL的請求命令），解析出攜帶的json包（contentLength）

  int main(){char cmd[20];char user[USER_NAME_LEN]; //用戶名char md5[MD5_LEN]; //文件md5碼char filename[FILE_NAME_LEN]; //文件名字//讀取數(shù)據(jù)庫配置信息read_cfg();//阻塞等待用戶連接while (FCGI_Accept() >= 0){// 獲取URL地址 "?" 后面的內(nèi)容char *query = getenv("QUERY_STRING");//解析命令query_parse_key_value(query, "cmd", cmd, NULL);LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cmd = %s\n", cmd);char *contentLength = getenv("CONTENT_LENGTH");int len;printf("Content-type: text/html\r\n\r\n");if( contentLength == NULL ){len = 0;}else{len = atoi(contentLength); //字符串轉(zhuǎn)整型}if (len <= 0){printf("No data from standard input.<p>\n");LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "len = 0, No data from standard input\n");}else{char buf[4*1024] = {0};int ret = 0;ret = fread(buf, 1, len, stdin); //從標準輸入(web服務(wù)器)讀取內(nèi)容if(ret == 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "fread(buf, 1, len, stdin) err\n");continue;}LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "buf = %s\n", buf);get_json_info(buf, user, md5, filename); //解析json信息LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "user = %s, md5 = %s, filename = %s\n", user, md5, filename);if(strcmp(cmd, "pv") == 0) //文件下載標志處理{pv_file(md5, filename);}else if(strcmp(cmd, "cancel") == 0) //取消分享文件{cancel_share_file(user, md5, filename);}else if(strcmp(cmd, "save") == 0) //轉(zhuǎn)存文件{save_file(user, md5, filename);}}}return 0;}

源碼

/*** @file dealsharefile_cgi.c* @brief 共享文件pv字段處理、取消分享、轉(zhuǎn)存文件cgi程序* @author Mike* @version 2.0* @date 2017年3月8日13:25:07*/#include "fcgi_config.h"#include "fcgi_stdio.h"#include <stdio.h>#include <stdlib.h>#include <string.h>#include "make_log.h" //日志頭文件#include "util_cgi.h"#include "deal_mysql.h"#include "cfg.h"#include "cJSON.h"#include "redis_keys.h"#include "redis_op.h"#include <sys/time.h>#define DEALSHAREFILE_LOG_MODULE "cgi"#define DEALSHAREFILE_LOG_PROC "dealsharefile"//mysql 數(shù)據(jù)庫配置信息 用戶名， 密碼， 數(shù)據(jù)庫名稱static char mysql_user[128] = {0};static char mysql_pwd[128] = {0};static char mysql_db[128] = {0};//redis 服務(wù)器ip、端口static char redis_ip[30] = {0};static char redis_port[10] = {0};//讀取配置信息void read_cfg(){//讀取mysql數(shù)據(jù)庫配置信息get_cfg_value(CFG_PATH, "mysql", "user", mysql_user);get_cfg_value(CFG_PATH, "mysql", "password", mysql_pwd);get_cfg_value(CFG_PATH, "mysql", "database", mysql_db);LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "mysql:[user=%s,pwd=%s,database=%s]", mysql_user, mysql_pwd, mysql_db);//讀取redis配置信息get_cfg_value(CFG_PATH, "redis", "ip", redis_ip);get_cfg_value(CFG_PATH, "redis", "port", redis_port);LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "redis:[ip=%s,port=%s]\n", redis_ip, redis_port);}//解析的json包int get_json_info(char *buf, char *user, char *md5, char *filename){int ret = 0;/*json數(shù)據(jù)如下{"user": "yoyo","md5": "xxx","filename": "xxx"}*///解析json包//解析一個json字符串為cJSON對象cJSON * root = cJSON_Parse(buf);if(NULL == root){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_Parse err\n");ret = -1;goto END;}//返回指定字符串對應(yīng)的json對象//用戶cJSON *child1 = cJSON_GetObjectItem(root, "user");if(NULL == child1){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_GetObjectItem err\n");ret = -1;goto END;}//LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "child1->valuestring = %s\n", child1->valuestring);strcpy(user, child1->valuestring); //拷貝內(nèi)容//文件md5碼cJSON *child2 = cJSON_GetObjectItem(root, "md5");if(NULL == child2){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_GetObjectItem err\n");ret = -1;goto END;}strcpy(md5, child2->valuestring); //拷貝內(nèi)容//文件名字cJSON *child3 = cJSON_GetObjectItem(root, "filename");if(NULL == child3){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cJSON_GetObjectItem err\n");ret = -1;goto END;}strcpy(filename, child3->valuestring); //拷貝內(nèi)容END:if(root != NULL){cJSON_Delete(root);//刪除json對象root = NULL;}return ret;}//文件下載標志處理int pv_file(char *md5, char *filename){int ret = 0;char sql_cmd[SQL_MAX_LEN] = {0};MYSQL *conn = NULL;char *out = NULL;char tmp[512] = {0};int ret2 = 0;redisContext * redis_conn = NULL;char fileid[1024] = {0};//連接redis數(shù)據(jù)庫redis_conn = rop_connectdb_nopwd(redis_ip, redis_port);if (redis_conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "redis connected error");ret = -1;goto END;}//文件標示，md5+文件名sprintf(fileid, "%s%s", md5, filename);//connect the databaseconn = msql_conn(mysql_user, mysql_pwd, mysql_db);if (conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "msql_conn err\n");ret = -1;goto END;}//設(shè)置數(shù)據(jù)庫編碼，主要處理中文編碼問題mysql_query(conn, "set names utf8");//===1、mysql的下載量+1(mysql操作)//sql語句//查看該共享文件的pv字段sprintf(sql_cmd, "select pv from share_file_list where md5 = '%s' and filename = '%s'", md5, filename);ret2 = process_result_one(conn, sql_cmd, tmp); //執(zhí)行sql語句int pv = 0;if(ret2 == 0){pv = atoi(tmp); //pv字段}else{LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//更新該文件pv字段，+1sprintf(sql_cmd, "update share_file_list set pv = %d where md5 = '%s' and filename = '%s'", pv+1, md5, filename);if (mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//===2、判斷元素是否在集合中(redis操作)ret2 = rop_zset_exit(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret2 == 1) //存在{//===3、如果存在，有序集合score+1ret = rop_zset_increment(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "rop_zset_increment 操作失敗\n");}}else if(ret2 == 0) //不存在{//===4、如果不存在，從mysql導(dǎo)入數(shù)據(jù)//===5、redis集合中增加一個元素(redis操作)rop_zset_add(redis_conn, FILE_PUBLIC_ZSET, pv+1, fileid);//===6、redis對應(yīng)的hash也需要變化 (redis操作)// fileid ------> filenamerop_hash_set(redis_conn, FILE_NAME_HASH, fileid, filename);}else//出錯{ret = -1;goto END;}END:/*下載文件pv字段處理成功：{"code":"016"}失敗：{"code":"017"}*/out = NULL;if(ret == 0){out = return_status("016");}else{out = return_status("017");}if(out != NULL){printf(out);//給前端反饋信息free(out);}if(redis_conn != NULL){rop_disconnect(redis_conn);}if(conn != NULL){mysql_close(conn);}return ret;}//取消分享文件int cancel_share_file(char *user, char *md5, char *filename){int ret = 0;char sql_cmd[SQL_MAX_LEN] = {0};MYSQL *conn = NULL;redisContext * redis_conn = NULL;char *out = NULL;char fileid[1024] = {0};//連接redis數(shù)據(jù)庫redis_conn = rop_connectdb_nopwd(redis_ip, redis_port);if (redis_conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "redis connected error");ret = -1;goto END;}//connect the databaseconn = msql_conn(mysql_user, mysql_pwd, mysql_db);if (conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "msql_conn err\n");ret = -1;goto END;}//設(shè)置數(shù)據(jù)庫編碼，主要處理中文編碼問題mysql_query(conn, "set names utf8");//文件標示，md5+文件名sprintf(fileid, "%s%s", md5, filename);//===1、mysql記錄操作//sql語句sprintf(sql_cmd, "update user_file_list set shared_status = 0 where user = '%s' and md5 = '%s' and filename = '%s'", user, md5, filename);if (mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//查詢共享文件數(shù)量sprintf(sql_cmd, "select count from user_file_count where user = '%s'", "xxx_share_xxx_file_xxx_list_xxx_count_xxx");int count = 0;char tmp[512] = {0};int ret2 = process_result_one(conn, sql_cmd, tmp); //執(zhí)行sql語句if(ret2 != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//更新用戶文件數(shù)量count字段count = atoi(tmp);if(count == 1){//刪除數(shù)據(jù)sprintf(sql_cmd, "delete from user_file_count where user = '%s'", "xxx_share_xxx_file_xxx_list_xxx_count_xxx");}else{sprintf(sql_cmd, "update user_file_count set count = %d where user = '%s'", count-1, "xxx_share_xxx_file_xxx_list_xxx_count_xxx");}if(mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//刪除在共享列表的數(shù)據(jù)sprintf(sql_cmd, "delete from share_file_list where user = '%s' and md5 = '%s' and filename = '%s'", user, md5, filename);if(mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//===2、redis記錄操作//有序集合刪除指定成員ret = rop_zset_zrem(redis_conn, FILE_PUBLIC_ZSET, fileid);if(ret != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "rop_zset_zrem 操作失敗\n");goto END;}//從hash移除相應(yīng)記錄ret = rop_hash_del(redis_conn, FILE_NAME_HASH, fileid);if(ret != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "rop_hash_del 操作失敗\n");goto END;}END:/*取消分享：成功：{"code":"018"}失敗：{"code":"019"}*/out = NULL;if(ret == 0){out = return_status("018");}else{out = return_status("019");}if(out != NULL){printf(out);//給前端反饋信息free(out);}if(redis_conn != NULL){rop_disconnect(redis_conn);}if(conn != NULL){mysql_close(conn);}return ret;}//轉(zhuǎn)存文件//返回值：0成功，-1轉(zhuǎn)存失敗，-2文件已存在int save_file(char *user, char *md5, char *filename){int ret = 0;char sql_cmd[SQL_MAX_LEN] = {0};MYSQL *conn = NULL;char *out = NULL;int ret2 = 0;char tmp[512] = {0};//connect the databaseconn = msql_conn(mysql_user, mysql_pwd, mysql_db);if (conn == NULL){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "msql_conn err\n");ret = -1;goto END;}//設(shè)置數(shù)據(jù)庫編碼，主要處理中文編碼問題mysql_query(conn, "set names utf8");//查看此用戶，文件名和md5是否存在，如果存在說明此文件存在sprintf(sql_cmd, "select * from user_file_list where user = '%s' and md5 = '%s' and filename = '%s'", user, md5, filename);//返回值： 0成功并保存記錄集，1沒有記錄集，2有記錄集但是沒有保存，-1失敗ret2 = process_result_one(conn, sql_cmd, NULL); //執(zhí)行sql語句, 最后一個參數(shù)為NULLif(ret2 == 2) //如果有結(jié)果，說明此用戶已有此文件{LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s[filename:%s, md5:%s]已存在\n", user, filename, md5);ret = -2; //返回-2錯誤碼goto END;}//文件信息表，查找該文件的計數(shù)器sprintf(sql_cmd, "select count from file_info where md5 = '%s'", md5);ret2 = process_result_one(conn, sql_cmd, tmp); //執(zhí)行sql語句if(ret2 != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}int count = atoi(tmp); //字符串轉(zhuǎn)整型，文件計數(shù)器//LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "count = %s\n", tmp);//1、修改file_info中的count字段，+1 （count 文件引用計數(shù)）sprintf(sql_cmd, "update file_info set count = %d where md5 = '%s'", count+1, md5);if(mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//2、user_file_list插入一條數(shù)據(jù)//當(dāng)前時間戳struct timeval tv;struct tm* ptm;char time_str[128];//使用函數(shù)gettimeofday()函數(shù)來得到時間。它的精度可以達到微妙gettimeofday(&tv, NULL);ptm = localtime(&tv.tv_sec);//把從1970-1-1零點零分到當(dāng)前時間系統(tǒng)所偏移的秒數(shù)時間轉(zhuǎn)換為本地時間//strftime() 函數(shù)根據(jù)區(qū)域設(shè)置格式化本地時間/日期，函數(shù)的功能將時間格式化，或者說格式化一個時間字符串strftime(time_str, sizeof(time_str), "%Y-%m-%d %H:%M:%S", ptm);//sql語句/*-- =============================================== 用戶文件列表-- user 文件所屬用戶-- md5 文件md5-- createtime 文件創(chuàng)建時間-- filename 文件名字-- shared_status 共享狀態(tài), 0為沒有共享， 1為共享-- pv 文件下載量，默認值為0，下載一次加1*/sprintf(sql_cmd, "insert into user_file_list(user, md5, createtime, filename, shared_status, pv) values ('%s', '%s', '%s', '%s', %d, %d)", user, md5, time_str, filename, 0, 0);if(mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//3、查詢用戶文件數(shù)量，更新該字段sprintf(sql_cmd, "select count from user_file_count where user = '%s'", user);count = 0;//返回值： 0成功并保存記錄集，1沒有記錄集，2有記錄集但是沒有保存，-1失敗ret2 = process_result_one(conn, sql_cmd, tmp); //指向sql語句if(ret2 == 1) //沒有記錄{//插入記錄sprintf(sql_cmd, " insert into user_file_count (user, count) values('%s', %d)", user, 1);}else if(ret2 == 0){//更新用戶文件數(shù)量count字段count = atoi(tmp);sprintf(sql_cmd, "update user_file_count set count = %d where user = '%s'", count+1, user);}if(mysql_query(conn, sql_cmd) != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}END:/*返回值：0成功，-1轉(zhuǎn)存失敗，-2文件已存在轉(zhuǎn)存文件：成功：{"code":"020"}文件已存在：{"code":"021"}失敗：{"code":"022"}*/out = NULL;if(ret == 0){out = return_status("020");}else if(ret == -1){out = return_status("022");}else if(ret == -2){out = return_status("021");}if(out != NULL){printf(out);//給前端反饋信息free(out);}if(conn != NULL){mysql_close(conn);}return ret;}int main(){char cmd[20];char user[USER_NAME_LEN]; //用戶名char md5[MD5_LEN]; //文件md5碼char filename[FILE_NAME_LEN]; //文件名字//讀取數(shù)據(jù)庫配置信息read_cfg();//阻塞等待用戶連接while (FCGI_Accept() >= 0){// 獲取URL地址 "?" 后面的內(nèi)容char *query = getenv("QUERY_STRING");//解析命令query_parse_key_value(query, "cmd", cmd, NULL);LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "cmd = %s\n", cmd);char *contentLength = getenv("CONTENT_LENGTH");int len;printf("Content-type: text/html\r\n\r\n");if( contentLength == NULL ){len = 0;}else{len = atoi(contentLength); //字符串轉(zhuǎn)整型}if (len <= 0){printf("No data from standard input.<p>\n");LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "len = 0, No data from standard input\n");}else{char buf[4*1024] = {0};int ret = 0;ret = fread(buf, 1, len, stdin); //從標準輸入(web服務(wù)器)讀取內(nèi)容if(ret == 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "fread(buf, 1, len, stdin) err\n");continue;}LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "buf = %s\n", buf);get_json_info(buf, user, md5, filename); //解析json信息LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "user = %s, md5 = %s, filename = %s\n", user, md5, filename);if(strcmp(cmd, "pv") == 0) //文件下載標志處理{pv_file(md5, filename);}else if(strcmp(cmd, "cancel") == 0) //取消分享文件{cancel_share_file(user, md5, filename);}else if(strcmp(cmd, "save") == 0) //轉(zhuǎn)存文件{save_file(user, md5, filename);}}}return 0;}

總結(jié)

以上是生活随笔為你收集整理的[云盘]共享文件列表的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。