import socket
?
# 建立socket對(duì)象
# 參數(shù)一表示IP地址類型（AF_INET為IPV4,AF_INET6為IPV6），參數(shù)二表示連接的類型（SOCK_STREAM表示TCP形式,SOCK_DGRAM表示UDP形式）
client_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM) ?# 代表(ipv4,TCP)
?
# 連接服務(wù)器(元組中填目標(biāo)ip地址和端口號(hào))
client_socket.connect(('127.0.0.1',7777))
# 準(zhǔn)備數(shù)據(jù)，需要轉(zhuǎn)換為二進(jìn)制數(shù)據(jù)，encode()中填寫的是本地的字符串編碼格式，mac、linux填utf-8
data='hello'.encode('gbk')
# 向服務(wù)器發(fā)送數(shù)據(jù)
client_socket.send(data)
# 接收數(shù)據(jù),必須要指定接收數(shù)據(jù)的大小，單位字節(jié)，最大4096，即4k
recv_data=client_socket.recv(1024)
# 接收的數(shù)據(jù)要進(jìn)行decode()解碼，發(fā)送的時(shí)候用啥編碼就填啥編碼
recv_data=recv_data.decode('gbk')
print(recv_data)
# 關(guān)閉連接
client_socket.close()

import socket
# 建立socket對(duì)象
server_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 如果服務(wù)器是一次性的，如果服務(wù)器結(jié)束后馬上重新啟動(dòng)會(huì)出現(xiàn)一個(gè)錯(cuò)誤，原因是地址和端口沒有被釋放
# OSError: [Errno 48] Address already in use
# 如果想馬上釋放，要設(shè)置一下socket選項(xiàng)
server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,True)
# 綁定IP和端口，如果在綁定IP時(shí)沒有給定IP，默認(rèn)是綁定本地IP
server_socket.bind(('',7777))
# 設(shè)置監(jiān)聽(最大監(jiān)聽數(shù))，設(shè)置完后服務(wù)端會(huì)進(jìn)入被動(dòng)模式，不能主動(dòng)連接客戶端，只能被動(dòng)地等待客戶端的連接
server_socket.listen(128)
# 等待客戶端連接，連接上后，函數(shù)會(huì)返回客戶端的Socket對(duì)象和地址信息
client_socket,ip_port=server_socket.accept()
print(f'客戶端{(lán)ip_port[0]}使用端口{ip_port[1]}連接成功...')
# 接收客戶端數(shù)據(jù)
data=client_socket.recv(1024)
# 查看客戶端發(fā)送的數(shù)據(jù)長度
if len(data)!=0:
? ? data=data.decode('gbk')
? ? print(f'客戶端{(lán)ip_port[0]}使用端口{ip_port[1]}發(fā)送是數(shù)據(jù)是{data}')
else:
? ? print(f'客戶端{(lán)ip_port[0]}使用端口{ip_port[1]}關(guān)閉了連接')
?
# 給客戶端發(fā)送數(shù)據(jù)
data='你好'.encode('gbk')
client_socket.send(data)
# 關(guān)閉客戶端
client_socket.close()
# 關(guān)閉服務(wù)端
server_socket.close()

import socket
import threading
?
?
def client_task(client_socket,ip_port):
? ? print(ip_port,'加入連接')
? ? # 持續(xù)接收客戶端的消息
? ? while True:
? ? ? ? data=client_socket.recv(1024).decode('gbk')
? ? ? ? if len(data)!=0:
? ? ? ? ? ? print(f'客戶端{(lán)ip_port[0]}發(fā)來的信息是{data}')
? ? ? ? else:
? ? ? ? ? ? print(f'客戶端{(lán)ip_port[0]}已經(jīng)斷開連接')
? ? ? ? ? ? break
? ? ? ? send_data=('Hello--'+data).encode('gbk')
? ? ? ? client_socket.send(send_data)
?
?
if __name__ == '__main__':
? ? server_socket=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
? ? server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,True)
? ? server_socket.bind(('',7777))
? ? server_socket.listen(128)
? ? # 循環(huán)接收客戶連接
? ? while True:
? ? ? ? client_socket,ip_port=server_socket.accept() ? ?# 會(huì)一直等待接收連接
? ? ? ? t_client=threading.Thread(target=client_task,args=(client_socket,ip_port))
? ? ? ? t_client.setDaemon(True)
? ? ? ? t_client.start()