import socketio
|
|
def create_sio():
|
sio = socketio.Client()
|
return sio
|
|
def connect_(url,sio):
|
if not url:
|
sio.connect(url)
|
sio.on('connect', on_connect)
|
sio.on('chat_message', revc_message)
|
sio.on('disconnect', on_disconnect)
|
sio.on('reconnect', on_reconnect)
|
print('create sio')
|
return sio
|
|
def sio(url,tparams):
|
if not tparams:
|
sio = socketio.Client()
|
sio.connect(url)
|
sio.on('connect', on_connect)
|
sio.on('chat_message', revc_message)
|
sio.on('disconnect', on_disconnect)
|
sio.on('reconnect', on_reconnect)
|
return sio
|
|
|
def get_sessionid(userid, roomid):
|
pass
|
|
def on_connect(*args):
|
# print(*args)
|
print('connect')
|
|
def on_disconnect():
|
print('## disconnect ##')
|
|
def on_reconnect():
|
print('reconnect')
|
|
def send_msg(sendmessage, sio):
|
sio.emit('msg', b'{sendmessage}')
|
return
|
|
def revc_message(*args): # 这个函数很重要 是socketio监听信息获取的函数, 这里面socketio会自行调用这个函数
|
response_data_format = {}
|
response_data = eval(args[0])
|
print(response_data)
|
|
def revc_message_mutil(*args): # 这个函数很重要 是socketio监听信息获取的函数, 这里面socketio会自行调用这个函数
|
response_data_format = {}
|
response_data = eval(args[0])
|
print(response_data)
|
|
def create_params(userid, roomid): # 这个方法类似requests库的封装方法 看底层貌似与requests的urllib3方法一样
|
vsessionid, tsessionid = get_sessionid(userid, roomid)
|
vparams = {
|
'sessionid': vsessionid,
|
}
|
tparams = {
|
'sessionid': tsessionid,
|
}
|
return vparams, tparams
|
|
def clear_data():
|
print('sessionid')
|
