Django频道+在post请求后发送websocket消息

2024-09-19 23:45:20 发布

您现在位置:Python中文网/ 问答频道 /正文

我的应用程序有问题。我的django通道和websocket工作得非常好,当我从JS(呈现的html内部)发送消息时,消息将进入websocket,然后再进入数据库(异步)。但是,当我尝试在POST请求呈现之前发送消息时,它会抛出一个错误

#here everything works fine:
def room(request, room_name):

    messages = message.objects.all()
    texts = []
    
    for i in messages:
        texts.append(i.text)
        
    last_lines = texts[-20:]
    
    vars = {
        "room_name": room_name,
        "messages": last_lines,
    }
    print()

    if request.method == "POST":
        vars["post_d"] = request.POST.get("desc")
        print(vars["post_d"])

        # ws = create_connection("ws://127.0.0.1:8000/ws/chat/loobby/")
        # time.sleep(2)
        # ws.send(json.dumps({"message": message}))

        return render(request, "chat/room.html", vars)

    return render(request, "chat/room.html", vars)
#=======================================================
System check identified no issues (0 silenced).
July 12, 2021 - 08:26:23
Django version 3.1.3, using settings 'onionChat.settings'
Starting ASGI/Channels version 3.0.3 development server at http://127.0.0.1:8000/
Quit the server with CTRL-BREAK.

Post request from c# console app
HTTP POST /chat/loobby/ 200 [0.10, 127.0.0.1:3261]

我的test.py文件发送python websocket消息(也可以正常工作)的更改显示在web浏览器的db和websocket中

import json
import time
import asyncio
from websocket import create_connection

async def send(message):
    ws = create_connection("ws://127.0.0.1:8000/ws/chat/loobby/")
    time.sleep(2)
    ws.send(json.dumps({"message": message}))
    print("here")

if __name__ == "__main__":
    asyncio.run(send("nothing"))

#==================================================================
System check identified no issues (0 silenced).
July 12, 2021 - 08:29:48
Django version 3.1.3, using settings 'onionChat.settings'
Starting ASGI/Channels version 3.0.3 development server at http://127.0.0.1:8000/
Quit the server with CTRL-BREAK.
WebSocket HANDSHAKING /ws/chat/loobby/ [127.0.0.1:1032]
WebSocket CONNECT /ws/chat/loobby/ [127.0.0.1:1032]
WebSocket DISCONNECT /ws/chat/loobby/ [127.0.0.1:1032]
added message to db

但当我试图发送websocket消息并在返回render之后,它会抛出一个错误

def room(request, room_name):

    messages = message.objects.all()
    texts = []

    for i in messages:
        texts.append(i.text)

    last_lines = texts[-20:]

    vars = {
        "room_name": room_name,
        "messages": last_lines,
    }
    print()

    if request.method == "POST":
        vars["post_d"] = request.POST.get("desc")
        print(vars["post_d"])

        ws = create_connection("ws://127.0.0.1:8000/ws/chat/loobby/")
        time.sleep(2) 
        ws.send(json.dumps({"message": message}))

    return render(request, "chat/room.html", vars)
#==================================================================
System check identified no issues (0 silenced).
July 12, 2021 - 08:34:51
Django version 3.1.3, using settings 'onionChat.settings'
Starting ASGI/Channels version 3.0.3 development server at http://127.0.0.1:8000/
Quit the server with CTRL-BREAK.

Post request from c# console app
WebSocket HANDSHAKING /ws/chat/loobby/ [127.0.0.1:30427]
WebSocket DISCONNECT /ws/chat/loobby/ [127.0.0.1:30427]
Internal Server Error: /chat/loobby/
Traceback (most recent call last):
  File "C:\Program Files\Python39\lib\site-packages\asgiref\sync.py", line 339, in thread_handler
    raise exc_info[1]
  File "C:\Program Files\Python39\lib\site-packages\django\core\handlers\exception.py", line 38, in inner
    response = await get_response(request)
  File "C:\Program Files\Python39\lib\site-packages\django\core\handlers\base.py", line 231, in _get_response_async
    response = await wrapped_callback(request, *callback_args, **callback_kwargs)
  File "C:\Program Files\Python39\lib\site-packages\asgiref\sync.py", line 304, in __call__
    ret = await asyncio.wait_for(future, timeout=None)
  File "C:\Program Files\Python39\lib\asyncio\tasks.py", line 442, in wait_for
    return await fut
  File "C:\Program Files\Python39\lib\concurrent\futures\thread.py", line 52, in run
    result = self.fn(*self.args, **self.kwargs)
  File "C:\Program Files\Python39\lib\site-packages\asgiref\sync.py", line 343, in thread_handler
    return func(*args, **kwargs)
  File "C:\Users\Алексей\Desktop\dev\OnionChat\onionChat\chat\views.py", line 48, in room
    ws = create_connection("ws://127.0.0.1:8000/ws/chat/loobby/")
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_core.py", line 595, in create_connection
    websock.connect(url, **options)
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_core.py", line 252, in connect
    self.handshake_response = handshake(self.sock, *addrs, **options)
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_handshake.py", line 59, in handshake
    status, resp = _get_resp_headers(sock)
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_handshake.py", line 143, in _get_resp_headers
    status, resp_headers, status_message = read_headers(sock)
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_http.py", line 300, in read_headers
    line = recv_line(sock)
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_socket.py", line 136, in recv_line
    c = recv(sock, 1)
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_socket.py", line 115, in recv
    bytes_ = _recv()
  File "C:\Users\Алексей\AppData\Roaming\Python\Python39\site-packages\websocket\_socket.py", line 92, in _recv
    return sock.recv(bufsize)
ConnectionResetError: [WinError 10054] Удаленный хост принудительно разорвал существующее подключение
HTTP POST /chat/loobby/ 500 [4.97, 127.0.0.1:30426]

还有我的c代码,但我认为问题不在这里

static void post_command(string command)
        {
            using (var client = new WebClient())
            {
                client.Timeout = 600 * 60 * 1000;
                
                client.Headers["User-Agent"] = "Mozilla/5.0";
                var values = new NameValueCollection();
                values["desc"] = $"{command}"; 
                client.UploadValues(link, values);
                //var responseString = Encoding.Default.GetString(response);
                //Console.Write(responseString);
            }
        }

Tags: inpymessagewsrequestpackageslinechat