# 服务端

import socket
from threading import Thread

"""
服务端
    1.要有固定的IP和PORT
    2.24小时不间断提供服务
    3.能够支持并发(多用户同时连接服务端)
"""
server = socket.socket()
server.bind(('127.0.0.1',8080))
server.listen(5)

def talk(conn):
    while True:
        try:
            data = conn.recv(1024)
            if len(data) == 0:break
            print(data.decode('utf-8'))
            conn.send(data.upper())
        except ConnectionResetError as e:
            print(e)
            break
    conn.close()

while True:
    conn, addr = server.accept()  # 监听 等待客户端的连接  阻塞态
    print(addr)
    t = Thread(target=talk,args=(conn,))
    t.start()

# 客户端

import socket

client = socket.socket()
client.connect(('127.0.0.1',8080))

while True:
    client.send(b'hello')
    data = client.recv(1024)
    print(data.decode('utf-8'))

相关文章:

  • 2022-12-23
  • 2021-09-06
  • 2022-12-23
  • 2021-12-26
  • 2021-07-14
  • 2022-12-23
  • 2021-08-26
  • 2022-02-01
猜你喜欢
  • 2022-01-18
  • 2022-12-23
  • 2021-07-12
  • 2022-02-27
  • 2021-06-12
  • 2021-11-01
  • 2021-10-06
相关资源
相似解决方案