共享文件操作

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

變量定義

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

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

• 定義三個static靜態字符數組存放MySQL登錄用戶名密碼和具體使用的數據庫

• 定義兩個static靜態數組存放Redis的ip+port

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

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

讀取配置文件

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

  void read_cfg(){//讀取mysql數據庫配置信息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的配置信息放放到當前目錄上一級下的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 從配置文件中得到相對應的參數** @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);//獲取數據庫用戶名、用戶密碼、數據庫標示等信息extern int get_mysql_info(char *mysql_user, char *mysql_pwd, char *mysql_db);#endif

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

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

cfg.c

#include <stdlib.h>#include <string.h>#include "make_log.h"#include "cfg.h"#include "cJSON.h"/* -------------------------------------------*//*** @brief 從配置文件中得到相對應的參數** @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); //動態分配空間if(buf == NULL){perror("calloc");LOG(CFG_LOG_MODULE, CFG_LOG_PROC, "calloc err\n");ret = -1;goto END;}//讀取文件內容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;}//返回指定字符串對應的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); //拷貝內容cJSON_Delete(root);//刪除json對象END:if(fp != NULL){fclose(fp);}if(buf != NULL){free(buf);}return ret;}//獲取數據庫用戶名、用戶密碼、數據庫標示等信息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數據如下{"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;}//返回指定字符串對應的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); //拷貝內容//文件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); //拷貝內容//文件名字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); //拷貝內容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導入數據//===5、redis集合中增加一個元素(redis操作)rop_zset_add(redis_conn, FILE_PUBLIC_ZSET, pv+1, fileid);//===6、redis對應的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數據庫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;}//設置數據庫編碼，主要處理中文編碼問題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); //執行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導入數據//===5、redis集合中增加一個元素(redis操作)rop_zset_add(redis_conn, FILE_PUBLIC_ZSET, pv+1, fileid);//===6、redis對應的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

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

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

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

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

  int main(){char cmd[20];char user[USER_NAME_LEN]; //用戶名char md5[MD5_LEN]; //文件md5碼char filename[FILE_NAME_LEN]; //文件名字//讀取數據庫配置信息read_cfg();//阻塞等待用戶連接while (FCGI_Accept() >= 0){// 獲取URL地址 "?" 后面的內容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); //字符串轉整型}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服務器)讀取內容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) //轉存文件{save_file(user, md5, filename);}}}return 0;}

源碼

/*** @file dealsharefile_cgi.c* @brief 共享文件pv字段處理、取消分享、轉存文件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 數據庫配置信息 用戶名， 密碼， 數據庫名稱static char mysql_user[128] = {0};static char mysql_pwd[128] = {0};static char mysql_db[128] = {0};//redis 服務器ip、端口static char redis_ip[30] = {0};static char redis_port[10] = {0};//讀取配置信息void read_cfg(){//讀取mysql數據庫配置信息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數據如下{"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;}//返回指定字符串對應的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); //拷貝內容//文件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); //拷貝內容//文件名字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); //拷貝內容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數據庫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;}//設置數據庫編碼，主要處理中文編碼問題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); //執行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導入數據//===5、redis集合中增加一個元素(redis操作)rop_zset_add(redis_conn, FILE_PUBLIC_ZSET, pv+1, fileid);//===6、redis對應的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數據庫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;}//設置數據庫編碼，主要處理中文編碼問題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;}//查詢共享文件數量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); //執行sql語句if(ret2 != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}//更新用戶文件數量count字段count = atoi(tmp);if(count == 1){//刪除數據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;}//刪除在共享列表的數據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移除相應記錄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;}//轉存文件//返回值：0成功，-1轉存失敗，-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;}//設置數據庫編碼，主要處理中文編碼問題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); //執行sql語句, 最后一個參數為NULLif(ret2 == 2) //如果有結果，說明此用戶已有此文件{LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s[filename:%s, md5:%s]已存在\n", user, filename, md5);ret = -2; //返回-2錯誤碼goto END;}//文件信息表，查找該文件的計數器sprintf(sql_cmd, "select count from file_info where md5 = '%s'", md5);ret2 = process_result_one(conn, sql_cmd, tmp); //執行sql語句if(ret2 != 0){LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "%s 操作失敗\n", sql_cmd);ret = -1;goto END;}int count = atoi(tmp); //字符串轉整型，文件計數器//LOG(DEALSHAREFILE_LOG_MODULE, DEALSHAREFILE_LOG_PROC, "count = %s\n", tmp);//1、修改file_info中的count字段，+1 （count 文件引用計數）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插入一條數據//當前時間戳struct timeval tv;struct tm* ptm;char time_str[128];//使用函數gettimeofday()函數來得到時間。它的精度可以達到微妙gettimeofday(&tv, NULL);ptm = localtime(&tv.tv_sec);//把從1970-1-1零點零分到當前時間系統所偏移的秒數時間轉換為本地時間//strftime() 函數根據區域設置格式化本地時間/日期，函數的功能將時間格式化，或者說格式化一個時間字符串strftime(time_str, sizeof(time_str), "%Y-%m-%d %H:%M:%S", ptm);//sql語句/*-- =============================================== 用戶文件列表-- user 文件所屬用戶-- md5 文件md5-- createtime 文件創建時間-- filename 文件名字-- shared_status 共享狀態, 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、查詢用戶文件數量，更新該字段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){//更新用戶文件數量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轉存失敗，-2文件已存在轉存文件：成功：{"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]; //文件名字//讀取數據庫配置信息read_cfg();//阻塞等待用戶連接while (FCGI_Accept() >= 0){// 獲取URL地址 "?" 后面的內容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); //字符串轉整型}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服務器)讀取內容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) //轉存文件{save_file(user, md5, filename);}}}return 0;}

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。