您好,登錄后才能下訂單哦!
使用socket實(shí)現(xiàn)tcp通信,需導(dǎo)入socket模塊
1、服務(wù)端
主要步驟:
(1)創(chuàng)建socket:socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)
family:AF_INET , AF_INET6, AF_UNIX, AF_CAN, AF_PACKET, AF_RDS
type:SOCK_STREAM , SOCK_DGRAM, SOCK_RAW,或者其他SOCK_*
proto:一般使用默認(rèn)值0
fileno:一般使用默認(rèn)值
(2)綁定IP和端口號(hào):socket.bind(address)
address:使用(host,port)元組即可
(3)監(jiān)聽:socket.listen([backlog])
backlog:就理解為最大連接數(shù)
(4)接受連接:socket.accept()
返回(conn,address)元組,分別是已連接客戶端的socket對(duì)象和地址
(5)發(fā)送/接受數(shù)據(jù):socket.recv(bufsize[, flags])/socket.send(bytes[, flags])
bufsize:接收的數(shù)據(jù)最大字節(jié)數(shù)
bytes:需要發(fā)送的數(shù)據(jù)字節(jié)數(shù)
(6)關(guān)閉連接:socket.close()
#!/usr/bin/python # -*- coding: UTF-8 -*- # 文件名:tcpserver.py import socket import time MaxBytes=1024*1024 server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) server.settimeout(60) host = '127.0.0.1' #host = socket.gethostname() port = 11223 server.bind((host, port)) # 綁定端口 server.listen(1) # 監(jiān)聽 try: client,addr = server.accept() # 等待客戶端連接 print(addr," 連接上了") while True: data = client.recv(MaxBytes) if not data: print('數(shù)據(jù)為空,我要退出了') break localTime = time.asctime( time.localtime(time.time())) print(localTime,' 接收到數(shù)據(jù)字節(jié)數(shù):',len(data)) print(data.decode()) client.send(data) except BaseException as e: print("出現(xiàn)異常:") print(repr(e)) finally: server.close() # 關(guān)閉連接 print("我已經(jīng)退出了,后會(huì)無期")
這個(gè)實(shí)例沒有創(chuàng)建其他線程,也只接收一個(gè)客戶端的連接;為了能手動(dòng)結(jié)束或自動(dòng)結(jié)束accept和recv的阻塞,設(shè)置了超時(shí)60秒,并將主體部分放入到try語句中;將socket的關(guān)閉放到finally塊中,可以防止程序異常退出,而導(dǎo)致沒有調(diào)用close函數(shù)。
2、客戶端
主要步驟:
(1)創(chuàng)建socket:socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None)
(2)連接:socket.connect(address)
address:使用(host,port)元組即可
(3)發(fā)送/接受數(shù)據(jù):socket.recv(bufsize[, flags])/socket.send(bytes[, flags])
(4)關(guān)閉連接:socket.close()
#!/usr/bin/python # -*- coding: UTF-8 -*- # 文件名:tcpclient.py import socket import time MaxBytes=1024*1024 host ='127.0.0.1' port = 11223 client = socket.socket(socket.AF_INET,socket.SOCK_STREAM) client.settimeout(30) client.connect((host,port)) while True: inputData=input(); #等待輸入數(shù)據(jù) if(inputData=="quit"): print("我要退出了,再見") break sendBytes = client.send(inputData.encode()) if sendBytes<=0: break; recvData = client.recv(MaxBytes) if not recvData: print('接收數(shù)據(jù)為空,我要退出了') break localTime = time.asctime( time.localtime(time.time())) print(localTime, ' 接收到數(shù)據(jù)字節(jié)數(shù):',len(recvData)) print(recvData.decode()) client.close() print("我已經(jīng)退出了,后會(huì)無期")
以上客戶端連接成功后等待用戶輸入,然后將輸入信息發(fā)送到服務(wù)端,服務(wù)端將數(shù)據(jù)原樣返回給客戶端,如果客戶端輸入quit就會(huì)跳出循環(huán)并關(guān)閉socket,這時(shí)服務(wù)端recv會(huì)返回空從而跳出循環(huán)并關(guān)閉socket。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。