统一消息平台
import socket
import json
# 模拟医院数据库
hospital_data = {
"doctors": [
{"id": 1, "name": "Dr. Smith", "cases_handled": 10},
{"id": 2, "name": "Dr. Johnson", "cases_handled": 15}
]
}
# 创建TCP/IP套接字
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 9999))
server_socket.listen(5)
print("Server is listening...")
while True:
client_socket, addr = server_socket.accept()
print(f"Connection from {addr}")
# 接收消息
message = client_socket.recv(1024).decode()
if message.startswith("GET_RANK"):
rank_data = json.dumps(hospital_data["doctors"])
client_socket.sendall(rank_data.encode())

elif message.startswith("UPDATE_CASES"):
doctor_id = int(message.split(":")[1])
for doc in hospital_data["doctors"]:
if doc["id"] == doctor_id:
doc["cases_handled"] += 1
break
client_socket.sendall(b"Updated!")
client_socket.close()
]]>
