掘金 后端 ( ) • 2024-04-03 10:51

在构建IMBoy这样的即时通讯平台时,数据处理的效率至关重要。为了确保用户体验的流畅性和系统的响应速度,IMBoy采用了先进的缓存策略。本文将深入探讨IMBoy项目中的缓存功能,以及它是如何通过Erlang代码实现高效数据处理的。

缓存的核心:depcache

IMBoy项目使用了一个名为depcache的内存缓存服务器,这是一个功能强大的Erlang缓存系统,具有依赖检查、缓存过期和本地进程内查找的功能。depcache是Zotonic项目中所有内存相关缓存策略的核心。它的源码地址:https://github.com/zotonic/depcache

缓存的工作原理

depcache是一个基于内存的键值存储系统,每个存储的键都有一个依赖列表。对于depcache中的每个键,系统会存储以下信息:

  • 键的值;
  • 一个序列号,每次更新请求时都会递增;
  • 键的过期时间(以秒为单位);
  • 一个依赖键的列表(例如,在缓存模板中显示的资源ID);
  • 如果键仍在计算中,一个等待键值的进程列表。

当请求一个键时,缓存会检查键是否存在、未过期,并且所有依赖键的序列号都低于缓存键的序列号。如果键仍然有效,它的值将被返回;否则,该键及其值将从缓存中移除,并返回未定义。

如果键仍在计算中,请求进程将被添加到该键的等待列表中。

缓存的实现

depcache使用ETS(Erlang Term Storage)实现,这是Erlang OTP(Open Telecom Platform)分发的一部分,是一个标准的哈希表实现。Zotonic为depcache创建了以下ETS表:

  • 元数据表:存储所有存储的键、过期时间和依赖键的ETS表。
  • 依赖表:存储每个键的序列号的ETS表。
  • 数据表:存储每个键的数据的ETS表。
  • 等待PID字典:存储所有等待键值到达的进程ID的ETS表。

这些ETS表优化了并行读取,并且通常直接被调用进程访问。这避免了调用进程和depcache进程之间的任何通信。

缓存的维护

depcache进程用于处理:

  • 记忆化,进程等待另一个进程计算的值;
  • 存储(put)请求,序列化序列号递增;
  • 删除请求,也序列化depcache访问。

为了防止depcache变得过大,有一个垃圾收集器进程。垃圾收集器慢慢遍历整个depcache,驱逐过期或无效的键。如果depcache大小超过一定阈值(默认为100 MiB),垃圾收集器会加速并驱逐遇到的所有项目的10%。它会继续驱逐,直到缓存大小低于阈值大小。

缓存的使用

在IMBoy项目中,我们通过imboy_cache.erl模块简化了depcache的使用。这个模块提供了一组API,允许开发者轻松地设置、获取和记忆化缓存值。例如:

imboy_cache:set(a, 1).imboy_cache:get(a).imboy_cache:memo(fun() ->    aend).
device_name(Uid, DID) ->    Key = {user_device_name, Uid, DID},    Fun = fun() -> user_device_repo:device_name(Uid, DID) end,    % 缓存10天    imboy_cache:memo(Fun, Key, 864000).

imboy_cache 模块源码:

https://gitee.com/imboy-pub/imboy/blob/main/apps/imlib/src/imboy_cache.erl

通过这些简单的函数调用,IMBoy能够有效地管理内存中的缓存数据,从而提高整体性能和用户体验。

结语

IMBoy项目的缓存机制是其高性能架构的关键部分之一。通过使用depcache和进程字典记忆化缓存,IMBoy能够提供快速的数据访问,同时保持系统的稳定性和可扩展性。

无论是处理常规的数据检索还是管理复杂的依赖关系,IMBoy的缓存策略都能确保用户享受到流畅、高效的即时通讯体验。

随着IMBoy项目的不断发展,其缓存机制也将继续演进,以满足不断增长的用户需求和技术挑战。