Server-py/sri-server-bg03/xprotobuf/ConnectionTest2008.py

"""
echo "执行：进入调试" \
&& project_path="/home/sri/repositories/repositories/sri-project.demo-py/sri-dino-pyserver01" \
&& cd ${project_path} \
&& sudo docker exec -it sri-dino-pyserver01 bash

python3 /home/sri/repositories/repositories/sri-project.demo-py/sri-dino-pyserver01/lib/ConnectionTest.py
"""
import socket
import struct
import traceback
import time

import sys
import importlib

# --- for linux
# sys.path.append('/home/sri/repositories/repositories/sri-project.demo-py/sri-dino-pyserver01')
# sys.path.append('/home/sri/repositories/repositories/sri-project.demo-py/3rdparty')


# --- for windows
# sys.path.append(r'E:\casper\repositories\repositories\sri-project.demo-py\sri-server-bg03')
# sys.path.append(r'E:\casper\repositories\repositories\sri-project.demo-py\3rdparty')

# --- import
# protobuf = importlib.import_module(f"xprotobuf.protocol_pb2")
# methods = importlib.import_module(f"xlib")
import protocol_pb2 as protobuf


# --- 服务地址
# host, port = '127.0.0.1', 20916
# host, port = '127.0.0.1', 20917
# host, port = '172.18.74.154', 20918  # 湛江
host, port = '10.10.60.237', 20918  # SRI内网


def test():
    head_sequence = '<hh'  # 字节序规则
    head_size = struct.calcsize(head_sequence)

    try:
        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # client.bind(('localhost', port))
        client.connect((host, port))

        # --- send 2008
        head = 2008, 0
        head_bytestream = struct.pack(head_sequence, *head)
        send_bytestream = head_bytestream
        print(f"Sent data: {send_bytestream}")
        client.sendall(send_bytestream)

        while True:
            pass

    except Exception as exception:

        print(f"#exception: {exception.__class__.__name__}")
        print(f"#traceback: {traceback.format_exc()}")

    finally:
        client.close()


if __name__ == "__main__":
    test()