从上篇文章可知，每个工作者，都会依次分配到任务。那么如果一个工作者，在处理任务的时候挂掉，这个任务就没有完成，应当交由其他工作者处理。所以应当有一种机制，当一个工作者完成任务时，会反馈消息。
消息确认就是当工作者完成任务后，会反馈给rabbitmq
修改receive.py的内容：
1 def callback(ch, method, properties, body): 2 3 print("received msg...start processing....",body) 4 time.sleep(5) 5 print(" [x] msg process done....",body) 6 ch.basic_ack(delivery_tag = method.delivery_tag)
或者修改：
1 channel.basic_consume(callback, queue=queue_name,no_ack=True)
即使其中一个工作者ctrl+c退出后，正在执行的任务也不会丢失，rabbitmq会将任务重新分配给其他工作者。