在线客服系统11.11优惠活动

http {
    upstream backend {
        server backend1.example.com;
        server backend2.example.com;
        server backend3.example.com;
    }

    server {
        listen 80;

        location / {
            proxy_pass http://backend;
        }
    }
}

import pika

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

channel.queue_declare(queue='customer_requests')

def callback(ch, method, properties, body):
    print(f"Received request: {body}")
    # 处理请求逻辑

channel.basic_consume(queue='customer_requests', on_message_callback=callback, auto_ack=True)

print('Waiting for requests. To exit press CTRL+C')
channel.start_consuming()