五一期间去韩国游玩，顺便去了朋友公司扯淡去了。 所谓的扯淡，就是过去听技术分享，有python, golang, devops，docker一些话题。总的来说，技术方面跟国内还是有一些差距的。
正题开始，因为业务的各方面的强需求，我们使用了rabbitmq作为消息队列，利用rabbitmq的ack机制来确认消息的可靠性。 但是rabbitmq本身是没有绝对的消息顺序机制的，单个queue在多消费者下不能保证其先后顺序。 另外ack的机制会触发消息重复消费的，需要我们在设计上避免该问题。
该文章写的有些乱，欢迎来喷 ! 另外文章后续不断更新中，请到原文地址查看更新. http://xiaorui.cc/?p=4493
关于消息的重复执行
首先我们可以确认的是，触发消息重复执行的条件会是很苛刻的！ 也就说 在大多数场景下不会触发该条件！！！ 一般出在任务超时，或者没有及时返回状态，引起任务重新入队列，重新消费！ 在rabbtimq里连接的断开也会触发消息重新入队列。
一句话，要不保证消息幂等性，要不就用map记录任务状态.
关于消息的绝对顺序执行
一句话，主动去分配队列，单个消费者。
基于Rabbitmq的多任务处理框架
这里提一下，我们用rabbitmq实现了一个颇为复杂的架构，节省了太多的mq连接及消耗。通过python pika gevent实现的，因py有gil，所以使用多进程来跑多核，进程之间不使用共享变量，而是用队列来传递ack信号。
这里实现的场景是用pika消费rabbitmq，然后把获取到的任务提丢到队列，另一个进程去消费该任务，然后触发ack。
END.
