最近做物联网类的项目，有个需求是要求实现设备的心跳监测设备每15秒发送一次心跳，服务端如果30秒未收到设备的心跳则需要将设备标记为离线

1. 轮询法

最早想到的方案是使用timer或者quartz定时扫描设备表

每次收到心跳后更新设备的上次心跳时间
timer每隔30秒搜索一次数据库，找出上次心跳时间在30之前的任务，标记为下线，并通知用户

但这个方案在数据量较大的时候效率比较低

2. Redis Keyspace Notifications

在 Redis 里面有一些事件，比如键到期、键被删除等。然后我们可以通过配置一些东西来让 Redis 一旦触发这些事件的时候就往特定的channel推一条消息。

Redis默认是关闭这个功能的，我们可以在redis.conf文件中修改 notify-keyspace-events 配置，其值可以是 Ex、Klg 等等。这些字母的具体含义如下所示：

K，表示 keyspace 事件，有这个字母表示会往 __keyspace@<db>__ 频道推消息。
E，表示 keyevent 事件，有这个字母表示会往 __keyevent@<db>__ 频道推消息。
g，表示一些通用指令事件支持，如 DEL、EXPIRE、RENAME 等等。
$，表示字符串（String）相关指令的事件支持。
l，表示列表（List）相关指令事件支持。
s，表示集合（Set）相关指令事件支持。
h，哈希（Hash）相关指令事件支持。
z，有序集（Sorted Set）相关指令事件支持。
x，过期事件，与 g 中的 EXPIRE 不同的是，g 的 EXPIRE 是指执行 EXPIRE key ttl 这条指令的时候顺便触发的事件，而这里是指那个 key 刚好过期的这个时间点触发的事件。
e，驱逐事件，一个 key 由于内存上限而被驱逐的时候会触发的事件。
A，g$lshzxe 的别名。也就是说 AKE 的意思就代表了所有的事件

如果我们删除了在 db 0 中一个叫 foo 的键，那么系统会往两个频道推消息，一个是 del 事件频道推 foo 消息，另一个是 foo 频道推 del 消息，它们小俩口被系统推送的指令分别等价于：

PUBLISH __keyspace@0__:foo del
PUBLISH __keyevent@0__:del foo

其中往 foo 推送 del 的频道名为 __keyspace@0__:foo，即是 "__keyspace@" + DB_NUMBER + "__:" + KEY_NAME；而 del 的频道名为 "__keyevent@" + DB_NUMBER + "__:" + EVENT_NAME

针对我们的需求，只需要开启字符串删除、过期的keyevent事件

notify-keyspace-events "Eg$x

我们为每个设备维护两个key

device:connected:<设备ID> 记录设备的心跳信息，如果存在这个键，说明设备的心跳正常，设置过期时间为30秒
device:disconnected:<设备ID> 记录设备的离线信息，如果存在这个键，说明设备已经离线

当收到设备的心跳时，设置设备的连接key

setex device:connected:<设备ID> 30 <设备ID>
del device:disconnected:<设备ID>

订阅io.vertx.redis.__keyevent@0__:expired通道，当收到device:connected:*事件时，说明有设备超过30秒没有心跳，通过解析key，算出离线的设备ID（消息中不会有数据的value）
订阅io.vertx.redis.__keyevent@0__:del通道，当收到device:disconnected:*事件时，说明有设备从离线中恢复

这个实现有个较大的问题是如果订阅方漏掉了对应的消息，那么设备可能永远不会上线或掉线