python实现 MetaTrader 5 到webSocket服务端的通信

import websocket
import _thread
import time
import socket, numpy as np
from sklearn.linear_model import LinearRegression


msg=""

def connect(address, port):
    global conn, addr,sock
    # global msg
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    print("创建socketServer")
    sock.bind((address, port))



def socket_close():
    sock.close()

def on_message(ws, message):

    # send(message)
    msg=message
    # print()
    # 监听来自mt5发送的连接socket请求
    sock.listen(1)
    conn, addr = sock.accept()
    print('connected to', addr)
    # send("1111"+msg)
    while True:

         # send("2222"+msg)
         sock.listen(1)
         conn, addr = sock.accept()
         conn.send(bytes(msg.encode("utf-8")))
         # break
         msg=""
         break

    # return message

def on_error(ws, error):
    print(error)

def on_close(ws, close_status_code, close_msg):
    print("### closed ###")

def on_open(ws):
    print("Opened connection")
    
# 在本地建立socket服务端
sockserver= connect("127.0.0.1", 9098)

# print("=======创建链接")
if __name__ == "__main__":
    websocket.enableTrace(True)
   

    ws = websocket.WebSocketApp("ws://localhost:8080/webSocket",
                              on_open=on_open,
                              on_error=on_error,
                              on_close=on_close,
                              on_message=on_message)

    ws.run_forever()