linux tcp 心跳程序

import socket
import time

def send_heartbeat(sock, interval=10):
    while True:
        try:
            sock.sendall(b'HEARTBEAT')
            print("Heartbeat sent")
        except socket.error as e:
            print(f"Socket error: {e}")
            break
        time.sleep(interval)

def receive_heartbeat(sock, timeout=30):
    sock.settimeout(timeout)
    while True:
        try:
            data = sock.recv(1024)
            if not data:
                print("Connection closed")
                break
            if data == b'HEARTBEAT':
                print("Heartbeat received")
        except socket.timeout:
            print("Heartbeat timeout, connection may be lost")
            break

# 创建TCP连接
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('127.0.0.1', 12345))

# 启动心跳发送和接收线程
import threading
threading.Thread(target=send_heartbeat, args=(sock,)).start()
threading.Thread(target=receive_heartbeat, args=(sock,)).start()