mirror of
https://gitee.com/Lyon1998/pikapython.git
synced 2025-01-15 17:02:53 +08:00
75 lines
1.9 KiB
Python
75 lines
1.9 KiB
Python
import socket
|
|
import _thread
|
|
import random
|
|
import time
|
|
import json
|
|
|
|
test_finished = False
|
|
server_started = False
|
|
test_data = {
|
|
'result': {
|
|
'a_a': {
|
|
'value': 0.290000, 'desc': 'A 相电流'
|
|
}
|
|
}, 'code': 0
|
|
}
|
|
|
|
|
|
def socket_server_task(host, port):
|
|
"""
|
|
socket 服务器任务
|
|
:return:
|
|
"""
|
|
print("socket server start:", host, port)
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
s.bind((host, port))
|
|
s.listen(5)
|
|
global server_started
|
|
server_started = True
|
|
while True:
|
|
try:
|
|
print("socket server waiting accept")
|
|
accept, addr = s.accept()
|
|
print("socket server accepted at", addr)
|
|
while True:
|
|
data = accept.recv(1024)
|
|
print('socket server recv:', data.decode())
|
|
# accept.send(data)
|
|
accept.send(json.dumps(test_data))
|
|
except Exception:
|
|
print('socket server closing accept')
|
|
accept.close()
|
|
break
|
|
print("socket server closing")
|
|
s.close()
|
|
global test_finished
|
|
test_finished = True
|
|
|
|
|
|
def socket_server_init(host='0.0.0.0', port=36500):
|
|
_thread.start_new_thread(socket_server_task, (host, port))
|
|
|
|
|
|
def socket_client_task(host, port):
|
|
print("socket client start:", host, port)
|
|
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
client.connect((host, port))
|
|
for i in range(2):
|
|
client.send("hello".encode())
|
|
recv = client.recv(1024).decode()
|
|
print("client recv:", recv)
|
|
client.close()
|
|
|
|
|
|
def socket_server_test(host='0.0.0.0', port=36500):
|
|
_thread.start_new_thread(socket_client_task, (host, port))
|
|
|
|
|
|
test_port = random.randint(10000, 65535)
|
|
socket_server_init(port=test_port)
|
|
while not server_started:
|
|
time.sleep(0.1)
|
|
socket_server_test(port=test_port)
|
|
while not test_finished:
|
|
time.sleep(0.1)
|