RabbitMQ队列不能被多个消费者服务并行消费

可以使用RabbitMQ的多个消费者服务并行消费的方法是使用多个队列，并将消息按照一定规则分配到不同的队列中。下面是一个使用RabbitMQ和Python的代码示例：

生产者代码：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='task_queue')

messages = ['Message 1', 'Message 2', 'Message 3', 'Message 4', 'Message 5']

for message in messages:
    channel.basic_publish(exchange='',
                          routing_key='task_queue',
                          body=message,
                          properties=pika.BasicProperties(
                              delivery_mode=2,  # make message persistent
                          ))
    print(" [x] Sent %r" % message)

connection.close()

消费者1代码：

import pika
import time

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    time.sleep(1)
    print(" [x] Done")
    ch.basic_ack(delivery_tag=method.delivery_tag)

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='task_queue')
channel.basic_qos(prefetch_count=1)
channel.basic_consume(queue='task_queue', on_message_callback=callback)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

消费者2代码：

import pika
import time

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    time.sleep(2)
    print(" [x] Done")
    ch.basic_ack(delivery_tag=method.delivery_tag)

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='task_queue')
channel.basic_qos(prefetch_count=1)
channel.basic_consume(queue='task_queue', on_message_callback=callback)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

在上面的代码示例中，我们创建了一个名为'task_queue'的队列，并在生产者代码中将消息发送到该队列中。

消费者1代码中的callback函数用于处理队列中的消息，我们在这个函数中模拟了一个耗时1秒的任务。消费者2代码中的callback函数模拟了一个耗时2秒的任务。

在消费者1和消费者2的代码中，我们都使用了channel.basic_qos(prefetch_count=1)方法来设置每次从队列中获取一条消息进行处理。这样可以确保每个消费者在处理完当前消息之前不会获取新的消息，从而实现了并行消费的效果。

需要注意的是，在消费者代码的channel.basic_consume()方法中，我们都使用了相同的队列名字'task_queue'来消费消息。

你可以通过运行生产者代码来发送消息到队列中，然后同时运行消费者1和消费者2的代码来观察并行消费的效果。