当前位置：首页 > news >正文

utdnsmasq源码解析：Rust实现的DNS缓存机制

news 2026/7/3 15:34:29

utdnsmasq源码解析：Rust实现的DNS缓存机制

【免费下载链接】utdnsmasqutdnsmasq is a refactoring of dnsmasq.项目地址: https://gitcode.com/openeuler/utdnsmasq

前往项目官网免费下载：https://ar.openeuler.org/ar/

utdnsmasq是openEuler项目中基于Rust重构的DNS缓存服务，它通过高效的缓存机制提升域名解析性能。本文将深入解析其DNS缓存实现原理，包括数据结构设计、缓存策略及核心功能模块。

DNS缓存的核心价值与实现挑战

DNS缓存是提升网络性能的关键组件，通过存储近期解析结果，可显著减少重复查询带来的网络延迟和带宽消耗。utdnsmasq作为dnsmasq的Rust重构版本，在保持功能兼容性的基础上，通过现代编程语言特性实现了更安全、高效的缓存管理。

Rust的内存安全特性和并发模型为实现高性能缓存提供了天然优势，同时也带来了独特的设计挑战：如何在保证线程安全的前提下，实现高效的缓存插入、查找和淘汰机制。

缓存核心数据结构设计

utdnsmasq的缓存实现集中在src/cache.rs文件中，采用了哈希表+双向链表的经典组合结构，既保证了查询效率，又支持灵活的缓存淘汰策略。

Cache结构体设计

核心结构体Cache包含以下关键成员：

pub struct Cache { pub cache_size: usize, // 缓存容量 pub length: usize, // 当前缓存条目数量 pub head: Option<Rc<RefCell<Crec>>>, // 双向链表头指针 pub tail: Option<Rc<RefCell<Crec>>>, // 双向链表尾指针 pub hash_table: HashMap<usize, Vec<Rc<RefCell<Crec>>>>, // 哈希表存储 pub hash_size: usize, // 哈希表大小 // 其他辅助字段... }

其中Crec（Cache Record）结构体代表缓存条目，包含域名、IP地址、过期时间、标志位等信息。Rust的Rc<RefCell<T>>组合实现了高效的内部可变性和引用计数，确保多线程环境下的安全访问。

哈希表与双向链表的协同工作

哈希表用于快速定位缓存条目，键为域名的哈希值，值为具有相同哈希值的条目列表。双向链表则维护了条目的访问顺序，支持LRU（最近最少使用）淘汰策略：

插入：新条目添加到链表头部
访问：命中的条目移到链表头部
淘汰：当缓存满时，从链表尾部移除最久未使用的条目

缓存淘汰策略实现

utdnsmasq实现了智能的缓存淘汰机制，结合了TTL过期和LRU（最近最少使用）两种策略：

TTL过期清理

cache_scan_free函数负责清理过期条目，支持三种清理模式：

按域名清理：删除指定域名的过期正向解析记录
按地址清理：删除指定IP的过期反向解析记录
全局清理：遍历所有哈希桶，删除所有过期记录

关键代码实现：

fn cache_scan_free( &mut self, name: Option<&str>, addr: Option<AllAddr>, now: SystemTime, flags: u16, ) { // 收集要删除的过期条目 let mut to_remove = Vec::new(); // 根据不同标志执行不同清理逻辑 if flags & F_FORWARD != 0 { // 按域名清理正向记录 let name = name.unwrap(); let index = self.hash_bucket(name); // ...查找并标记过期条目 } else { // 按地址清理反向记录或全局清理 // ...遍历哈希桶查找过期条目 } // 执行删除操作 for crec_rc in to_remove { self.remove_crec(crec_rc); } }

LRU淘汰机制

当缓存达到设定容量（cache_size）时，utdnsmasq会触发LRU淘汰：

// 缓存满时的淘汰逻辑 loop { if self.length + self.new_chain.len() >= self.cache_size { if freed_all != 1 { // 尝试删除尾部最久未使用的条目 if let Some(tail_rc) = self.tail.take() { let tail = tail_rc.borrow(); self.cache_scan_free(Some(&tail.name), tail.addr, now, tail.flags); } self.cache_live_freed += 1; // 记录强制删除计数 } else { // 执行全局过期清理 self.cache_scan_free(None, None, now, 0); freed_all = 1; } continue; } break; }

缓存操作核心流程

缓存插入流程

缓存插入通过cache_start_insert-cache_insert-cache_end_insert三步完成：

准备阶段：cache_start_insert初始化插入状态，清空临时链表
插入阶段：cache_insert将新条目添加到临时链表，检查并处理缓存溢出
提交阶段：cache_end_insert将临时链表中的条目正式添加到哈希表和双向链表

关键代码：

// 开始插入 pub fn cache_start_insert(&mut self) { let mut insert_error = INSERT_ERROR.lock().unwrap(); self.new_chain = Vec::new(); *insert_error = false; } // 插入条目 pub fn cache_insert(/* 参数 */) { // 检查缓存空间，必要时执行淘汰 loop { if self.length + self.new_chain.len() >= self.cache_size { // 执行淘汰逻辑... } break; } // 创建新条目并添加到临时链表 let new_rc = Rc::new(RefCell::new(new)); self.new_chain.push(new_rc); } // 提交插入 pub fn cache_end_insert(&mut self) { let insert_error = INSERT_ERROR.lock().unwrap(); if *insert_error { return; } // 将临时链表中的条目添加到哈希表和双向链表 for tmp in self.new_chain.clone() { self.cache_link(Rc::clone(&tmp)); self.cache_hash(tmp); self.cache_inserted += 1; } self.new_chain = Vec::new(); }

缓存查找流程

cache_find_by_name函数实现了按域名查找缓存的功能，支持轮询（round-robin）机制以实现负载均衡：

pub fn cache_find_by_name( &mut self, crecp: Option<Rc<RefCell<Crec>>>, name: &str, now: SystemTime, prot: u16, ) -> Option<Rc<RefCell<Crec>>> { // 如果提供了前一个结果，返回下一个匹配条目（轮询） if crecp.is_some() { self.match_name.index += 1; if self.match_name.index < self.match_name.match_recoder.len() { // 返回下一个匹配条目 // ... } else { return None; // 没有更多条目 } } else { // 首次查找，收集所有匹配条目 let hash = self.hash_bucket(name); // ...遍历哈希桶查找匹配条目 // 使用round-robin索引选择条目 let current_index = self.round_robin_indices.entry(name.to_string()).or_insert(0); // ...选择并返回条目 } // ...返回结果 }

特殊缓存类型处理

utdnsmasq支持多种特殊类型的缓存条目，通过标志位区分处理：

永不过期条目（F_IMMORTAL）

某些系统关键域名解析结果需要永久缓存，通过F_IMMORTAL标志实现：

// 永不过期条目检查 let is_expired = crecp.flags & F_IMMORTAL == 0 && difftime(now, crecp.ttd) > 0;

DHCP与hosts文件条目

来自DHCP（F_DHCP）和hosts文件（F_HOSTS）的条目具有特殊处理逻辑，不会被常规缓存清理机制删除：

// 保留DHCP和hosts条目 if (is_expired || is_matching_reverse) && (crecp.flags & (F_HOSTS | F_DHCP) == 0) { to_remove.push(Rc::clone(crec_rc)); }

缓存性能优化

哈希函数优化

hash_bucket函数使用简单高效的哈希算法，将域名转换为哈希桶索引：

fn hash_bucket(&self, name: &str) -> usize { let mut val = 0u32; let name_lower = name.to_ascii_lowercase(); // 不区分大小写 for c in name_lower.bytes() { val += c as u32; } (val as usize) & (self.hash_size - 1) // hash_size是2的幂，确保均匀分布 }