Django + Activemq 和 Web 服务器中的长时间运行连接

Question

多年来，我一直在使用 stomp.py 和 stompest 与 activemq 进行通信，效果很好，但这主要是使用独立的 python 守护程序。

我想使用网络服务器中的这两个库与后端进行通信，但在不为每个请求创建新连接的情况下，我无法找到如何做到这一点。

是否有安全处理网络服务器中 TCP 连接的标准方法？在其他语言中，该级别的某种全局对象将用于连接池。

Answer 1

HTTP 是一种同步协议。每个等待的客户端在等待响应时都会消耗服务器资源（CPU、内存、文件描述符）。这意味着网络服务器必须快速响应。 HTTP Web 服务器不应在响应请求时阻止外部长时间运行的进程。

解决方案是异步处理请求。有两个主要选项：

1. 使用轮询。

   POST 将新任务推送到消息队列：

   POST /api/generate_report
   {
        "report_id": 1337
   }
   

   GET 检查 MQ（或数据库）的结果：

   GET /api/report?id=1337
   {
       "ready": false
   }
   
   GET /api/report?id=1337
   {
       "ready": true,
       "report": "Lorem ipsum..."
   }
   

   Django生态系统中的异步任务通常使用Celery来实现，但你可以直接使用任何MQ。

2. 使用 WebSockets。

有用的链接：

1. What are Long-Polling, Websockets, Server-Sent Events (SSE) and Comet?
2. https://en.wikipedia.org/wiki/Push_technology
3. https://www.reddit.com/r/django/comments/4kcitl/help_in_design_for_long_running_requests/
4. https://realpython.com/asynchronous-tasks-with-django-and-celery/
5. https://blog.heroku.com/in_deep_with_django_channels_the_future_of_real_time_apps_in_django

编辑：

这是一个伪代码示例，说明如何重用与 MQ 的连接：

projectName/appName/services.py:

import stomp

def create_connection():
    conn = stomp.Connection([('localhost', 9998)])
    conn.start()
    conn.connect(wait=True)
    return conn

print('This code will be executed only once per thread')
activemq = create_connection()

projectName/appName/views.py:

from django.http import HttpResponse
from .services import activemq

def index(request):
    activemq.send(message='foo', destination='bar')
    return HttpResponse('Success!')