端口日志

Administrator

2023-08-28 e8c8451aa2028793d0ed0a9e5cf5cbb230f21221

端口日志

 huaxin_client/trade_client_server.py

@@ -4,6 +4,7 @@
import time

from huaxin_client.command_manager import TradeCommandManager
from log_module.log import logger_system
from utils import socket_util

SERVER_PORT = 10088
@@ -42,4 +43,8 @@
    time.sleep(10)
    laddr = "0.0.0.0", SERVER_PORT
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
    tcpserver.serve_forever()
    try:
        tcpserver.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{SERVER_PORT} 启动失败")

 main.py

@@ -50,14 +50,22 @@
    print("create Server")
    laddr = "", 9001
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_trade=pipe)  # 注意：参数是MyBaseRequestHandle
    # tcpserver.handle_request()  # 只接受一个客户端连接
    tcpserver.serve_forever()  # 永久循环执行,可以接受多个客户端连接
    try:
        tcpserver.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{laddr[1]} 启动失败")


def createDataServer():
    print("create DataServer")
    tcpserver = data_server.run("", 9004)
    tcpserver.serve_forever()
    try:
        tcpserver.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{9004} 启动失败")


if __name__ == '__main__':

 ocr/ocr_server.py

@@ -6,6 +6,7 @@
import numpy

import constant
from log_module.log import logger_system
from utils import ths_industry_util
from ocr import ocr_util
from third_data import kpl_util
@@ -157,7 +158,11 @@
    handler = OCRServer
    httpd = socketserver.TCPServer((addr, port), handler)
    print("HTTP server is at: http://%s:%d/" % (addr, port))
    httpd.serve_forever()
    try:
        httpd.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{port} 启动失败")


if __name__ == "__main__":

 third_data/data_server.py

@@ -5,6 +5,7 @@
from http.server import BaseHTTPRequestHandler
import dask

from log_module.log import logger_system
from utils import global_util, tool
from code_attribute import gpcode_manager
from log_module import log, log_analyse, log_export
@@ -573,7 +574,11 @@
    # httpd = socketserver.TCPServer((addr, port), handler)
    httpd = ThreadedHTTPServer((addr, port), handler)
    print("HTTP server is at: http://%s:%d/" % (addr, port))
    httpd.serve_forever()
    try:
        httpd.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{port} 启动失败")


if __name__ == "__main__":

 trade/huaxin/trade_server.py

@@ -32,7 +32,7 @@
from log_module import async_log_util
from log_module.log import hx_logger_l2_upload, hx_logger_contact_debug, hx_logger_trade_callback, \
    hx_logger_l2_orderdetail, hx_logger_l2_transaction, hx_logger_l2_market_data, logger_l2_trade_buy_queue, \
    logger_l2_g_cancel, logger_debug
    logger_l2_g_cancel, logger_debug, logger_system
from third_data import block_info, kpl_api, kpl_data_manager
from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager
from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils
@@ -765,7 +765,11 @@

    laddr = "0.0.0.0", 10008
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
    tcpserver.serve_forever()
    try:
        tcpserver.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{laddr[1]} 启动失败")


if __name__ == "__main__":