这个示例使用redis代替kafkamq,减少中间间的使用,采用不同的任务批次用不同的队列,方便中止时删除队列