利用多線程使socket服務端可以與多個客戶端同時通訊
server
import socket
1. 符合TCP協議的手機
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # TCP
2. 綁定手機號 110
server.bind(('127.0.0.1', 8000)) # 127.0.0.1代表本地
server.bind(('192.168.11.210',8000)) # 127.0.0.1代表本地
server.listen(5) # 半連接池
3. 等待客戶端連接
print('start...')
鏈接循環
while True:
# 通信循環
conn, client_addr = server.accept()
while True:
try:
# 4. 收到消息receive
data = conn.recv(1024)
print(data)
# 5. 回消息
conn.send(data.upper())
except ConnectionAbortedError:
continue
except ConnectionResetError:
break
client
! /user/bin/ebv python
-- encoding:utf-8 --
from threading import Thread
import socket, random
count = 0
1. 創建符合TCp協議的手機
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
2. 撥號
client.connect(('127.0.0.1',8000))
def task(i):
while True:
msg = input(f'{i}please enter your msg:').strip() # dir
# 3. 發送消息
client.send(msg.encode('utf8'))
# 4. 接收消息
data = client.recv(1024)
print(data)
if name == 'main':
while count <6:
i = random.randint(0,6)
t = Thread(target=task, args=(i,))
t.start()
print(count)
count += 1