rabbitmq 高并发写压力

为了解决高并发写压力问题，可以采用以下两种方法：

1.消息确认机制
在RabbitMQ中，消息确认机制是指生产者将消息发送到队列后，需要等待RabbitMQ的确认消息，确认消息表示RabbitMQ已经成功接收到了消息。如果RabbitMQ没有收到消息，则会返回一个nack消息，表示消息发送失败。生产者可以根据nack消息进行重试或者其他处理。

2.消息持久化
在RabbitMQ中，消息持久化是指将消息存储到磁盘上，即使RabbitMQ服务器宕机，消息也不会丢失。可以通过将消息标记为持久化来实现消息持久化。在生产者发送消息时，需要将消息标记为持久化，然后在消费者消费消息时，也需要将消息标记为持久化。

下面是一个示例代码，演示了如何使用消息确认机制和消息持久化来解决高并发写压力问题：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 创建队列
channel.queue_declare(queue='hello', durable=True)

# 发送消息
for i in range(10000):
    message = 'Hello World %d' % i
    channel.basic_publish(exchange='',
                          routing_key='hello',
                          body=message,
                          properties=pika.BasicProperties(
                              delivery_mode=2,  # 消息持久化
                          ))
    print("Sent %r" % message)

# 关闭连接
connection.close()