我不知道为什么,但它总是断开连接。有时它工作 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>()]>>
最佳答案
您的错误是在操作码 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 次识别的限制
(顺便说一句,我已经尝试过各种等待时间)
https://stackoverflow.com/questions/69936450/
相关文章:
git - 重新启用 Visual Studio Code GitHub 身份验证
c# - 由于 XmlSerialization (sgen.exe) 无法在 Visual Stu
node.js - 在配置数据库时连接详细信息不可用 Digital Ocean
python - IPywidgets 观察包裹在一个类中时不起作用
reactjs - “开始故事书”不被识别为内部或外部命令,
kubernetes - 如何在我的 Kubernetes 容器中安装 tar 二进制文件以使 ku
python - 如果使用 native ORM,如何避免 Django Rest API 中的 S
unit-testing - 使用 Jest 测试 Vue3 组件时如何模拟计算属性