Code: Alles auswählen
import websocket
websocket.enableTrace(True)
def on_data(wsapp, data, data_type, is_continue=None):
print("###### on_data", data)
def on_message(wsapp, message):
print("###### on_message", message)
def on_error(wsapp, err):
print("Got a an error: ", err)
def on_close(wsapp, close_status_code, close_msg):
# Because on_close was triggered, we know the opcode = 8
print("on_close args:")
if close_status_code or close_msg:
print("close status code: " + str(close_status_code))
print("close message: " + str(close_msg))
def on_open(wsapp):
#wsapp.send(json.dumps(headers))
print("connection opened.")
#wsapp.send(msg.decode("latin-1"))
return
server = "ws://127.0.0.1:9998"
if __name__ == "__main__":
wsapp = websocket.WebSocketApp(server, header=headers, on_message=on_message, on_error=on_error, on_open=on_open, on_close=on_close, on_data=on_data)
print("wsapp:", wsapp)
#
wsapp.run_forever()