背景

营销系统中，客户投诉是业务发展的一大阻碍，一般会过滤掉黑名单高风险账号，并配合频控策略，来减少客诉，进而增加营销效率，减少营销成本，提升营销质量。

营销系统一般是通过大数据分析建模，在 CDP（客户数据平台，以客户为核心，围绕数据融合、人群圈选、用户洞察等提供产品能力）创建营销目标客户群体，黑名单同样也是通过 CDP 维护。下面的图片简单描述了过滤黑名单的处理流程，流程是相对简单的。但是，测试过程中却发现一个问题，对于一个近 30 万的营销群体，整个触达流程需要处理一个多小时，而其中过滤黑名单就占用了近半个小时的时间，业务有点难以接受这个性能。

性能优化

引入多线程优化

其实很容易就能想到，对于调用 RPC 接口这种含有 I/O 操作的场景，可以引入多线程优化，将一个几十万的账号集合拆分为多个子任务提交给线程池处理，从而加快处理速度。从下图可以看出引入多线程后性能有很明显的改善，单线程处理 25 万、50 万个账号的群体分别需要近半小时、近一小时，改为 25 个线程处理后可以分别控制在 1 分钟、2 分钟左右。

引入位图优化

进一步了解 CDP 的底层原理后，会发现这个问题应该还有其他的解决方案，即通过位图优化。CDP 的群体都会有对应的位图文件，也就是说营销客户群体和黑名单群体都是以位图的数据结构存储的，通过 CDP 下载群体的 SDK 就可以获取到位图文件，营销群体的位图与黑名单群体位图进行与非操作（andNot，就是从一个位图中移除另一个位图中存在的元素，而保留不在另一个位图中的元素），得到的新的位图就是过滤掉黑名单账号后的目标客户的位图。代码实现很简单，使用 CDP SDK 的示例代码如下（也可以参考GitHub示例代码，但不适用于 CDP 群体位图处理）：

DataLoader dataLoader = new DataLoader(token, bitMapBaseUrl);
ABitmap customerBitmap = dataLoader.loadGroup(customerGroupCode);
ABitmap blacklistBitmap = dataLoader.loadGroup(blacklistGroupCode);
customerBitmap.andNot(blacklistBitmap);

位图存储相当节省空间，50 万群体的位图文件也就约 2MB 大小。同时位图的与非操作是相当快的，上边例子中的 25 万、50 万的群体都可以在 80 毫秒左右过滤掉黑名单账号。从近半小时、近一小时到几十毫秒这个对比非常惊人了，那么为什么位图的处理速度可以这么快呢？

位图简介

位图原理

位图的基本思想是使用 bit 来标记一个数值，1 表示该数值存在，0 表示不存在。由于以位为单位存储数据，因此可以大大节省存储空间。通过这种方式，可以非常高效地表示和操作数值集合。

举个直观的例子，有 40 亿个不重复的随机自然数，如果使用long型数值存储，一个long型数值 8 个字节，40 亿个数值占用约 29.8GB，但如果是存储为 40 亿个 bit，则只需要约 0.47GB。

在 Java 中一个long型数值占 64 位，可以用一个long型数组long[] words = new long[(nBits - 1) / 64 + 1]存储位图，其中nBits表示位图的初始大小。对于给定任意自然数x，x / 64就能得到x在数组中的下标，x % 64就能得到x在此下标的哪个位。数组的第一个下标words[0]可以表示数值0~63，第二个下标words[1]可以表示数值64~127，之后依此类推。

如果将 3, 4, 6 几个数值存入位图，则如下图所示，对应数组的第一个下标的 3, 4, 6 位被标记为 1，其他位均为 0。

对于添加操作，假设要添加数值2，可以计算出其在数组中的下标为2 / 64即0，在words[0]的位置为2 % 64即2，只需将1按位左移2位，然后和words[0]进行按位或操作，将相应位置置为1。

对于移除操作，假设要移除刚添加的数值2，和添加操作一样，可以通过计算得到其在数组的下标为0, 在words[0]的位置为2，只需将1按位左移2位再按位取反，然后和words[0]进行按位与操作，将相应位置置为0。

而对于查找操作，假设要查找数值3，可以计算得到其在数组的下标为0, 在words[0]的位置为3，只需将1按位左移3位，然后和words[0]按位与操作不等于0即可判断数值是否存在。

以上内容简单介绍了 Java 中的BitSet的实现原理，实际代码还会稍微复杂一些，比如会涉及到数组扩容，范围边界的检测等等。有意思的是BitSet中计算数组下标和位置并没有使用除法和取模，都是通过位移操作实现的，x / 64是通过右移操作x >> 6，1按位左移x % 64位是直接将1左移x位即1 << x。

位图对象还支持一些常用的位运算，如求交集 (and, 按位与操作)，求并集 (or, 按位或操作)，求差集 (andNot, 按位与非操作)。

位图非常节省存储空间，位操作也非常高效，这也是为什么引入位图过滤黑名单能在毫秒级别处理完成的原因。

RoaringBitmap

遗憾的是，BitSet会占用过多内存。如果BitSet中只存储一个数值200000000，通过 GraphLayout 发现BitSet会占用约 23MB 内存，这种情况对空间的浪费极其严重。为了弥补这一缺陷，通常使用压缩位图。

RoaringBitmap是一种压缩位图，其性能往往优于WAH、EWAH或Concise等传统压缩位图。在某些情况下，RoaringBitmap的速度可以快上数百倍，而且压缩效果往往要好得多。它们甚至比未压缩的位图更快。如果使用RoaringBitmap只存储一个数值200000000，只需要 144B 的内存。

RoaringBitmap将一个int数值x划分为高 16 位和低 16 位，高 16 位下标可以通过x >>> 16得到，高位 container 中维护了一个数组，数组的元素中存储了低位 container，低位 container 中的元素数量未达到 4096 时，使用ArrayContainer存储，其内部实现是一个char数组，数组中存放低位数值，达到 4096 后低位 container 会转换为BitmapContainer，其内部实现就是一个位图。此外还有一个RunContainer的实现，不过较少使用。

为什么要使用 4096 这个阈值呢？是因为超过 4096 后，BitmapContainer会比ArrayContainer更节省空间。

存储long型数值时可以使用Roaring64NavigableMap，区别是它会将数值分为高 32 位和低 32 位。CDP 存储人群的位图就是基于Roaring64NavigableMap实现的。

位图的应用场景

位图可以用较少的内存来表示大规模的布尔值集合，节省内存空间，并且支持高效的位操作，如AND、OR、XOR等，使得对集合进行复杂操作变得简单高效，对于存在性查询，位图可以在常数时间内完成，具有高效的查询性能。一些面试题中出现的几十亿数据的去重、排序、计数或者成员查询等问题，都可以通过位图解决，此外还有很多场景应用到了位图。

Java 中的位图应用

ArrayList为了提升性能并节省空间，重写了Collection接口默认的removeIf方法，重写后的方法使用了位图，首先遍历一遍元素用位图标记待删除的元素位置，然后遍历第二遍才真正删除元素，通过这种方式实现，可以高效移除元素，减少不必要的数组复制和元素移动次数，并且使用位图标记待删除位置也没有过多浪费空间。

位图索引

位图索引是一种特别适合于处理具有较少唯一值的列（例如性别、婚姻状况等）查询的数据结构，它在数据仓库等场合中非常有用，因为这些环境通常包含大量的数据读取操作和复杂的布尔逻辑查询，同时数据更新的频率相对较低。位图索引通过将列值映射到位上，并利用位运算来快速完成查询，能够有效提高查询效率，但它不适合那些具有高基数值和频繁更新的场景，因为这些场景下位图索引会占用大量空间并且更新成本很高。

Redis 的位图

Redis 的位图非常适合于处理大量的布尔值数据，例如追踪用户的在线状态、记录用户每日签到或统计活跃用户数量等场景，因为位图通过每个位代表一个布尔值，可以极大地节省存储空间，并且 Redis 提供了丰富的位操作命令来高效地执行各种计算，如统计特定位上值为 1 的数量或者对多个位图进行位运算以实现快速的集合操作，这些特性使得位图在特征标记、实验分组以及 AB 测试等方面也非常有用；但是，需要注意的是，由于 Redis 将位图存储为字符串，因此其大小会受到字符串最大长度的限制，并且当数据量巨大时，对内存的使用效率也是一个需要考虑的因素。

布隆过滤器

数值可以很方便地使用位图处理，但是有些场景需要处理的可能是字符串，比如用户账号、URL 等，一般需要将字符串跟数值做一个映射，CDP 是将用户账号和偏移量 offset 做了一个映射表，再将偏移量 offset 存储到位图。布隆过滤器则是通过多个哈希函数将元素映射到了位图上，它是一种空间效率极高的概率型数据结构，它用于判断一个元素是否在一个集合中，并且能够非常快速地进行查询，常见的应用场景包括网络爬虫中避免重复爬取相同的 URL、数据库中快速判断某个元素是否存在以减少不必要的磁盘 IO 操作、防止缓存击穿，以及各种需要快速集合检测且可以容忍一定误报率的场合，误报是指布隆过滤器可能会错误地判断某个不存在集合中的元素为存在，但它绝不会错误地判断存在的元素为不存在，因此在不需要百分之百准确性的情况下，布隆过滤器是一种非常有用的工具。

总结

通过探讨营销系统中优化黑名单过滤的策略，本文引入了位图这一数据结构，并详细阐述了其背后的实现机制及适用场合。位图特别适用于那些对空间效率和查询速度有极高要求的场景。在处理大数据时，位图通过压缩和优化可以极大地减少内存占用，提升数据处理的性能，希望本文能为大家提供有益的参考和帮助。

作者：京东科技 冯浩

来源：京东云开发者社区 转载请注明来源