python - 一段时间后 Discord api websocket 网关连接断开

Question

我不知道为什么，但它总是断开连接。有时它工作 1 小时，有时更少，有时 2.5 小时左右

import aiohttp
import asyncio
import json
import datetime, time

token = "123"

payload = {
    'op': 2,
    "d": {
        "token": token,
        "properties": {
            "$os": "windows",
            "$browser": "chrome",
            "$device": 'pc'
        }
    }
}



last_sequence = "null"

async def main():
    global last_sequence


    session = aiohttp.ClientSession()
    async with  session.ws_connect('wss://gateway.discord.gg/?v=9&encording=json') as ws:
        async for msg in ws:
            data = json.loads(msg.data)

            if data["op"] == 10:  # Hello
                await ws.send_json(payload)

                # (Keeps the connection alive!)
                asyncio.ensure_future(heartbeat(ws, data['d']['heartbeat_interval']))
            elif data["op"] == 11:  # Heartbeat ACK
                #print("Heartbeat Received")
                pass

            elif data["op"] == 0:  # Dispatch
                try:
                    if data['d']['guild_id']==("669653521007902751") and data['d']['channel_id']==("669653521007902766"):
                        print(f"{data['d']['content']}")
                        last_sequence = data['s']   
                        #print(data)  

                except:
                    pass

            elif data["op"] == 3: # Presence Update 
                print("This is OP 3", data)
            elif data["op"] == 4: # Voice State Update  
                print("This is OP 4", data)
            elif data["op"] == 6: # Resume
                print("This is OP 6", data)
            elif data["op"] == 7: # Reconnect, i don't know how this works. I was just testing it.
                await ws.send_json(
                    {"op": 6,
                        "d": {
                            "token":token,
                            "session_id": "null",
                            "seq": last_sequence
                    }})
                print("This is OP 7", data)
            elif data["op"] == 8: # Request Guild Members   
                print("This is OP 8", data)
            elif data["op"] == 9: # Invalid Session
                print("This is OP 9", data)


            else:
                print("What happened?", data)
                
        #await session.close()
    



async def heartbeat(ws, interval):
    while True:
        await asyncio.sleep(interval / 1000)  # seconds
        await ws.send_json({
            "op": 1,  # Heartbeat
            "d": last_sequence
        })
        print("Heartbeat Sent", last_sequence, time.strftime("%H:%M:%S", time.localtime()))




loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.close()

错误是

This is OP 7 {'t': None, 's': None, 'op': 7, 'd': None}Task was destroyed but it is pending!task: <Task pending name='Task-4' coro=<heartbeat() running at C:\Users\test\Desktop\Discord_Test\aio_test.py:83> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x00000214675B83D0>()]>>

Answer 1

您的错误是在操作码 7 上您没有断开连接。您只是发送简历字符串。您需要完全关闭连接，然后在收到服务器问候后重新连接，发送简历(使用有效的 session_id 和 seq，它们不能为空)。服务器正在关闭您的连接，因为您在它告诉您断开连接/重新连接(操作码 7)后向它发送数据然后您的代码崩溃，因为当服务器终止您的连接时它有一个任务正在等待心跳。

编辑:(您应该存储来自服务器 READY 事件的 session_id(在您确定(op 2)之后，以及您从服务器收到的最后一个“seq”编号，以便在您的恢复字符串中使用它们进行恢复。)

Discord 现在要求您通过向您发送操作码“7”来定期重新连接(无明显原因)。当您收到该操作码时，您应该让您的机器人断开连接并重新连接。然后您应该尝试识别(操作码 2)或恢复(操作码 6)。

如果您有有效的“session_id”和“seq”编号，您应该发送一份简历(op 6)，如果没有，您应该识别(op 2)。 Discord 可能会使用操作码 9(无效 session )来响应恢复，并将“d”设置为 true(可以尝试恢复)或 false(需要重新识别)。您应该重新发送正确的操作码(2 或 6)，具体取决于 d 是真还是假。(您应该不需要断开/重新连接操作码 9，只需重新发送识别/恢复有效负载)

https://discord.com/developers/docs/topics/gateway#reconnect

附加信息:https://github.com/discord/discord-api-docs/commit/d4ccc367966eef95b05c8e82ca6cac333ab586db

最近我遇到了另一个问题，当我发送简历时，discord 总是返回操作码 9。

因此，discord 向我的客户发送了一个 op 7。在收到服务器问候操作码 (10) 后，我重新连接并发送操作 6。然后我立即收到一个操作码 9，即使我绝对 100% 为操作码 6 发送正确的有效负载数据等。然后我必须重新发送一个操作码 2(识别)并开始一个新 session 。

似乎奇怪的不和谐现在让我每次尝试在获得操作码 7 后恢复并重新连接时重新启动我的 session 。如果有人知道为什么会这样，那就太好了。但这并不是什么大不了的事，因为我不认为 discord 会让你重新识别足够的次数来达到每天 1000 次识别的限制

(顺便说一句，我已经尝试过各种等待时间)