一、Socket通常也稱作"套接字"，用于描述IP地址和端口，是一個通信鏈的句柄，可以用來實現不同虛擬機或不同計算機之間的通信。

socket服務端示例：

importsocket

ip_port= ('127.0.0.1',9999) #設定服務端的IP地址與端口。

sk= socket.socket() #調用socket構造函數。

sk.bind(ip_port) #使用bind方法綁定服務端IP與端口。也可以理解成向系統注冊IP與端口信息。

sk.listen(5) #設定最多連接數。

whileTrue:print('server waiting...')

conn,addr= sk.accept() #服務器套接字通過socket的accept方法等待客戶請求一個連接。

client_data = conn.recv(1024) #設定每次最多能接受1024個字節

print(str(client_data,'utf8')) #打印服務端接收客戶端的信息。

conn.sendall(bytes('不要回答,不要回答,不要回答','utf8')) #使用sendall方法發信息給客戶端。

conn.close() #關閉連接。

socket服務端示例：

socket客戶端示例：

importsocket

ip_port= ('127.0.0.1',9999) #設定好服務端的IP與開放的端口。

sk= socket.socket() #調用socket構造函數

sk.connect(ip_port) #使用socket的connect方法連接服務器

sk.sendall(bytes('請求占領地球','utf8')) #使用sendall方法發信息給服務端。

server_reply = sk.recv(1024) #設定每次最多能接受1024個字節

print(str(server_reply,'utf8')) #打印出接收到的服務端反回信息。

sk.close() #關閉socket連接。

socket客戶端示例：

socket更多功能：

sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM,0)

參數一：地址簇

socket.AF_INET IPv4(默認)

socket.AF_INET6 IPv6

socket.AF_UNIX 只能夠用于單一的Unix系統進程間通信

參數二：類型

socket.SOCK_STREAM　　流式socket , for TCP (默認)

socket.SOCK_DGRAM　　 數據報式socket , for UDP

socket.SOCK_RAW 原始套接字，普通的套接字無法處理ICMP、IGMP等網絡報文，而SOCK_RAW可以；其次，SOCK_RAW也可以處理特殊的IPv4報文；此外，利用原始套接字，可以通過IP_HDRINCL套接字選項由用戶構造IP頭。

socket.SOCK_RDM 是一種可靠的UDP形式，即保證交付數據報但不保證順序。SOCK_RAM用來提供對原始協議的低級訪問，在需要執行某些特殊操作時使用，如發送ICMP報文。SOCK_RAM通常僅限于高級用戶或管理員運行的程序使用。

socket.SOCK_SEQPACKET 可靠的連續數據包服務

sk.bind(address)

s.bind(address) 將套接字綁定到地址。address地址的格式取決于地址族。在AF_INET下，以元組(host,port)的形式表示地址。

sk.listen(backlog)

開始監聽傳入連接。backlog指定在拒絕連接之前，可以掛起的最大連接數量。

backlog等于5，表示內核已經接到了連接請求，但服務器還沒有調用accept進行處理的連接個數最大為5

這個值不能無限大，因為要在內核中維護連接隊列

sk.setblocking(bool)

是否阻塞(默認True)，如果設置False，那么accept和recv時一旦無數據，則報錯。

sk.accept()

接受連接并返回(conn,address),其中conn是新的套接字對象，可以用來接收和發送數據。address是連接客戶端的地址。

接收TCP 客戶的連接(阻塞式)等待連接的到來

sk.connect(address)

連接到address處的套接字。一般，address的格式為元組(hostname,port),如果連接出錯，返回socket.error錯誤。

sk.connect_ex(address)

同上，只不過會有返回值，連接成功時返回 0 ，連接失敗時候返回編碼，例如：10061

sk.close()

關閉套接字

sk.recv(bufsize[,flag])

接受套接字的數據。數據以字符串形式返回，bufsize指定最多可以接收的數量。flag提供有關消息的其他信息，通常可以忽略。

sk.recvfrom(bufsize[.flag])

與recv()類似，但返回值是(data,address)。其中data是包含接收數據的字符串，address是發送數據的套接字地址。

sk.send(string[,flag])

將string中的數據發送到連接的套接字。返回值是要發送的字節數量，該數量可能小于string的字節大小。即：可能未將指定內容全部發送。

sk.sendall(string[,flag])

將string中的數據發送到連接的套接字，但在返回之前會嘗試發送所有數據。成功返回None，失敗則拋出異常。

內部通過遞歸調用send，將所有內容發送出去。

sk.sendto(string[,flag],address)

將數據發送到套接字，address是形式為(ipaddr，port)的元組，指定遠程地址。返回值是發送的字節數。該函數主要用于UDP協議。

sk.settimeout(timeout)

設置套接字操作的超時期，timeout是一個浮點數，單位是秒。值為None表示沒有超時期。一般，超時期應該在剛創建套接字時設置，因為它們可能用于連接的操作(如 client 連接最多等待5s )

sk.getpeername()

返回連接套接字的遠程地址。返回值通常是元組(ipaddr,port)。

sk.getsockname()

返回套接字自己的地址。通常是一個元組(ipaddr,port)

sk.fileno()

套接字的文件描述符

二、SocketServer模塊：

SocketServer內部使用 IO多路復用 以及 “多線程” 和 “多進程” ，從而實現并發處理多個客戶端請求的Socket服務端。即：每個客戶端請求連接到服務器時，Socket服務端都會在服務器是創建一個“線程”或者“進程” 專門負責處理當前客戶端的所有請求。

ThreadingTCPServer

ThreadingTCPServer實現的Soket服務器內部會為每個client創建一個 “線程”，該線程用來和客戶端進行交互。

1、ThreadingTCPServer基礎

使用ThreadingTCPServer:

創建一個繼承自 SocketServer.BaseRequestHandler 的類

類中必須定義一個名稱為 handle 的方法

啟動ThreadingTCPServer

importsocketserverclassmy_server(socketserver.BaseRequestHandler):defhandle(self):whileTrue:print('新的連接：',self.client_address)

data= self.request.recv(1024)if not data:break

print('客戶端說：',data.decode())

self.request.send(data)if __name__ == '__main__':

host,port= 'localhost',5000

#把剛才寫的類當作一個參數傳給my_server類，下面代碼是創建一下多線程socket server

server =socketserver.ThreadingTCPServer((host,port),my_server)#啟動server,這個server會一起運行。

server.serve_forever()

服務器端代碼示例：

importsocket

ip_port= ('127.0.0.1',5000)

sk=socket.socket()

sk.connect(ip_port)whileTrue:

user_inpu= input('請輸入：').strip()

sk.sendall(bytes(user_inpu,'utf8'))

server_recv= sk.recv(1024)print('服務器回應：',str(server_recv,'utf8'))

sk.close()

客戶端代碼示例：

總結

以上是生活随笔為你收集整理的python socket 书籍_Python学习之路——socket的全部內容，希望文章能夠幫你解決所遇到的問題。

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