Kubernetes集群中使用Python套接字的服务器-客户端连接

import socket

# 创建套接字
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 绑定地址和端口
server_address = ('0.0.0.0', 8080)
server_socket.bind(server_address)

# 监听连接请求
server_socket.listen(1)

while True:
    print('等待客户端连接...')
    client_socket, client_address = server_socket.accept()
    print('客户端已连接:', client_address)
    
    # 处理客户端请求
    data = client_socket.recv(1024)
    response = '服务器收到消息：' + data.decode()
    client_socket.sendall(response.encode())
    
    # 关闭客户端连接
    client_socket.close()

apiVersion: apps/v1
kind: Deployment
metadata:
  name: socket-server
spec:
  replicas: 1
  selector:
    matchLabels:
      app: socket-server
  template:
    metadata:
      labels:
        app: socket-server
    spec:
      containers:
      - name: socket-server
        image: your-socket-server-image
        ports:
        - containerPort: 8080

kubectl apply -f deployment.yaml

apiVersion: v1
kind: Service
metadata:
  name: socket-service
spec:
  selector:
    app: socket-server
  ports:
    - protocol: TCP
      port: 8080
      targetPort: 8080
  type: LoadBalancer

kubectl apply -f service.yaml