添加一个中间件,取名为内存set,消费者每次消费到了MQ的一条消息的时候,想内存set中插入消费记录,如果消费者消费的消息存在于内存set中,则这条消息被过滤
基于数据库的唯一键,保证重复数据不会被插入多条