35 lines
1.1 KiB
Python
35 lines
1.1 KiB
Python
|
import asyncio
|
||
|
|
import websockets
|
||
|
|
|
||
|
|
|
||
|
|
async def connect():
|
||
|
|
uri = "wss://live-ws.immomo.com/ws/im"
|
||
|
|
async with websockets.connect(uri) as websocket:
|
||
|
|
print(f"链接websocket:[{uri}] 完成")
|
||
|
|
|
||
|
|
client_time = "1711123627734"
|
||
|
|
momoid = "1062302597"
|
||
|
|
roomid = "15925755150740"
|
||
|
|
token = "b458d6fd04ee38a9e5330e76a3802df9"
|
||
|
|
|
||
|
|
data = '{{"msg_id":1,"client_time":{0},"type":"Sauth","data":{{"momoid":"{1}","roomid":"{2}","role":6,"isVisitor":false,"token":"{3}","ua":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36"}}}}'.format(
|
||
|
|
client_time, momoid, roomid, token)
|
||
|
|
await websocket.send(data)
|
||
|
|
|
||
|
|
print("Send Hello")
|
||
|
|
|
||
|
|
while True:
|
||
|
|
try:
|
||
|
|
response = await websocket.recv()
|
||
|
|
print("收到消息=>" + response)
|
||
|
|
except websockets.exceptions.ConnectionClosedError:
|
||
|
|
print("与服务器断开链接")
|
||
|
|
break
|
||
|
|
|
||
|
|
|
||
|
|
async def main():
|
||
|
|
await connect()
|
||
|
|
|
||
|
|
|
||
|
|
asyncio.run(main())
|