在老师讲的代码中加入redis的锁机制就可以了,当第10和11个同时判断时,都是会加入队列,加入锁机制保证第10个插入时第11个插不进.

守护进程就是做一个监听，发现队列中有消息就进行消费，

AMQP协议中的核心思想就是生产者和消费者隔离，生产者从不直接将消息发送给队列。生产者通常不知道是否一个消息会被发送到队列中，只是将消息发送到一个交换机。先由Exchange来接收，然后Exchange按照特定的策略转发到Queue进行存储。同理，消费者也是如此。Exchange 就类似于一个交换机，转发各个消息分发到相应的队列中。