3

我的堆栈是Django 1.3(Python 2.7) + Apache + mod_wsgi

Apache为每个请求生成一个新进程......有时在这些请求中，我必须向RabbitMQ发布一条消息，说明稍后要完成的一些繁重任务（比如通知某人的关注者他们刚刚发布的猫照片）。

发布涉及与RabbitMQ建立连接，这很昂贵。（请参阅这个 SO 问题：RabbitMQ 创建连接是一项昂贵的操作）

我也很遗憾地意识到 Python 无法跨进程共享内存......叹息:(

在这种情况下，如何防止每个 apache 请求创建和关闭 RabbitMQ 连接的开销？

为了清晰，这里使用 RabbitMQ + pika 是我在进程之间共享连接的失败尝试：

def test_view(request):
    """a django view publishing to RabbitMQ"""
    connection = Connection.get_shared_connection()
    channel = connection.channel() 
    channel.queue_declare(queue='test_queue', auto_delete=False, durable=True)
    channel.basic_publish(exchange='', routing_key='test_queue', body='Hello Rabbit!', 
                                properties=pika.BasicProperties(delivery_mode=2))
    print 'SENT:', body

    return HttpResponse("published")


class Connection(object):
    """failed attempt to create a singleton"""
    _connection = None

    @staticmethod
    def get_shared_connection(): # return a pika connection
        if not Connection._connection:
            print 'NEW CONNECTION'  # prints NEW CONNECTION with every request
            Connection._connection = pika.BlockingConnection(pika.ConnectionParameters(
                                                                           host='localhost'))
        return Connection._connection

在服务器设置（Django + Apache + mod_wsgi）'NEW CONNECTION'中打印每个请求test_view

这似乎是任何人在使用 Django 和 RabbitMQ 时都会遇到的问题。一定有办法...

谢谢...任何帮助表示赞赏

4

1 回答 1

1

Apache 不会为每个请求生成一个新进程。

您可能会误以为这是因为在嵌入式模式下它可以是一个多进程 Web 服务器，因此不同的请求可能会在单独的进程中得到处理。

我会建议您使用 mod_wsgi 守护程序模式并使用单个多线程进程，但不幸的是，您的代码不是线程安全的，因为您不保护同时从多个线程创建全局套接字连接。但是，仅此一项也无济于事，因为如果多个线程同时尝试使用该一个连接，则可能会导致问题。所以你真的需要每个线程都有一个连接对象。

我建议您阅读以下内容以了解有关 Apache/mod_wsgi 的不同进程/线程模型的一些背景知识。

于 2012-10-25T09:41:50.730 回答