lua strftime

Lua 中没有内置的 strftime 函数。不过你可以使用 Lua 的 os.date 函数来格式化日期和时间。下面是一个示例： ```lua local time = os.time() -- 获取当前时间的 Unix 时间戳 local formattedTime = os.date("%Y-%m-%d %H:%M:%S", time) -- 格式化时间 print(formattedTime) ``` 这个示例将会打印出当前的日期和时间，格式为 "年-月-日时:分:秒"。你可以根据需要修改格式字符串来得到不同的日期和时间格式。有关格式字符串的更多详细信息，请参考 Lua 官方文档中的 os.date 部分。

录音没有使用lua 而是直接使用的再拨号计划里写的<include> <include> <extension name="outbound_via_gateway"> <condition field="destination_number" expression="^(\d+)$">  <action application="set" data="RECORD_APPEND=true"/> <action application="set" data="RECORD_FORCE=true"/>  <action application="set" data="record_path=/home/recordings/${caller_id_number}_${destination_number}_${strftime(%Y%m%d-%H%M%S)}.wav"/>  <action application="record_session" data="${record_path} stereo 16 raw wait"/>  <action application="set" data="hangup_after_bridge=true"/> <action application="bridge" data="sofia/gateway/121_40_149_63_6086/$1"/> </condition> </extension> </include> 这个就是写的录音逻辑

### 录音文件无声音的排查与配置分析 #### 1. **录音文件格式与录音分支的匹配问题** 在 FreeSWITCH 中，`record_session` 的录音行为会根据录音文件名是否带有后缀来决定使用哪个录音分支。如果录音文件名不带后缀，例如： ```xml <action application="record_session" data="/home/recordings/call"/> ``` 那么录音会使用 `SWITCH_ABC_TYPE_TAP_NATIVE_READ` 分支，录制的是原生音频格式（NATIVE），通常用于内部音频流的直接捕获[^1]。如果文件名带有 `.wav` 后缀： ```xml <action application="record_session" data="/home/recordings/call.wav"/> ``` 则会使用 `SWITCH_ABC_TYPE_READ_PING` 分支，通过音频编码器将音频流写入文件。如果录音文件为空或播放无声音，可能是由于该分支的音频编码或写入逻辑未能正确执行。 #### 2. **媒体流是否成功建立** 录音文件无声音的常见原因是媒体流未建立。在呼叫过程中，如果被叫未接听、忙线或无响应，媒体流将不会建立，导致录音文件为空。例如： ```plaintext Hangup sofia/external/18888888888 [CS_EXCHANGE_MEDIA] [NO_USER_RESPONSE] ``` 表示媒体流未成功交换，录音无法捕获有效音频数据。为确保录音有效，应在媒体流建立后才开始录音，可以使用 `session:answer()` 强制建立媒体流： ```lua session:answer() session:record_session("/home/recordings/call.wav") ``` #### 3. **录音路径与权限问题** 确保录音文件路径存在，并且 FreeSWITCH 有写入权限。例如： ```xml <action application="set" data="record_path=/home/recordings/${caller_id_number}_${destination_number}_${strftime(%Y%m%d-%H%M%S)}.wav"/> ``` 需要确保 `/home/recordings` 目录可写，可以使用以下命令检查和设置权限： ```bash mkdir -p /home/recordings chown freeswitch:freeswitch /home/recordings chmod 755 /home/recordings ``` #### 4. **录音逻辑配置的完整性** 在配置中，使用了以下动作： ```xml <action application="set" data="RECORD_APPEND=true"/> <action application="set" data="RECORD_FORCE=true"/> <action application="set" data="record_path=/home/recordings/${caller_id_number}_${destination_number}_${strftime(%Y%m%d-%H%M%S)}.wav"/> <action application="record_session" data="${record_path} stereo 16 raw wait"/> ``` 其中 `RECORD_APPEND` 和 `RECORD_FORCE` 是用于控制录音行为的全局变量，`record_path` 定义了录音文件路径，`record_session` 的 `stereo 16 raw wait` 参数表示录制双声道、16位深度、原始音频格式并等待录音结束。若录音文件仍然无声音，可能是由于 `record_session` 在媒体流未建立时就开始录音，或者音频编码器未能正确写入数据。建议在录音前加入 `playback` 测试音频流是否正常： ```lua session:answer() session:playback("/path/to/test.wav") session:record_session("/home/recordings/call.wav") ``` #### 5. **日志级别调整以获取更多调试信息** 可以通过调整日志级别获取更多录音和媒体流相关的调试信息： ```bash fs_cli -x "console loglevel DEBUG" ``` 这将显示录音是否成功开始、媒体流是否建立、音频数据是否写入文件等详细信息。 --- ###

/** * Copyright (C) 2008 Happy Fish / YuQing * * FastDFS may be copied only under the terms of the GNU General * Public License V3, which may be found in the FastDFS source kit. * Please visit the FastDFS Home Page http://www.fastken.com/ for more detail. **/ #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <errno.h> #include <limits.h> #include <time.h> #include <unistd.h> #include "fastcommon/logger.h" #include "fastcommon/shared_func.h" #include "fastcommon/sockopt.h" #include "fastcommon/http_func.h" #include "fastcommon/local_ip_func.h" #include "fastdfs/fdfs_define.h" #include "fastdfs/fdfs_global.h" #include "fastdfs/fdfs_http_shared.h" #include "fastdfs/fdfs_client.h" #include "fastdfs/fdfs_shared_func.h" #include "fastdfs/trunk_shared.h" #include "common.h" #define FDFS_MOD_REPONSE_MODE_PROXY 'P' #define FDFS_MOD_REPONSE_MODE_REDIRECT 'R' #define FDFS_CONTENT_TYPE_TAG_STR "Content-type: " #define FDFS_CONTENT_TYPE_TAG_LEN (sizeof(FDFS_CONTENT_TYPE_TAG_STR) - 1) #define FDFS_CONTENT_RANGE_TAG_STR "Content-range: " #define FDFS_CONTENT_RANGE_TAG_LEN (sizeof(FDFS_CONTENT_RANGE_TAG_STR) - 1) static char flv_header[] = "FLV\x1\x1\0\0\0\x9\0\0\0\x9"; #define FDFS_RANGE_LENGTH(range) ((range.end - range.start) + 1) typedef struct tagGroupStorePaths { char group_name[FDFS_GROUP_NAME_MAX_LEN + 1]; int group_name_len; int storage_server_port; FDFSStorePaths store_paths; } GroupStorePaths; static int storage_server_port = FDFS_STORAGE_SERVER_DEF_PORT; static int my_group_name_len = 0; static int group_count = 0; //for multi groups static bool url_have_group_name = false; static bool use_storage_id = false; static bool flv_support = false; //if support flv static char flv_extension[FDFS_FILE_EXT_NAME_MAX_LEN + 1] = {0}; //flv extension name static int flv_ext_len = 0; //flv extension length static char my_group_name[FDFS_GROUP_NAME_MAX_LEN + 1] = {0}; static char response_mode = FDFS_MOD_REPONSE_MODE_PROXY; static GroupStorePaths group_store_paths = NULL; //for multi groups static FDFSHTTPParams g_http_params; static int storage_sync_file_max_delay = 24 3600; static int fdfs_get_params_from_tracker(); static int fdfs_format_http_datetime(time_t t, char buff, const int buff_size); static int fdfs_strtoll(const char s, int64_t value) { char end = NULL; value = strtoll(s, &end, 10); if (end != NULL && end != '\0') { return EINVAL; } return 0; } static int fdfs_load_groups_store_paths(IniContext pItemContext) { char section_name[64]; char pGroupName; int bytes; int result; int i; bytes = sizeof(GroupStorePaths) * group_count; group_store_paths = (GroupStorePaths )malloc(bytes); if (group_store_paths == NULL) { logError("file: "FILE", line: %d, " \ "malloc %d bytes fail, " \ "errno: %d, error info: %s", \ LINE, bytes, errno, STRERROR(errno)); return errno != 0 ? errno : ENOMEM; } for (i=0; i<group_count; i++) { sprintf(section_name, "group%d", i + 1); pGroupName = iniGetStrValue(section_name, "group_name", \ pItemContext); if (pGroupName == NULL) { logError("file: "FILE", line: %d, " \ "section: %s, you must set parameter: " \ "group_name!", LINE, section_name); return ENOENT; } group_store_paths[i].storage_server_port = iniGetIntValue( \ section_name, "storage_server_port", pItemContext, \ FDFS_STORAGE_SERVER_DEF_PORT); group_store_paths[i].group_name_len = snprintf( \ group_store_paths[i].group_name, \ sizeof(group_store_paths[i].group_name), \ "%s", pGroupName); if (group_store_paths[i].group_name_len == 0) { logError("file: "FILE", line: %d, " \ "section: %s, parameter: group_name " \ "can't be empty!", LINE, section_name); return EINVAL; } group_store_paths[i].store_paths.paths = \ storage_load_paths_from_conf_file_ex(pItemContext, \ section_name, false, &group_store_paths[i].store_paths.count, \ &result); if (result != 0) { return result; } } return 0; } int fdfs_mod_init() { IniContext iniContext; int result; int len; int i; char pLogFilename; char pReponseMode; char pIfAliasPrefix; char buff[2 * 1024]; bool load_fdfs_parameters_from_tracker = false; log_init(); trunk_shared_init(); if ((result=iniLoadFromFile(FDFS_MOD_CONF_FILENAME, &iniContext)) != 0) { logError("file: "FILE", line: %d, " \ "load conf file \"%s\" fail, ret code: %d", \ LINE, FDFS_MOD_CONF_FILENAME, result); return result; } do { group_count = iniGetIntValue(NULL, "group_count", &iniContext, 0); if (group_count < 0) { logError("file: "FILE", line: %d, " \ "conf file: %s, group_count: %d is invalid!", \ LINE, FDFS_MOD_CONF_FILENAME, group_count); return EINVAL; } url_have_group_name = iniGetBoolValue(NULL, "url_have_group_name", \ &iniContext, false); if (group_count > 0) { if (!url_have_group_name) { logError("file: "FILE", line: %d, " \ "config file: %s, you must set " \ "url_have_group_name to true to " \ "support multi-group!", \ LINE, FDFS_MOD_CONF_FILENAME); result = ENOENT; break; } if ((result=fdfs_load_groups_store_paths(&iniContext)) != 0) { break; } } else { char pGroupName; pGroupName = iniGetStrValue(NULL, "group_name", &iniContext); if (pGroupName == NULL) { logError("file: "FILE", line: %d, " \ "config file: %s, you must set parameter: " \ "group_name!", LINE, FDFS_MOD_CONF_FILENAME); result = ENOENT; break; } my_group_name_len = snprintf(my_group_name, \ sizeof(my_group_name), "%s", pGroupName); if (my_group_name_len == 0) { logError("file: "FILE", line: %d, " \ "config file: %s, parameter: group_name " \ "can't be empty!", LINE, \ FDFS_MOD_CONF_FILENAME); result = EINVAL; break; } if ((result=storage_load_paths_from_conf_file(&iniContext)) != 0) { break; } } FDFS_CONNECT_TIMEOUT = iniGetIntValue(NULL, "connect_timeout", \ &iniContext, DEFAULT_CONNECT_TIMEOUT); if (FDFS_CONNECT_TIMEOUT <= 0) { FDFS_CONNECT_TIMEOUT = DEFAULT_CONNECT_TIMEOUT; } FDFS_NETWORK_TIMEOUT = iniGetIntValue(NULL, "network_timeout", \ &iniContext, DEFAULT_NETWORK_TIMEOUT); if (FDFS_NETWORK_TIMEOUT <= 0) { FDFS_NETWORK_TIMEOUT = DEFAULT_NETWORK_TIMEOUT; } load_log_level(&iniContext); pLogFilename = iniGetStrValue(NULL, "log_filename", &iniContext); if (pLogFilename != NULL && pLogFilename != '\0') { if ((result=log_set_filename(pLogFilename)) != 0) { break; } } storage_server_port = iniGetIntValue(NULL, "storage_server_port", \ &iniContext, FDFS_STORAGE_SERVER_DEF_PORT); if ((result=fdfs_http_params_load(&iniContext, FDFS_MOD_CONF_FILENAME, \ &g_http_params)) != 0) { break; } pReponseMode = iniGetStrValue(NULL, "response_mode", &iniContext); if (pReponseMode != NULL) { if (strcmp(pReponseMode, "redirect") == 0) { response_mode = FDFS_MOD_REPONSE_MODE_REDIRECT; } } pIfAliasPrefix = iniGetStrValue (NULL, "if_alias_prefix", &iniContext); if (pIfAliasPrefix == NULL) { g_if_alias_prefix = '\0'; } else { snprintf(g_if_alias_prefix, sizeof(g_if_alias_prefix), "%s", pIfAliasPrefix); } load_fdfs_parameters_from_tracker = iniGetBoolValue(NULL, \ "load_fdfs_parameters_from_tracker", \ &iniContext, false); if (load_fdfs_parameters_from_tracker) { result = fdfs_load_tracker_group_ex(&g_tracker_group, \ FDFS_MOD_CONF_FILENAME, &iniContext); } else { storage_sync_file_max_delay = iniGetIntValue(NULL, \ "storage_sync_file_max_delay", \ &iniContext, 24 3600); use_storage_id = iniGetBoolValue(NULL, "use_storage_id", \ &iniContext, false); if (use_storage_id) { result = fdfs_load_storage_ids_from_file( \ FDFS_MOD_CONF_FILENAME, &iniContext); } } } while (false); flv_support = iniGetBoolValue(NULL, "flv_support", \ &iniContext, false); if (flv_support) { char flvExtension; flvExtension = iniGetStrValue (NULL, "flv_extension", \ &iniContext); if (flvExtension == NULL) { flv_ext_len = sprintf(flv_extension, "flv"); } else { flv_ext_len = snprintf(flv_extension, \ sizeof(flv_extension), "%s", flvExtension); } } iniFreeContext(&iniContext); if (result != 0) { return result; } load_local_host_ip_addrs(); if (load_fdfs_parameters_from_tracker) { fdfs_get_params_from_tracker(); } if (group_count > 0) { len = sprintf(buff, "group_count=%d, ", group_count); } else { len = sprintf(buff, "group_name=%s, storage_server_port=%d, " \ "path_count=%d, ", my_group_name, \ storage_server_port, g_fdfs_store_paths.count); for (i=0; i<g_fdfs_store_paths.count; i++) { len += snprintf(buff + len, sizeof(buff) - len, \ "store_path%d=%s, ", i, \ g_fdfs_store_paths.paths[i].path); } } logInfo("fastdfs apache / nginx module v1.21, " "response_mode=%s, " "base_path=%s, " "url_have_group_name=%d, " "%s" "connect_timeout=%d, " "network_timeout=%d, " "tracker_server_count=%d, " "if_alias_prefix=%s, " "local_host_ip_count=%d, " "anti_steal_token=%d, " "token_ttl=%ds, " "anti_steal_secret_key length=%d, " "token_check_fail content_type=%s, " "token_check_fail buff length=%d, " "load_fdfs_parameters_from_tracker=%d, " "storage_sync_file_max_delay=%ds, " "use_storage_id=%d, storage server id/ip count=%d / %d, " "flv_support=%d, flv_extension=%s", response_mode == FDFS_MOD_REPONSE_MODE_PROXY ? "proxy" : "redirect", FDFS_BASE_PATH_STR, url_have_group_name, buff, FDFS_CONNECT_TIMEOUT, FDFS_NETWORK_TIMEOUT, g_tracker_group.server_count, g_if_alias_prefix, g_local_host_ip_count, g_http_params.anti_steal_token, g_http_params.token_ttl, g_http_params.anti_steal_secret_key.length, g_http_params.token_check_fail_content_type, g_http_params.token_check_fail_buff.length, load_fdfs_parameters_from_tracker, storage_sync_file_max_delay, use_storage_id, g_storage_ids_by_id.count, g_storage_ids_by_ip.count, flv_support, flv_extension); if (group_count > 0) { int k; for (k=0; k<group_count; k++) { len = 0; buff = '\0'; for (i=0; i<group_store_paths[k].store_paths.count; i++) { len += snprintf(buff + len, sizeof(buff) - len, \ ", store_path%d=%s", i, \ group_store_paths[k].store_paths.paths[i].path); } logInfo("group %d. group_name=%s, " \ "storage_server_port=%d, path_count=%d%s", \ k + 1, group_store_paths[k].group_name, \ storage_server_port, group_store_paths[k]. \ store_paths.count, buff); } } //print_local_host_ip_addrs(); return 0; } #define OUTPUT_HEADERS(pContext, pResponse, http_status) \ do { \ (pResponse)->status = http_status; \ pContext->output_headers(pContext->arg, pResponse); \ } while (0) static int fdfs_send_boundary(struct fdfs_http_context pContext, struct fdfs_http_response pResponse, const bool bLast) { int result; if ((result=pContext->send_reply_chunk(pContext->arg, false, "\r\n--", 4)) != 0) { return result; } if ((result=pContext->send_reply_chunk(pContext->arg, false, pResponse->boundary, pResponse->boundary_len)) != 0) { return result; } if (bLast) { result = pContext->send_reply_chunk(pContext->arg, true, "--\r\n", 4); } else { result = pContext->send_reply_chunk(pContext->arg, false, "\r\n", 2); } return result; } static int fdfs_send_range_subheader(struct fdfs_http_context pContext, struct fdfs_http_response pResponse, const int index) { char buff[256]; int len; len = snprintf(buff, sizeof(buff), "%s%s\r\n%s%s\r\n\r\n", FDFS_CONTENT_TYPE_TAG_STR, pResponse->range_content_type, FDFS_CONTENT_RANGE_TAG_STR, pResponse->content_ranges[index].content); return pContext->send_reply_chunk(pContext->arg, false, buff, len); } static int fdfs_download_callback(void arg, const int64_t file_size, \ const char data, const int current_size) { struct fdfs_download_callback_args pCallbackArgs; int result; bool bLast; pCallbackArgs = (struct fdfs_download_callback_args )arg; if (!pCallbackArgs->pResponse->header_outputed) { if (!(pCallbackArgs->pContext->if_range && pCallbackArgs->pContext->range_count > 1)) { pCallbackArgs->pResponse->content_length = file_size; } OUTPUT_HEADERS(pCallbackArgs->pContext, pCallbackArgs->pResponse, HTTP_OK); } if (pCallbackArgs->pContext->if_range && pCallbackArgs-> pContext->range_count > 1) { bLast = false; if (pCallbackArgs->sent_bytes == 0) { if ((result=fdfs_send_boundary(pCallbackArgs->pContext, pCallbackArgs->pResponse, false)) != 0) { return result; } if ((result=fdfs_send_range_subheader(pCallbackArgs->pContext, pCallbackArgs->pResponse, pCallbackArgs->range_index)) != 0) { return result; } } } else { bLast = true; } pCallbackArgs->sent_bytes += current_size; return pCallbackArgs->pContext->send_reply_chunk( pCallbackArgs->pContext->arg, (pCallbackArgs->sent_bytes == file_size && bLast) ? 1 : 0, data, current_size); } static void fdfs_do_format_range(const struct fdfs_http_range range, struct fdfs_http_response pResponse) { if (range->start < 0) { pResponse->range_len += sprintf(pResponse->range + pResponse->range_len, \ "%"PRId64, range->start); } else if (range->end == 0) { pResponse->range_len += sprintf(pResponse->range + pResponse->range_len, \ "%"PRId64"-", range->start); } else { pResponse->range_len += sprintf(pResponse->range + pResponse->range_len, \ "%"PRId64"-%"PRId64, \ range->start, range->end); } } static void fdfs_format_range(struct fdfs_http_context pContext, struct fdfs_http_response pResponse) { int i; pResponse->range_len = sprintf(pResponse->range, "%s", "bytes="); for (i=0; i<pContext->range_count; i++) { if (i > 0) { (pResponse->range + pResponse->range_len) = ','; pResponse->range_len++; } fdfs_do_format_range(pContext->ranges + i, pResponse); } } static void fdfs_do_format_content_range(const struct fdfs_http_range range, const int64_t file_size, struct fdfs_http_resp_content_range content_range) { content_range->length = sprintf(content_range->content, "bytes %"PRId64"-%"PRId64"/%"PRId64, range->start, range->end, file_size); } static void fdfs_format_content_range(struct fdfs_http_context pContext, const int64_t file_size, struct fdfs_http_response pResponse) { int i; pResponse->content_range_count = pContext->range_count; for (i=0; i<pContext->range_count; i++) { fdfs_do_format_content_range(pContext->ranges + i, file_size, pResponse->content_ranges + i); } } static int64_t fdfs_calc_download_bytes(struct fdfs_http_context pContext) { int64_t download_bytes; int i; download_bytes = 0; for (i=0; i<pContext->range_count; i++) { download_bytes += FDFS_RANGE_LENGTH(pContext->ranges[i]); } return download_bytes; } static int fdfs_calc_content_length(struct fdfs_http_context pContext, const int64_t download_bytes, const int flv_header_len, const char ext_name, const int ext_len, struct fdfs_http_response pResponse) { int result; int i; int content_type_part_len; int boundary_part_len; pResponse->content_length = download_bytes + flv_header_len; if (pContext->if_range && pContext->range_count > 1) { pResponse->boundary_len = sprintf(pResponse->boundary, "%"PRIx64, get_current_time_us()); sprintf(pResponse->content_type_buff, "multipart/byteranges; boundary=%s", pResponse->boundary); pResponse->content_type = pResponse->content_type_buff; if ((result=fdfs_http_get_content_type_by_extname(&g_http_params, ext_name, ext_len, pResponse->range_content_type, sizeof(pResponse->range_content_type))) != 0) { return result; } content_type_part_len = FDFS_CONTENT_TYPE_TAG_LEN + strlen(pResponse->range_content_type) + 2; boundary_part_len = 4 + pResponse->boundary_len + 2; pResponse->content_length += (pContext->range_count + 1) boundary_part_len; pResponse->content_length += pContext->range_count * content_type_part_len; for (i=0; i<pContext->range_count; i++) { pResponse->content_length += FDFS_CONTENT_RANGE_TAG_LEN + pResponse->content_ranges[i].length + 4; } pResponse->content_length += 2; //last -- } return 0; } static int fdfs_do_check_and_format_range(struct fdfs_http_range range, const int64_t file_size) { if (range->start < 0) { int64_t start; start = range->start + file_size; if (start < 0) { logWarning("file: "FILE", line: %d, " \ "invalid range value: %"PRId64", set to 0", \ LINE, range->start); start = 0; } range->start = start; } else if (range->start >= file_size) { logError("file: "FILE", line: %d, " \ "invalid range start value: %"PRId64 \ ", exceeds file size: %"PRId64, \ LINE, range->start, file_size); return EINVAL; } if (range->end == 0) { range->end = file_size - 1; } else if (range->end >= file_size) { logWarning("file: "FILE", line: %d, " \ "invalid range end value: %"PRId64 \ ", exceeds file size: %"PRId64, \ LINE, range->end, file_size); range->end = file_size - 1; } if (range->start > range->end) { logError("file: "FILE", line: %d, " \ "invalid range value, start: %"PRId64 \ ", exceeds end: %"PRId64, \ LINE, range->start, range->end); return EINVAL; } return 0; } static int fdfs_check_and_format_range(struct fdfs_http_context pContext, const int64_t file_size) { int result; int i; result = 0; for (i=0; i<pContext->range_count; i++) { if ((result=fdfs_do_check_and_format_range(pContext->ranges + i, file_size)) != 0) { return result; } } return 0; } #define FDFS_SET_LAST_MODIFIED(response, pContext, mtime) \ do { \ response.last_modified = mtime; \ fdfs_format_http_datetime(response.last_modified, \ response.last_modified_buff, \ sizeof(response.last_modified_buff)); \ if (pContext->if_modified_since != '\0') \ { \ if (strcmp(response.last_modified_buff, \ pContext->if_modified_since) == 0) \ { \ OUTPUT_HEADERS(pContext, (&response), HTTP_NOTMODIFIED);\ return HTTP_NOTMODIFIED; \ } \ } \ \ /\ logInfo("last_modified: %s, if_modified_since: %s, strcmp=%d", \ response.last_modified_buff, \ pContext->if_modified_since, \ strcmp(response.last_modified_buff, \ pContext->if_modified_since)); \ / \ } while (0) static int fdfs_send_file_buffer(struct fdfs_http_context pContext, const char full_filename, int fd, const int64_t download_bytes, const bool bLast) { char file_trunk_buff[FDFS_OUTPUT_CHUNK_SIZE]; off_t remain_bytes; int read_bytes; int result; remain_bytes = download_bytes; while (remain_bytes > 0) { read_bytes = remain_bytes <= FDFS_OUTPUT_CHUNK_SIZE ? \ remain_bytes : FDFS_OUTPUT_CHUNK_SIZE; if (read(fd, file_trunk_buff, read_bytes) != read_bytes) { result = errno != 0 ? errno : EIO; logError("file: "FILE", line: %d, " \ "read from file %s fail, " \ "errno: %d, error info: %s", LINE, \ full_filename, result, STRERROR(result)); return result; } remain_bytes -= read_bytes; if ((result=pContext->send_reply_chunk(pContext->arg, (remain_bytes == 0 && bLast) ? 1: 0, file_trunk_buff, read_bytes)) != 0) { return result; } } return 0; } int fdfs_http_request_handler(struct fdfs_http_context pContext) { #define HTTPD_MAX_PARAMS 32 char file_id_without_group; char url; char file_id[128]; char uri[512]; int url_len; int uri_len; int flv_header_len; int param_count; int ext_len; KeyValuePair params[HTTPD_MAX_PARAMS]; char p; char filename; const char ext_name; FDFSStorePaths pStorePaths; char true_filename[128]; char full_filename[MAX_PATH_SIZE + 64]; //char content_type[64]; struct stat file_stat; int64_t file_offset; int64_t file_size; int64_t download_bytes; int filename_len; int full_filename_len; int store_path_index; int fd; int result; int http_status; int the_storage_port; int i; struct fdfs_http_response response; FDFSFileInfo file_info; bool bFileExists; bool bSameGroup; //if in my group bool bTrunkFile; FDFSTrunkFullInfo trunkInfo; memset(&response, 0, sizeof(response)); response.status = HTTP_OK; //logInfo("url=%s", pContext->url); url_len = strlen(pContext->url); if (url_len < 16) { logError("file: "FILE", line: %d, " \ "url length: %d < 16", LINE, url_len); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } if (strncasecmp(pContext->url, "http://", 7) == 0) { p = strchr(pContext->url + 7, '/'); if (p == NULL) { logError("file: "FILE", line: %d, " \ "invalid url: %s", LINE, pContext->url); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } uri_len = url_len - (p - pContext->url); url = p; } else { uri_len = url_len; url = pContext->url; } if (uri_len + 1 >= (int)sizeof(uri)) { logError("file: "FILE", line: %d, " \ "uri length: %d is too long, >= %d", LINE, \ uri_len, (int)sizeof(uri)); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } if (url != '/') { uri = '/'; memcpy(uri+1, url, uri_len+1); uri_len++; } else { memcpy(uri, url, uri_len+1); } the_storage_port = storage_server_port; param_count = http_parse_query(uri, params, HTTPD_MAX_PARAMS); if (url_have_group_name) { int group_name_len; snprintf(file_id, sizeof(file_id), "%s", uri + 1); file_id_without_group = strchr(file_id, '/'); if (file_id_without_group == NULL) { logError("file: "FILE", line: %d, " \ "no group name in url, uri: %s", LINE, uri); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } pStorePaths = &g_fdfs_store_paths; group_name_len = file_id_without_group - file_id; if (group_count == 0) { bSameGroup = (group_name_len == my_group_name_len) && \ (memcmp(file_id, my_group_name, \ group_name_len) == 0); } else { int i; bSameGroup = false; for (i=0; i<group_count; i++) { if (group_store_paths[i].group_name_len == \ group_name_len && memcmp(file_id, \ group_store_paths[i].group_name, \ group_name_len) == 0) { the_storage_port = group_store_paths[i]. \ storage_server_port; bSameGroup = true; pStorePaths = &group_store_paths[i].store_paths; break; } } } file_id_without_group++; //skip / } else { pStorePaths = &g_fdfs_store_paths; bSameGroup = true; file_id_without_group = uri + 1; //skip / snprintf(file_id, sizeof(file_id), "%s/%s", \ my_group_name, file_id_without_group); } if (strlen(file_id_without_group) < 22) { logError("file: "FILE", line: %d, " \ "file id is too short, length: %d < 22, " \ "uri: %s", LINE, \ (int)strlen(file_id_without_group), uri); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } if (g_http_params.anti_steal_token) { char token; char ts; int timestamp; token = fdfs_http_get_parameter("token", params, param_count); ts = fdfs_http_get_parameter("ts", params, param_count); if (token == NULL || ts == NULL) { logError("file: "FILE", line: %d, " \ "expect parameter token or ts in url, " \ "uri: %s", LINE, uri); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } timestamp = atoi(ts); if ((result=fdfs_http_check_token( \ &g_http_params.anti_steal_secret_key, \ file_id_without_group, timestamp, token, \ g_http_params.token_ttl)) != 0) { logError("file: "FILE", line: %d, " \ "check token fail, uri: %s, " \ "errno: %d, error info: %s", \ LINE, uri, result, STRERROR(result)); if ((g_http_params.token_check_fail_content_type)) { response.content_length = g_http_params. \ token_check_fail_buff.length; response.content_type = g_http_params. \ token_check_fail_content_type; OUTPUT_HEADERS(pContext, (&response), HTTP_OK); pContext->send_reply_chunk(pContext->arg, 1, \ g_http_params.token_check_fail_buff.buff, g_http_params.token_check_fail_buff.length); return HTTP_OK; } else { OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } } } filename = file_id_without_group; filename_len = strlen(filename); //logInfo("filename=%s", filename); if (storage_split_filename_no_check(filename, \ &filename_len, true_filename, &store_path_index) != 0) { OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } if (bSameGroup) { if (store_path_index < 0 || \ store_path_index >= pStorePaths->count) { logError("file: "FILE", line: %d, " \ "filename: %s is invalid, " \ "invalid store path index: %d, " \ "which < 0 or >= %d", LINE, filename, \ store_path_index, pStorePaths->count); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } } if (fdfs_check_data_filename(true_filename, filename_len) != 0) { OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } if ((result=fdfs_get_file_info_ex1(file_id, false, &file_info)) != 0) { if (result == ENOENT) { http_status = HTTP_NOTFOUND; } else if (result == EINVAL) { http_status = HTTP_BADREQUEST; } else { http_status = HTTP_INTERNAL_SERVER_ERROR; } OUTPUT_HEADERS(pContext, (&response), http_status); return http_status; } if (file_info.file_size >= 0) //normal file { FDFS_SET_LAST_MODIFIED(response, pContext, \ file_info.create_timestamp); } fd = -1; memset(&file_stat, 0, sizeof(file_stat)); if (bSameGroup) { FDFSTrunkHeader trunkHeader; if ((result=trunk_file_stat_ex1(pStorePaths, store_path_index, \ true_filename, filename_len, &file_stat, \ &trunkInfo, &trunkHeader, &fd)) != 0) { bFileExists = false; } else { bFileExists = true; } } else { bFileExists = false; memset(&trunkInfo, 0, sizeof(trunkInfo)); } response.attachment_filename = fdfs_http_get_parameter("filename", \ params, param_count); if (bFileExists) { if (file_info.file_size < 0) //slave or appender file { FDFS_SET_LAST_MODIFIED(response, pContext, \ file_stat.st_mtime); } } else { char redirect; //logInfo("source id: %d", file_info.source_id); //logInfo("source ip addr: %s", file_info.source_ip_addr); //logInfo("create_timestamp: %d", file_info.create_timestamp); if (bSameGroup && (is_local_host_ip(file_info.source_ip_addr) \ || (file_info.create_timestamp > 0 && (time(NULL) - \ file_info.create_timestamp > storage_sync_file_max_delay)))) { if (IS_TRUNK_FILE_BY_ID(trunkInfo)) { if (result == ENOENT) { logError("file: "FILE", line: %d, "\ "logic file: %s not exist", \ LINE, filename); } else { logError("file: "FILE", line: %d, "\ "stat logic file: %s fail, " \ "errno: %d, error info: %s", \ LINE, filename, result, \ STRERROR(result)); } } else { snprintf(full_filename, \ sizeof(full_filename), "%s/data/%s", \ pStorePaths->paths[store_path_index].path, \ true_filename); if (result == ENOENT) { logError("file: "FILE", line: %d, "\ "file: %s not exist", \ LINE, full_filename); } else { logError("file: "FILE", line: %d, "\ "stat file: %s fail, " \ "errno: %d, error info: %s", \ LINE, full_filename, \ result, STRERROR(result)); } } OUTPUT_HEADERS(pContext, (&response), HTTP_NOTFOUND); return HTTP_NOTFOUND; } redirect = fdfs_http_get_parameter("redirect", \ params, param_count); if (redirect != NULL) { logWarning("file: "FILE", line: %d, " \ "redirect again, url: %s", \ LINE, url); OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } if ((file_info.source_ip_addr) == '\0') { logWarning("file: "FILE", line: %d, " \ "can't get ip address of source storage " \ "id: %d, url: %s", LINE, \ file_info.source_id, url); OUTPUT_HEADERS(pContext, (&response), HTTP_INTERNAL_SERVER_ERROR); return HTTP_INTERNAL_SERVER_ERROR; } if (response_mode == FDFS_MOD_REPONSE_MODE_REDIRECT) { char path_split_str; char port_part[16]; char param_split_char; if (pContext->server_port == 80) { port_part = '\0'; } else { sprintf(port_part, ":%d", pContext->server_port); } if (param_count == 0) { param_split_char = '?'; } else { param_split_char = '&'; } if (url != '/') { path_split_str = "/"; } else { path_split_str = ""; } response.redirect_url_len = snprintf( \ response.redirect_url, \ sizeof(response.redirect_url), \ "http://%s%s%s%s%c%s", \ file_info.source_ip_addr, port_part, \ path_split_str, url, \ param_split_char, "redirect=1"); logDebug("file: "FILE", line: %d, " \ "redirect to %s", \ LINE, response.redirect_url); if (pContext->if_range) { fdfs_format_range(pContext, &response); } OUTPUT_HEADERS(pContext, (&response), HTTP_MOVETEMP); return HTTP_MOVETEMP; } else if (pContext->proxy_handler != NULL) { return pContext->proxy_handler(pContext->arg, \ file_info.source_ip_addr); } } ext_name = fdfs_http_get_file_extension(true_filename, \ filename_len, &ext_len); /* if (g_http_params.need_find_content_type) { if (fdfs_http_get_content_type_by_extname(&g_http_params, \ ext_name, ext_len, content_type, sizeof(content_type)) != 0) { if (fd >= 0) { close(fd); } OUTPUT_HEADERS(pContext, (&response), HTTP_SERVUNAVAIL); return HTTP_SERVUNAVAIL; } response.content_type = content_type; } / if (bFileExists) { file_size = file_stat.st_size; } else { bool if_get_file_info; if_get_file_info = pContext->header_only || \ (pContext->if_range && file_info.file_size < 0); if (if_get_file_info) { if ((result=fdfs_get_file_info_ex1(file_id, true, \ &file_info)) != 0) { if (result == ENOENT) { http_status = HTTP_NOTFOUND; } else { http_status = HTTP_INTERNAL_SERVER_ERROR; } OUTPUT_HEADERS(pContext, (&response), http_status); return http_status; } } file_size = file_info.file_size; } flv_header_len = 0; if (pContext->if_range) { if (fdfs_check_and_format_range(pContext, file_size) != 0 || (pContext->range_count > 1 && !g_http_params.support_multi_range)) { if (fd >= 0) { close(fd); } OUTPUT_HEADERS(pContext, (&response), HTTP_RANGE_NOT_SATISFIABLE); return HTTP_RANGE_NOT_SATISFIABLE; } if (pContext->range_count == 1) { download_bytes = FDFS_RANGE_LENGTH(pContext->ranges[0]); } else { download_bytes = fdfs_calc_download_bytes(pContext); } fdfs_format_content_range(pContext, file_size, &response); } else { download_bytes = file_size > 0 ? file_size : 0; //flv support if (flv_support && (flv_ext_len == ext_len && \ memcmp(ext_name, flv_extension, ext_len) == 0)) { char pStart; pStart = fdfs_http_get_parameter("start", \ params, param_count); if (pStart != NULL) { int64_t start; if (fdfs_strtoll(pStart, &start) == 0) { char pEnd; pContext->range_count = 1; pContext->ranges[0].start = start; pContext->ranges[0].end = 0; pEnd = fdfs_http_get_parameter("end", \ params, param_count); if (pEnd != NULL) { int64_t end; if (fdfs_strtoll(pEnd, &end) == 0) { pContext->ranges[0].end = end - 1; } } if (fdfs_check_and_format_range(pContext, file_size) != 0) { if (fd >= 0) { close(fd); } OUTPUT_HEADERS(pContext, (&response), HTTP_BADREQUEST); return HTTP_BADREQUEST; } download_bytes = FDFS_RANGE_LENGTH(pContext->ranges[0]); if (start > 0) { flv_header_len = sizeof(flv_header) - 1; } } } } } //logInfo("flv_header_len: %d", flv_header_len); if (pContext->header_only) { if (fd >= 0) { close(fd); } if (fdfs_calc_content_length(pContext, download_bytes, flv_header_len, ext_name, ext_len, &response) != 0) { OUTPUT_HEADERS(pContext, (&response), HTTP_SERVUNAVAIL); return HTTP_SERVUNAVAIL; } OUTPUT_HEADERS(pContext, (&response), pContext->if_range ? \ HTTP_PARTIAL_CONTENT : HTTP_OK ); return HTTP_OK; } if (fdfs_calc_content_length(pContext, download_bytes, flv_header_len, ext_name, ext_len, &response) != 0) { OUTPUT_HEADERS(pContext, (&response), HTTP_SERVUNAVAIL); return HTTP_SERVUNAVAIL; } if (!bFileExists) { ConnectionInfo storage_server; struct fdfs_download_callback_args callback_args; int64_t file_size; strcpy(storage_server.ip_addr, file_info.source_ip_addr); storage_server.port = the_storage_port; storage_server.sock = -1; callback_args.pContext = pContext; callback_args.pResponse = &response; callback_args.sent_bytes = 0; callback_args.range_index = 0; if (pContext->if_range) { download_bytes = FDFS_RANGE_LENGTH(pContext->ranges[0]); } result = storage_download_file_ex1(NULL, \ &storage_server, file_id, \ pContext->ranges[0].start, download_bytes, \ fdfs_download_callback, &callback_args, &file_size); logDebug("file: "FILE", line: %d, " \ "storage_download_file_ex1 return code: %d, " \ "file id: %s", LINE, result, file_id); if (result == 0) { http_status = HTTP_OK; } if (result == ENOENT) { http_status = HTTP_NOTFOUND; } else { http_status = HTTP_INTERNAL_SERVER_ERROR; } OUTPUT_HEADERS(pContext, (&response), http_status); if (result != 0 || !(pContext->if_range && pContext->range_count > 1)) { return http_status; } for (i=1; i<pContext->range_count; i++) { callback_args.sent_bytes = 0; callback_args.range_index = i; download_bytes = FDFS_RANGE_LENGTH(pContext->ranges[i]); result = storage_download_file_ex1(NULL, &storage_server, file_id, pContext->ranges[i].start, download_bytes, fdfs_download_callback, &callback_args, &file_size); if (result != 0) { return HTTP_INTERNAL_SERVER_ERROR; } } if (fdfs_send_boundary(pContext, &response, true) != 0) { return HTTP_INTERNAL_SERVER_ERROR; } return http_status; } bTrunkFile = IS_TRUNK_FILE_BY_ID(trunkInfo); if (bTrunkFile) { trunk_get_full_filename_ex(pStorePaths, &trunkInfo, \ full_filename, sizeof(full_filename)); full_filename_len = strlen(full_filename); file_offset = TRUNK_FILE_START_OFFSET(trunkInfo) + \ pContext->ranges[0].start; } else { full_filename_len = snprintf(full_filename, \ sizeof(full_filename), "%s/data/%s", \ pStorePaths->paths[store_path_index].path, \ true_filename); file_offset = pContext->ranges[0].start; } if (pContext->send_file != NULL && !bTrunkFile && !(pContext->if_range && pContext->range_count > 1)) { http_status = pContext->if_range ? \ HTTP_PARTIAL_CONTENT : HTTP_OK; OUTPUT_HEADERS(pContext, (&response), http_status); if (flv_header_len > 0) { if (pContext->send_reply_chunk(pContext->arg, \ false, flv_header, flv_header_len) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } } return pContext->send_file(pContext->arg, full_filename, \ full_filename_len, file_offset, download_bytes); } if (fd < 0) { fd = open(full_filename, O_RDONLY); if (fd < 0) { logError("file: "FILE", line: %d, " \ "open file %s fail, " \ "errno: %d, error info: %s", LINE, \ full_filename, errno, STRERROR(errno)); OUTPUT_HEADERS(pContext, (&response), \ HTTP_SERVUNAVAIL); return HTTP_SERVUNAVAIL; } if (file_offset > 0 && lseek(fd, file_offset, SEEK_SET) < 0) { close(fd); logError("file: "FILE", line: %d, " \ "lseek file: %s fail, " \ "errno: %d, error info: %s", \ LINE, full_filename, \ errno, STRERROR(errno)); OUTPUT_HEADERS(pContext, (&response), HTTP_INTERNAL_SERVER_ERROR); return HTTP_INTERNAL_SERVER_ERROR; } } else { if (pContext->ranges[0].start > 0 && \ lseek(fd, pContext->ranges[0].start, SEEK_CUR) < 0) { close(fd); logError("file: "FILE", line: %d, " \ "lseek file: %s fail, " \ "errno: %d, error info: %s", \ LINE, full_filename, \ errno, STRERROR(errno)); OUTPUT_HEADERS(pContext, (&response), HTTP_INTERNAL_SERVER_ERROR); return HTTP_INTERNAL_SERVER_ERROR; } } OUTPUT_HEADERS(pContext, (&response), pContext->if_range ? \ HTTP_PARTIAL_CONTENT : HTTP_OK); if (pContext->if_range && pContext->range_count > 1) { if (fdfs_send_boundary(pContext, &response, false) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } if (fdfs_send_range_subheader(pContext, &response, 0) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } } if (flv_header_len > 0) { if (pContext->send_reply_chunk(pContext->arg, \ false, flv_header, flv_header_len) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } } if (pContext->if_range) { download_bytes = FDFS_RANGE_LENGTH(pContext->ranges[0]); } if (fdfs_send_file_buffer(pContext, full_filename, fd, download_bytes, !(pContext->if_range && pContext->range_count > 1)) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } if (!(pContext->if_range && pContext->range_count > 1)) { close(fd); return HTTP_OK; } for (i=1; i<pContext->range_count; i++) { if (bTrunkFile) { file_offset = TRUNK_FILE_START_OFFSET(trunkInfo) + pContext->ranges[i].start; } else { file_offset = pContext->ranges[i].start; } if (lseek(fd, file_offset, SEEK_SET) < 0) { close(fd); logError("file: "FILE", line: %d, " \ "lseek file: %s fail, " \ "errno: %d, error info: %s", \ LINE, full_filename, \ errno, STRERROR(errno)); return HTTP_INTERNAL_SERVER_ERROR; } if (fdfs_send_boundary(pContext, &response, false) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } if (fdfs_send_range_subheader(pContext, &response, i) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } if (fdfs_send_file_buffer(pContext, full_filename, fd, FDFS_RANGE_LENGTH(pContext->ranges[i]), false) != 0) { close(fd); return HTTP_INTERNAL_SERVER_ERROR; } } close(fd); if (fdfs_send_boundary(pContext, &response, true) != 0) { return HTTP_INTERNAL_SERVER_ERROR; } return HTTP_OK; } static int fdfs_get_params_from_tracker() { IniContext iniContext; int result; bool continue_flag; continue_flag = false; if ((result=fdfs_get_ini_context_from_tracker(&g_tracker_group, &iniContext, &continue_flag,NULL)) != 0) { return result; } storage_sync_file_max_delay = iniGetIntValue(NULL, \ "storage_sync_file_max_delay", \ &iniContext, 24 3600); use_storage_id = iniGetBoolValue(NULL, "use_storage_id", \ &iniContext, false); iniFreeContext(&iniContext); if (use_storage_id) { result = fdfs_get_storage_ids_from_tracker_group( \ &g_tracker_group); } return result; } static int fdfs_format_http_datetime(time_t t, char buff, const int buff_size) { struct tm tm; struct tm ptm; buff = '\0'; if ((ptm=gmtime_r(&t, &tm)) == NULL) { return errno != 0 ? errno : EFAULT; } strftime(buff, buff_size, "%a, %d %b %Y %H:%M:%S GMT", ptm); return 0; } static int fdfs_parse_range(char value, struct fdfs_http_range range) { int result; char pEndPos; if (value == '-') { if ((result=fdfs_strtoll(value, &(range->start))) != 0) { return result; } range->end = 0; return 0; } pEndPos = strchr(value, '-'); if (pEndPos == NULL) { return EINVAL; } pEndPos = '\0'; if ((result=fdfs_strtoll(value, &(range->start))) != 0) { return result; } pEndPos++; //skip - if (pEndPos == '\0') { range->end = 0; } else { if ((result=fdfs_strtoll(pEndPos, &(range->end))) != 0) { return result; } } return 0; } int fdfs_parse_ranges(const char value, struct fdfs_http_context pContext) { / range format: bytes=500-999 bytes=-500 bytes=9500- / #define RANGE_PREFIX_STR "bytes=" #define RANGE_PREFIX_LEN (int)(sizeof(RANGE_PREFIX_STR) - 1) int result; int len; int i; const char p; char buff[256]; char parts[FDFS_MAX_HTTP_RANGES]; len = strlen(value); if (len <= RANGE_PREFIX_LEN + 1) { return EINVAL; } p = value + RANGE_PREFIX_LEN; len -= RANGE_PREFIX_LEN; if (len >= (int)sizeof(buff)) { return EINVAL; } memcpy(buff, p, len); (buff + len) = '\0'; result = 0; pContext->range_count = splitEx(buff, ',', parts, FDFS_MAX_HTTP_RANGES); for (i=0; i<pContext->range_count; i++) { if ((result=fdfs_parse_range(parts[i], pContext->ranges + i)) != 0) { break; } } return result; } commic内容为以上还是报错In file included from /usr/local/fastdfs-nginx-module/src/ngx_http_fastdfs_module.c:6: /usr/local/fastdfs-nginx-module/src/common.c: In function ‘fdfs_mod_init’: /usr/local/fastdfs-nginx-module/src/common.c:230:9: error: ‘FDFS_CONNECT_TIMEOUT’ undeclared (first use in this function); did you mean ‘DEFAULT_CONNECT_TIMEOUT’? 230 | FDFS_CONNECT_TIMEOUT = iniGetIntValue(NULL, "connect_timeout", \ | ^~~~~~~~~~ | DEFAULT_CONNECT_TIMEOUT /usr/local/fastdfs-nginx-module/src/common.c:230:9: note: each undeclared identifier is reported only once for each function it appears in /usr/local/fastdfs-nginx-module/src/common.c:237:9: error: ‘FDFS_NETWORK_TIMEOUT’ undeclared (first use in this function); did you mean ‘DEFAULT_NETWORK_TIMEOUT’? 237 | FDFS_NETWORK_TIMEOUT = iniGetIntValue(NULL, "network_timeout", \ | ^~ | DEFAULT_NETWORK_TIMEOUT /usr/local/fastdfs-nginx-module/src/common.c:376:17: error: ‘FDFS_BASE_PATH_STR’ undeclared (first use in this function) 376 | FDFS_BASE_PATH_STR, url_have_group_name, buff, | ^~ /usr/local/fastdfs-nginx-module/src/common.c: In function ‘fdfs_get_params_from_tracker’: /usr/local/fastdfs-nginx-module/src/common.c:1601:21: error: too few arguments to function ‘fdfs_get_ini_context_from_tracker’ 1601 | if ((result=fdfs_get_ini_context_from_tracker(&g_tracker_group, | ^ In file included from /usr/include/fastdfs/fdfs_client.h:14, from /usr/local/fastdfs-nginx-module/src/common.c:29: /usr/include/fastdfs/tracker_proto.h:323:5: note: declared here 323 | int fdfs_get_ini_context_from_tracker(TrackerServerGroup pTrackerGroup, \ | ^~~~~~~~~ cc -c -I/usr/local/include/luajit-2.1 -pipe -O -W -Wall -Wpointer-arith -Wno-unused-parameter -Werror -g -Wno-error -DNDK_SET_VAR -Wformat-truncation=0 -Wformat-overflow=0 -D_FILE_OFFSET_BITS=64 -DFDFS_OUTPUT_CHUNK_SIZE='2561024' -DFDFS_MOD_CONF_FILENAME='"/etc/fdfs/mod_fastdfs.conf"' -I src/core -I src/event -I src/event/modules -I src/os/unix -I /www/server/nginx/src/ngx_devel_kit/objs -I objs/addon/ndk -I /www/server/nginx/src/lua_nginx_module/src/api -I /www/server/nginx/src/pcre-8.43 -I /www/server/nginx/src/openssl/.openssl/include -I /usr/include/libxml2 -I objs \ -o objs/ngx_modules.o \ objs/ngx_modules.c make[1]: * [objs/Makefile:2254: objs/addon/src/ngx_http_fastdfs_module.o] Error 1 make[1]: * Waiting for unfinished jobs.... make[1]: Leaving directory '/www/server/nginx/src/nginx-1.24.0' make: *** [Makefile:10: build] Error 2

<think>我们正在解决FastDFS编译错误，主要涉及三个问题：1.FDFS_CONNECT_TIMEOUT和FDFS_NETWORK_TIMEOUT未声明2.FDFS_BASE_PATH_STR未声明3.fdfs_get_ini_context_from_tracker函数参数不足根据引用[1]和引用[5]的信息，我们可以推断这些错误通常与头文件包含路径和宏定义有关。解决方案如下：步骤1：确保头文件路径正确在编译时，需要确保FastDFS和FastCommon的头文件路径被正确包含。根据引用[5]中的配置，我们可以看到在fastdfs-nginx-module的config文件中设置了：ngx_module_incs="/usr/include/fastdfs/usr/include/fastcommon/"因此，我们需要检查这两个路径是否存在，以及其中是否包含所需的头文件。步骤2：检查宏定义在FastDFS的较新版本中，这些宏定义通常在头文件中。例如：-FDFS_CONNECT_TIMEOUT和FDFS_NETWORK_TIMEOUT可能在`fdfs_define.h`中定义。-FDFS_BASE_PATH_STR可能在`fdfs_global.h`中定义。如果这些头文件中没有定义，可能是版本问题。可以尝试在代码中显式定义它们，但更推荐的方法是升级FastDFS到最新版本或使用正确的版本。步骤3：修复函数调用参数根据引用[1]和引用[5]的上下文，函数`fdfs_get_ini_context_from_tracker`在新版本中可能需要4个参数。原调用是3个参数，现在需要增加一个参数（通常是组名，可以为NULL）。因此，我们需要将调用改为：`fdfs_get_ini_context_from_tracker(&g_tracker_group,pIniContext,storage_server_index,NULL);`具体操作：1.修改源码中的函数调用：在报错的代码位置（如common.c）找到`fdfs_get_ini_context_from_tracker`调用，将其改为4个参数，最后一个参数为`NULL`。2.检查头文件包含：确保在源文件开头包含了必要的头文件，例如：#include"fdfs_define.h"#include"fdfs_global.h"3.如果头文件中确实没有这些宏，我们可以根据旧版本中的定义手动添加（不推荐，最好使用正确版本）：在包含头文件之前，可以尝试定义：#defineFDFS_CONNECT_TIMEOUT30//默认值#defineFDFS_NETWORK_TIMEOUT60#defineFDFS_BASE_PATH_STR"base_path"但是，根据引用[1]中的错误信息，旧版本中可能使用的是`DEFAULT_CONNECT_TIMEOUT`，而在新版本中已经改为`FDFS_CONNECT_TIMEOUT`。因此，如果头文件中没有`FDFS_CONNECT_TIMEOUT`，我们可以尝试使用旧版本的宏，或者查看FastDFS的更新日志，确定新版本中对应的宏。步骤4：调整fastdfs-nginx-module的config文件根据引用[5]，我们需要确保config文件中的头文件路径正确，并且链接了正确的库。示例配置如下：ngx_module_incs="/usr/include/fastdfs/usr/include/fastcommon/"ngx_module_libs="-lfastcommon-lfdfsclient"另外，检查CFLAGS中是否有必要的定义，如：CFLAGS="$CFLAGS-D_FILE_OFFSET_BITS=64-DFDFS_OUTPUT_CHUNK_SIZE='256*1024'-DFDFS_MOD_CONF_FILENAME='\"/etc/fdfs/mod_fastdfs.conf\"'"步骤5：重新编译在修改后，重新编译Nginx和fastdfs-nginx-module。如果问题仍然存在，我们可以尝试以下步骤：1.确认FastDFS和FastCommon的安装路径，并确保头文件在`/usr/include/fastdfs`和`/usr/include/fastcommon`下。如果不在，可以通过创建软链接解决：sudoln-s/usr/local/include/fastdfs/usr/include/fastdfssudoln-s/usr/local/include/fastcommon/usr/include/fastcommon2.检查FastCommon和FastDFS的版本兼容性。确保它们都是最新版本，或者至少是相互兼容的版本。3.根据引用[2]和引用[3]，注意配置文件中的参数设置，例如connect_timeout。在mod_fastdfs.conf中，确保设置了：connect_timeout=30network_timeout=604.根据引用[4]，如果是集群部署，确保tracker_server配置正确。由于错误信息中提到了`DEFAULT_CONNECT_TIMEOUT`未声明，我们可以尝试在代码中定义这个宏，或者修改代码使用新的宏。具体如下：在FastDFS的全局配置文件（如fdfs_global.c）中，旧版本可能使用：intg_fdfs_connect_timeout=DEFAULT_CONNECT_TIMEOUT;而新版本可能已经改为：intg_fdfs_connect_timeout=FDFS_CONNECT_TIMEOUT;因此，如果我们的FastCommon或FastDFS版本升级后，这个宏被重命名了，我们需要修改代码中所有使用旧宏的地方。但是，我们注意到错误发生在`../common/fdfs_global.c`中，说明这个文件属于FastDFS源码。因此，我们应该在FastDFS的源码中修复这个问题。解决方案：升级FastDFS到最新版本，或者从正确版本的源码中获取这些宏的定义。如果时间紧迫，我们可以临时在fdfs_global.c文件的开头添加：#ifndefDEFAULT_CONNECT_TIMEOUT#defineDEFAULT_CONNECT_TIMEOUT30#endif但这不是长久之计。总结：最根本的解决方法是确保使用正确版本的FastDFS和FastCommon，并且头文件包含路径正确。下面给出具体操作步骤：1.重新安装FastCommon和FastDFS，使用最新版本。gitclonehttps://github.com/happyfish100/libfastcommon.gitcdlibfastcommon./make.shclean./make.sh&&sudo./make.shinstallgitclonehttps://github.com/happyfish100/fastdfs.gitcdfastdfs./make.shclean./make.sh&&sudo./make.shinstall2.安装后，检查头文件是否在`/usr/include/fastdfs`和`/usr/include/fastcommon`中。如果不在，创建软链接。3.重新编译fastdfs-nginx-module，并确保在config文件中设置了正确的头文件路径。4.在Nginx的配置中重新添加fastdfs-nginx-module，并重新编译Nginx。5.部署配置文件（mod_fastdfs.conf等）并启动服务。如果按照以上步骤，应该可以解决编译错误。</think>### 解决 FastDFS 编译错误：符号未声明和函数参数问题 #### 问题根本原因这些编译错误通常由以下原因导致： 1. **头文件包含路径不正确** - 编译器找不到关键头文件（如 `fdfs_define.h`） 2. **版本兼容性问题** - FastDFS 6.0+ 修改了关键宏和函数签名[^1][^5] 3. **环境配置缺失** - 缺少必要的链接库路径 --- ### 完整解决方案 #### 步骤 1：修复头文件包含路径修改 `fastdfs-nginx-module` 的配置文件： ```bash # 编辑模块配置文件 vi /usr/local/fastdfs-nginx-module/src/config ``` ```diff ngx_module_incs="/usr/include/fastdfs /usr/include/fastcommon/ \ - /usr/local/include/fastdfs" + /usr/include/fastcommon /usr/include/libfastcommon/" ``` #### 步骤 2：解决符号未声明问题在 `common.c` 中添加缺失的宏定义（通常在文件开头）： ```c // 添加以下定义（根据实际需求调整默认值） #ifndef FDFS_CONNECT_TIMEOUT #define FDFS_CONNECT_TIMEOUT 30 // 默认30秒 #endif #ifndef FDFS_NETWORK_TIMEOUT #define FDFS_NETWORK_TIMEOUT 60 // 默认60秒 #endif #ifndef FDFS_BASE_PATH_STR #define FDFS_BASE_PATH_STR "base_path" #endif ``` #### 步骤 3：修复函数参数问题修改 `fdfs_get_ini_context_from_tracker` 调用（通常在 `common.c` 1600行附近）： ```diff - fdfs_get_ini_context_from_tracker(&g_tracker_group, pIniContext, storage_server_index); + fdfs_get_ini_context_from_tracker(&g_tracker_group, pIniContext, storage_server_index, NULL); ``` #### 步骤 4：验证头文件存在性检查关键头文件是否存在： ```bash # 检查必需头文件 ls -l /usr/include/fastcommon/{common_define.h,fdfs_define.h} ls -l /usr/include/fastdfs/fdfs_global.h # 若缺失则创建软链接（假设实际安装在/usr/local） sudo ln -s /usr/local/include/fastcommon /usr/include/fastcommon sudo ln -s /usr/local/include/fastdfs /usr/include/fastdfs ``` #### 步骤 5：重新编译安装 ```bash # 进入Nginx源码目录 cd /path/to/nginx/source # 配置时添加必要参数 ./configure \ --add-module=/usr/local/fastdfs-nginx-module/src \ CFLAGS="-I/usr/include/fastcommon -I/usr/include/fastdfs" \ LDFLAGS="-L/usr/local/lib" # 编译安装 make -j$(nproc) sudo make install ``` #### 步骤 6：验证修复结果检查编译日志中是否还有错误： ```bash # 查看最后100行编译日志 tail -n 100 objs/autoconf.err ``` --- ### 关键预防措施 1. **版本兼容性**： - FastDFS ≥ 6.07 - fastdfs-nginx-module ≥ 1.22 - libfastcommon ≥ 1.0.53 2. **环境变量配置**： ```bash # 添加到/etc/profile export CPATH=/usr/include/fastcommon:/usr/include/fastdfs:$CPATH export LIBRARY_PATH=/usr/local/lib:$LIBRARY_PATH ``` 3. **头文件验证**：确保以下头文件包含必要定义： ```c // /usr/include/fastcommon/fdfs_define.h #define FDFS_CONNECT_TIMEOUT 30 #define FDFS_NETWORK_TIMEOUT 60 // /usr/include/fastdfs/fdfs_global.h #define FDFS_BASE_PATH_STR "base_path" ``` > **重要提示**：若使用自定义编译路径，需同步更新 `ngx_module_incs` 和动态链接库路径[^5]。 --- ### 相关问题 1. FastDFS 如何配置多 tracker 服务器实现高可用？ 2. 如何监控 FastDFS 存储节点的磁盘使用情况？ 3. 升级 FastDFS 版本时如何保证数据兼容性？ 4. 为什么修改头文件后需要清除编译缓存？ [^1]: 宏定义变更需同步修改源码和配置文件 [^5]: 头文件路径错误是编译失败的常见原因 [^2]: 参数格式变更需严格遵循新版函数定义

阅读全文

相关推荐

Lua获取系统时间和时间格式化方法及格式化参数

luaEditor6.30

lua学习资料lua学习资料lua学习资料lua学习资料lua学习资料

lua：Go Lua编译器和VM

date:Lua 5.x 的日期和时间模块

Go语言实现的Lua编译器与虚拟机使用指南

Lua 5.x 日期时间模块LuaDate v2.2功能详解

遥感监测基于RADD算法的森林变化检测系统：多区域警报与基线数据可视化建模

paging-compose-common-iossimulatorarm64-3.3.0-alpha02-0.5.1-

axon-test-0.0.15-javadoc.jar

appsync-jvm-0.21.1-beta-javadoc.jar

elasticinference-jvm-1.3.48-javadoc.jar

aws-config-jvm-1.0.55-sources.jar

cloudfrontkeyvaluestore-jvm-1.2.27-javadoc.jar

cybrid-api-organization-java-v0.108.1-sources.jar

基于javaScript+vue实现的年会抽奖程序+源码+项目文档（毕业设计&课程设计&项目开发）

cloudhsmv2-1.0.29-javadoc.jar

pact-jvm-provider-sbt-1.7.jar

jmeter笔记

account-1.3.75-javadoc.jar

大家在看

Engineering_Equation_Solver_-_EES_Pro_10.561.rar

android 文本内容转换为语音

均衡器的代码.zip

STM32+W5500 Modbus-TCP协议功能实现

mssdk10130048en MsSDK u14

最新推荐

遥感监测基于RADD算法的森林变化检测系统：多区域警报与基线数据可视化建模

个人作品：使用React和Material-UI打造的赛车主题个人网站

活动图设计技巧大公开：如何在StarUML中构建高逻辑性的业务流程？

模拟经典运放电路结构

MATLAB模拟无线传感器网络与区块链技术

UML状态图深度剖析：掌握对象生命周期建模的7个关键要点

dbeaver缩小编辑页面

加强Magento管理员密码强度的扩展工具

时序图绘制实战指南：3步提升可读性，精准表达复杂交互流程

postman离线版arm64