什么是 Socket?

Socket又稱"套接字"，應用程序通常通過"套接字"向網絡發出請求或者應答網絡請求，使主機間或者一臺計算機上的進程間可以通訊。

socket()函數

Python 中，我們用 socket（）函數來創建套接字，語法格式如下：

socket.socket([family[, type[, proto]]])

參數

• family: 套接字家族可以使AF_UNIX或者AF_INET 地址簇
• type: 套接字類型可以根據是面向連接的還是非連接分為SOCK_STREAM或SOCK_DGRAM　即tcp/ip和udp　
• protocol: 一般不填默認為0.

Socket 對象(內建)方法

函數描述

服務器端套接字
s.bind()	綁定地址（host,port）到套接字， 在AF_INET下,以元組（host,port）的形式表示地址。
s.listen()	開始TCP監聽。backlog指定在拒絕連接之前，操作系統可以掛起的最大連接數量。該值至少為1，大部分應用程序設為5就可以了。
s.accept()	被動接受TCP客戶端連接,(阻塞式)等待連接的到來
客戶端套接字
s.connect()	主動初始化TCP服務器連接，。一般address的格式為元組（hostname,port），如果連接出錯，返回socket.error錯誤。
s.connect_ex()	connect()函數的擴展版本,出錯時返回出錯碼,而不是拋出異常
公共用途的套接字函數
s.recv()	接收TCP數據，數據以字符串形式返回，bufsize指定要接收的最大數據量。flag提供有關消息的其他信息，通常可以忽略。
s.send()	發送TCP數據，將string中的數據發送到連接的套接字。返回值是要發送的字節數量，該數量可能小于string的字節大小。
s.sendall()	完整發送TCP數據，完整發送TCP數據。將string中的數據發送到連接的套接字，但在返回之前會嘗試發送所有數據。成功返回None，失敗則拋出異常。
s.recvform()	接收UDP數據，與recv()類似，但返回值是（data,address）。其中data是包含接收數據的字符串，address是發送數據的套接字地址。
s.sendto()	發送UDP數據，將數據發送到套接字，address是形式為（ipaddr，port）的元組，指定遠程地址。返回值是發送的字節數。
s.close()	關閉套接字
s.getpeername()	返回連接套接字的遠程地址。返回值通常是元組（ipaddr,port）。
s.getsockname()	返回套接字自己的地址。通常是一個元組(ipaddr,port)
s.setsockopt(level,optname,value)	設置給定套接字選項的值。
s.getsockopt(level,optname[.buflen])	返回套接字選項的值。
s.settimeout(timeout)	設置套接字操作的超時期，timeout是一個浮點數，單位是秒。值為None表示沒有超時期。一般，超時期應該在剛創建套接字時設置，因為它們可能用于連接的操作（如connect()）
s.gettimeout()	返回當前超時期的值，單位是秒，如果沒有設置超時期，則返回None。
s.fileno()	返回套接字的文件描述符。
s.setblocking(flag)	如果flag為0，則將套接字設為非阻塞模式，否則將套接字設為阻塞模式（默認值）。非阻塞模式下，如果調用recv()沒有發現任何數據，或send()調用無法立即發送數據，那么將引起socket.error異常。
s.makefile()	創建一個與該套接字相關連的文件

簡單實例

服務端

我們使用 socket 模塊的?socket?函數來創建一個 socket 對象。socket 對象可以通過調用其他函數來設置一個 socket 服務。

現在我們可以通過調用?bind(hostname, port)?函數來指定服務的?port(端口)。

接著，我們調用 socket 對象的?accept?方法。該方法等待客戶端的連接，并返回?connection?對象，表示已連接到客戶端。

完整代碼如下：

#!/usr/bin/env python # -*- coding: utf-8 -*- # @Author : Willpower-chen # @blog: http://www.cnblogs.com/willpower-chen/ import socket,os,time #導入socket和os模塊#實例化，AF_INET地址簇ipv4協議，SOCK_STREAM這是TCP/IP協議 server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) server.bind(('0.0.0.0',9999)) #綁定地址及服務端口 server.listen(5) #限制連接數 while True: #當一個client端斷開時，接收下一個客戶端# 每個客戶端發送過來的數據，生成相應的實例conn，client端連接地址addrconn,addr = server.accept()print('新的連接：',addr)while True:print('等待新的指令')data = conn.recv(1024) #接收client端發來的數據if not data:print('客戶端已斷開')break #當數據為空時，跳出循環等待下一個連接print('執行指令',data.decode()) #打印要執行的命令cmd_res = os.popen(data.decode()).read()#返回client發過來的cmd命令，在server端的執行結果#由于每次接收數據的大小為1024，為了確定client需要接收幾次，所以需要先把總數據大小發給clientprint('開始發送',len(cmd_res))if len(cmd_res) == 0 : #如果cmd執行結果為空時，server端不會發送數據cmd_res = 'cmd_res is not info' #為了防止為空時不發數據，自定義一個數據print('執行命令結果大小：',len(cmd_res))#打印命令執行結果數據大小conn.send(str(len(cmd_res.encode('utf-8'))).encode('utf-8')) #給client發送數據總大小信息#time.sleep(0.5)client_ack = conn.recv(1024) #等待client端確認ack，防止粘包print('ack from client',client_ack.decode('utf-8')) #打印ack確認信息conn.send(cmd_res.encode('utf-8')) #給client發送命令執行結果數據print('發送完畢') server.close()

客戶端

接下來我們寫一個簡單的客戶端實例連接到以上創建的服務。端口號為 9999。

socket.connect(hosname, port )?方法打開一個 TCP 連接到主機為?hostname?端口為?port?的服務商。連接后我們就可以從服務端后期數據，記住，操作完成后需要關閉連接。

完整代碼如下：

#!/usr/bin/env python # -*- coding: utf-8 -*- # @Author : Willpower-chen # @blog: http://www.cnblogs.com/willpower-chen/ import socketclient = socket.socket() #默認地址簇是ipv4，傳輸協議是TCP/IP client.connect(('localhost',9999))#與server建立連接 while True:cmd = input('>>:').strip() # 用戶輸入cmd命令if len(cmd) == 0: continue #如果用戶輸入為空，循環輸入client.send(cmd.encode('utf-8'))#發送cmd命令，encode是把字符串轉為byte(python3.0傳輸只能是二進制)cmd_res_size = client.recv(1024)#確認接收命令結果的長度print('命令結果大小',cmd_res_size.decode()) #打印命令結果的長度client.send('準備好接收了，loser可以發了'.encode('utf-8'))#ack確認，防止粘包，注意這里不能用b''因為加中文了receive_size = 0 #已經接收的數據，默認先設置為0receive_data = ''.encode()while receive_size < int(cmd_res_size.decode()): #已接收數據小于總數據時，循環接收數據data = client.recv(1024)receive_size += len(data) #每次收到的有可能小于1024，所以用len（data）計算receive_data += dataelse:print('cmd res receive done...',receive_size)print(receive_data.decode('utf-8')) client.close()

ftp實例：

server端

#!/usr/bin/env python # -*- coding: utf-8 -*- # @Author : Willpower-chen # @blog: http://www.cnblogs.com/willpower-chen/ import os,hashlib,socketserver = socket.socket() server.bind(('0.0.0.0',9999)) server.listen(5) while True:conn,addr = server.accept() #客戶端實例成conn，客戶端連接地址為addrprint('客戶端已經斷開，開始新的連接,客戶端連接地址為：',addr)while True:cmd = conn.recv(1024) #客戶端發出的命令if len(cmd) == 0: break #如果接收到的命令為空，斷開連接，等待新的連接# cmd_res = os.popen(cmd.decode('utf-8')).read() #server端根據cmd命令，獲取結果filename = cmd.decode().split()[1] #獲取文件名if os.path.isfile(filename):file_total_size = os.stat(filename).st_size #獲取文件大小,得到的數據類型是intm = hashlib.md5() # 打開md5哈希conn.send(str(file_total_size).encode('utf-8')) #發送總文件大小,conn.recv(1024) #接收client端確認，防止粘包f = open(filename,'rb')#只讀二進制方式打開文件，文件句柄為ffor line in f:m.update(line) #md5逐行加密conn.send(line) #逐行發送數據，由于之前打開方式是rb，所以這里不用encondeserver_file_md5 = m.hexdigest() #服務端文件md5哈希值conn.send(server_file_md5.encode('utf-8')) #發送服務端文件md5哈希值f.close() #關閉文件 server.close()

client端

#!/usr/bin/env python # -*- coding: utf-8 -*- # @Author : Willpower-chen # @blog: http://www.cnblogs.com/willpower-chen/ import socket,hashlibclient = socket.socket() client.connect(('localhost',9999)) while True:data = input('>>:').strip() #輸入命令行if len(data)==0:continue #如果輸入是空，返回上層，重新輸入cmd,filename = data.split() #獲取命令和文件名if len(filename)==0:continue #r如果沒有文件名，返回三層，重新輸入if data.startswith('get'): #判斷如果是get命令是，繼續以下操作client.send(data.encode('utf-8'))#發送命令行file_total_size = int(client.recv(1024).decode()) #獲取文件大小信息,文件大小轉換成int格式client.send('ack 確認'.encode()) #ack確認，防止粘包m = hashlib.md5() #啟用md5哈希加密receive_size = 0 #定義一個接收數據初始值為0f = open(filename+'new.txt','wb') #打開一個文件，存儲接收的文件數據# 如果接收的數據小于中大小，循環接收數據while receive_size < file_total_size:# 如果剩余數據的大于1024，定義下次接收數據大小為size，且大小是1024if file_total_size - receive_size > 1024:size = 1024# 如果剩余數據的小于等于1024，定義下次接收數據大小為size，大小是總大小減去已經接收的數據else:size = file_total_size - receive_sizefile_recv = client.recv(size) #接收文件數據# receive_size +=size #每接收一次數據，接收數據大小累計加一次receive_size +=len(file_recv) #每接收一次數據，接收數據大小累計加一次m.update(file_recv) # 每接收一次數據，做一次md5加密f.write(file_recv) #每接收一次數據，往文件里寫入一次else:print('接收完畢，要接收的文件總大小是%s ,已經接收的總數據是%s'%(file_total_size,receive_size))f.close()server_file_md5 = client.recv(1024) #接收server端文件md5值client_file_md5 = m.hexdigest() #客戶端文件md5值print('server_file_md5',server_file_md5.decode()) #打印server端文件md5值print('client_file_md5',client_file_md5) #打印client端文件md5值 client.close()

?

?

Python Internet 模塊

以下列出了 Python 網絡編程的一些重要模塊：

協議功能用處端口號Python 模塊

HTTP	網頁訪問	80	httplib, urllib, xmlrpclib
NNTP	閱讀和張貼新聞文章，俗稱為"帖子"	119	nntplib
FTP	文件傳輸	20	ftplib, urllib
SMTP	發送郵件	25	smtplib
POP3	接收郵件	110	poplib
IMAP4	獲取郵件	143	imaplib
Telnet	命令行	23	telnetlib
Gopher	信息查找	70	gopherlib, urllib

參考網址：http://www.runoob.com/python/python-socket.html

?

轉載于:https://www.cnblogs.com/willpower-chen/p/5867832.html

總結

以上是生活随笔為你收集整理的python运维开发之第八天（socket）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。