你怎么优雅的判断当前队列 worker 消费的当前消息队列中是否有重复的？

讲道理，不要在transaction中执行 job😂

我猜题主是想问这个问题：怎么保证数据库和消息队列强一致性呢？即数据库提交成功消息队列一定写成功，数据库提交失败消息队列一定别他妈给我写进去。

答案是：不存在的。

但是针对你这个问题是有解的。

这个问题本质上就是如何保证两个分布式事务（数据库是一个事务，消息队列是另一个事务）都能优雅的完美执行。这就需要用一些其他办法来保证了。

对于你这个问题其实也很好解决，数据库成功了才去写消息队列，失败了就不写，那么代码就变成了下面这个样子：

try {
    DB::beginTransaction();
    // 逻辑
    DB::commit();
} catch (Throwable $e) {
    DB::rollback();

    throw $e; // 都他妈别往后走了，老子挂了
}

Queue::connection('connection_name')->push(new Job(),null,'queue_name');

这样做数据库跟消息队列就解耦开来了，也防止消息队列挂了影响主流程。现在你只需要关心数据库写成功了，但是消息队列没写进去的问题了。怎么办呢？定期对数据就行，下游没有消费到的数据都跑出来重新扔到队列里就行了。

再多说一句，你自己的代码里写的那段就算能保证数据库和消息队列强一致性，也有一个问题，消息优先于数据库提交成功时进行了消费，这个时候下游是拿不到数据的，一样会出问题。