解决Redis队列重复执行问题（redis 队列重复执行）

在使用Redis队列作为消息队列时，由于同一条消息可能会被多次投入队列，如果没有有效的限制，就会导致消息的重复执行，这是在开发过程中必须要解决的问题。解决重复消息执行的一种方法是采用幂等。我们可以为每一条入队消息生成一个唯一标识，并将这个标识存在Redis中，当消息被消费时，如果该标识已经存在，则视为重复消息，不做任何处理。

下面以PHP语言为例，给出一个具体的解决方案。

在发布消息时，消息内容里增加messageID值，messageID可以使用uuid或者消息发出的时间戳（如果消息发出的时间不会重复）等来标识。

在消费消息时，先读取messageID值，然后将messageID值设置到一个redis键，当消费下一个消息时，先读取messageID，查询该键是否存在，如果存在，则认为是重复消息，则忽略消费。

下面是该实现方案的代码：

$msg = $redis->rPop();
// 读取消息的messageID
$msgID = $msg['messageID'];
// 使用messageID设置redis键
$key = "lQueue:" . $msgID;
// 查询该键是否存在
if($redis->exists($key)){
    // 如果存在，则忽略处理
    return;
}else{
    // 设置该键，5分钟过期
    $redis->set($key,1, array('EX',300));
    // 处理消息内容
    ......
}

以上是解决Redis队列重复执行问题的一种有效解决方案，它采用在消息入队时使用唯一标识messageID，在取出时，使用对应的messageID去验证，可有效避免同一条消息重复投入队列和重复执行的问题。此外，在实际应用过程中，也可以根据实际的使用情况，进行自己的定制，保证更加可靠的消息队列服务。

香港服务器首选后浪云，2H2G首月10元开通。
后浪云（www.IDC.Net）提供简单好用，价格厚道的香港/美国云服务器和独立服务器。IDC+ISP+ICP资质。ARIN和APNIC会员。成熟技术团队15年行业经验。