【字节跳动】本文摘要展示了几个核心系统组件的实现代码，包括公共头文件、日志工具、雪花ID生成器、推荐引擎和审核引擎。主要内容有：1) 定义了全局类型和常量；2) 实现分级别带时间戳的日志系统；3) 实

本文摘要展示了几个核心系统组件的实现代码包括公共头文件、日志工具、雪花ID生成器、推荐引擎和审核引擎。主要内容有1) 定义了全局类型和常量2) 实现分级别带时间戳的日志系统3) 实现简易雪花ID生成算法4) 推荐引擎支持多路召回和权重排序5) 审核引擎基于字典树实现敏感词检测。这些组件构成了系统的基础框架和关键功能模块。150字第二十八份公共全局通用头文件 common/global.h#ifndefGLOBAL_H#defineGLOBAL_H#include stdio.h#include stdlib.h#include string.h#include time.h#include stdbool.h// 基础类型别名typedef unsigned char uint8_t;typedef unsigned int uint32_t;typedef unsigned long long uint64_t;// 特征维度定义#define FEATURE_DIM_128 128// 日志等级#define LOG_INFO 1#define LOG_WARN 2#define LOG_ERROR 3#endif第二十九份日志工具封装 utils/log.c#include “log.h”void LogPrint(int level, const char *fmt, …){va_list args;va_start(args, fmt);time_t now time(NULL);struct tm *tm_now localtime(now);char level_str[16] {0}; if(level LOG_INFO) snprintf(level_str, sizeof(level_str), INFO); else if(level LOG_WARN) snprintf(level_str, sizeof(level_str), WARN); else if(level LOG_ERROR) snprintf(level_str, sizeof(level_str), ERROR); printf([%04d-%02d-%02d %02d:%02d:%02d] [%s] , tm_now-tm_year1900, tm_now-tm_mon1, tm_now-tm_mday, tm_now-tm_hour, tm_now-tm_min, tm_now-tm_sec, level_str); vprintf(fmt, args); printf(\n); va_end(args);}第三十份日志头文件 utils/log.h#ifndefLOG_H#defineLOG_H#include “…/common/global.h”#include stdarg.hvoid LogPrint(int level, const char *fmt, …);#define LOGI(fmt, …) LogPrint(LOG_INFO, fmt, ##VA_ARGS)#define LOGW(fmt, …) LogPrint(LOG_WARN, fmt, ##VA_ARGS)#define LOGE(fmt, …) LogPrint(LOG_ERROR, fmt, ##VA_ARGS)#endif第三十一份雪花ID生成器 utils/snowflake.c#include “snowflake.h”static uint64_t last_ts 0;static uint16_t seq 0;static const uint16_t max_seq 4095;uint64_t get_timestamp_ms(){return (uint64_t)time(NULL) * 1000;}uint64_t snowflake_gen(){uint64_t now get_timestamp_ms();if(now last_ts){seq;if(seq max_seq){while(get_timestamp_ms() now);now get_timestamp_ms();seq 0;}}else{seq 0;}last_ts now;// 时间戳机器位序列号 简易实现 uint64_t id (now 22) | (1 12) | seq; return id;}第三十二份雪花ID头文件 utils/snowflake.h#ifndefSNOWFLAKE_H#defineSNOWFLAKE_H#include “…/common/global.h”uint64_t get_timestamp_ms();uint64_t snowflake_gen();#endif第三十三份推荐引擎总入口 recommend-engine/rec_engine.c#include “…/common/global.h”#include “…/utils/log.c”#include “…/utils/snowflake.c”#include “rec_struct.h”#include “rec_merge.c”#define MAX_REC_NUM 50// 多路召回统一入口int RecommendEngineDispatch(RecRequest *req, RecItem *out_list, int out_max){if(req NULL || out_list NULL){LOGE(“RecommendEngineDispatch param null”);return 0;}int total 0;RecItem tmp_buf[MAX_REC_NUM] {0};// 兴趣召回 if(req-rec_type 1 || req-rec_type 0) { int cnt InterestRecall(req-uid, tmp_buf total, req-rec_num); total cnt; } // 社交召回 if(req-rec_type 2 || req-rec_type 0) { int cnt SocialRecall(req-uid, tmp_buf total, req-rec_num); total cnt; } // 全局权重排序 RecSortByWeight(tmp_buf, total); // 拷贝输出限制返回数量 int copy_num total out_max ? total : out_max; memcpy(out_list, tmp_buf, copy_num * sizeof(RecItem)); LOGI(RecommendEngineDispatch uid:%llu total:%d return:%d, req-uid, total, copy_num); return copy_num;}第三十四份审核引擎调度入口 audit-engine/audit_engine.c#include “…/common/global.h”#include “…/utils/log.c”#include “audit_struct.h”#include “trie_tree.c”static TrieNode *g_audit_root NULL;// 初始化敏感词树void AuditEngineInit(char **sensitive_words, int word_cnt){g_audit_root TrieNodeCreate();for(int i 0; i word_cnt; i){TrieInsert(g_audit_root, sensitive_words[i]);}LOGI(“AuditEngineInit load sensitive word count:%d”, word_cnt);}// 单任务审核执行AuditResult AuditTaskRun(AuditTask *task){AuditResult res {0};res.task_id task-task_id;res.audit_result 1; // 默认正常// 文本敏感词检测 if(task-audit_type 1) { bool has_sensitive TrieSearch(g_audit_root, task-content); if(has_sensitive) { res.audit_result 2; snprintf(res.reason, sizeof(res.reason), 包含敏感词汇); LOGW(AuditTaskRun task:%llu detect sensitive word, task-task_id); } else { snprintf(res.reason, sizeof(res.reason), 文本内容正常); } } else { // 图片/视频/音频 默认待人工复审 res.audit_result 3; snprintf(res.reason, sizeof(res.reason), 非文本内容待人工复审); } return res;}第三十五份支付账务解析配置工具 pay-ledger/pay_config.c#include “…/common/global.h”#include “…/utils/log.c”// 简易yml配置解析结构体typedef struct{int server_port;int server_timeout;char wechat_pay_url[128];char alipay_url[128];int tax_auto_hour;char archive_path[128];bool exclude_monthly;int settle_day_cycle;float service_fee_rate;} PayLedgerConfig;// 加载pay.yml配置模拟解析int PayConfigLoad(PayLedgerConfig *cfg){memset(cfg, 0, sizeof(PayLedgerConfig));cfg-server_port 8095;cfg-server_timeout 5000;snprintf(cfg-wechat_pay_url, sizeof(cfg-wechat_pay_url), https://pay.weixin.qq.com); snprintf(cfg-alipay_url, sizeof(cfg-alipay_url), https://openapi.alipay.com); cfg-tax_auto_hour 3; snprintf(cfg-archive_path, sizeof(cfg-archive_path), /data/ledger/buffer/); cfg-exclude_monthly true; cfg-settle_day_cycle 7; cfg-service_fee_rate 0.10f; LOGI(PayConfigLoad success port:%d tax_hour:%d rate:%.2f, cfg-server_port, cfg-tax_auto_hour, cfg-service_fee_rate); return 0;}第三十六份税务自动结算任务 pay-ledger/tax_task.c#include “…/common/global.h”#include “…/utils/log.c”#include “pay_config.c”// 定时税务归档执行void TaxBufferAutoRun(PayLedgerConfig *cfg){LOGI(“TaxBufferAutoRun start hour:%d path:%s”,cfg-tax_auto_hour, cfg-archive_path);// 模拟按月排除归档逻辑 if(cfg-exclude_monthly) { LOGI(TaxBufferAutoRun exclude monthly archive); } else { LOGI(TaxBufferAutoRun execute monthly archive); } LOGI(TaxBufferAutoRun finish settle_cycle:%d fee_rate:%.2f, cfg-settle_day_cycle, cfg-service_fee_rate);}