一、socket的通信流程介紹
一開始,套接字被設計用在同 一臺主機上多個應用程式之間的通訊，這也被稱行程間通訊,或 IPC，套接字有兩種（或者稱為有兩個種族）,分別是基于檔案型的和基于網路型的，
先從服務器端說起，服務器端先初始化Socket，然后與埠系結(bind)，對埠進行監聽(listen)，呼叫accept阻塞，等待客戶端連接，在這時如果有個客戶端初始化一個Socket，然后連接服務器(connect)，如果連接成功，這時客戶端與服務器端的連接就建立了，客戶端發送資料請求，服務器端接收請求并處理請求，然后把回應資料發送給客戶端，客戶端讀取資料，最后關閉連接，一次互動結束.
#socket()模塊函式用法
服務端套接字函式
s.bind() 系結(主機,埠號)到套接字
s.listen() 開始TCP監聽
s.accept() 被動接受TCP客戶的連接,(阻塞式)等待連接的到來
客戶端套接字函式
s.connect() 主動初始化TCP服務器連接
s.connect_ex() connect()函式的擴展版本,出錯時回傳出錯碼,而不是拋出例外
公共用途的套接字函式
s.recv() 接收TCP資料
s.send() 發送TCP資料(send在待發送資料量大于己端快取區剩余空間時,資料丟失,不會發完)
s.sendall() 發送完整的TCP資料(本質就是回圈呼叫send,sendall在待發送資料量大于己端快取區剩余空間時,資料不丟失,回圈呼叫send直到發完)
s.recvfrom() 接收UDP資料
s.sendto() 發送UDP資料
s.getpeername() 連接到當前套接字的遠端的地址
s.getsockname() 當前套接字的地址
s.getsockopt() 回傳指定套接字的引數
s.setsockopt() 設定指定套接字的引數
s.close() 關閉套接字
面向鎖的套接字方法
s.setblocking() 設定套接字的阻塞與非阻塞模式
s.settimeout() 設定阻塞套接字操作的超時時間
s.gettimeout() 得到阻塞套接字操作的超時時間
面向檔案的套接字的函式
s.fileno() 套接字的檔案描述符
s.makefile() 創建一個與該套接字相關的檔案
二、基于tcp協議通信的套接字程式撰寫
1、Socket是：應用層與TCP/IP協議族通信的中間軟體抽象層，它是一組介面，在設計模式中，Socket其實就是一個門面模式，它把復雜的TCP/IP協議族隱藏在Socket介面后面，對用戶來說，一組簡單的介面就是全部，讓Socket去組織資料，以符合指定的協議，
所以，我們無需深入理解tcp/udp協議，socket已經為我們封裝好了，我們只需要遵循socket的規定去編程，寫出的程式自然就是遵循tcp/udp標準的，
也有人將socket說成ip+port，ip是用來標識互聯網中的一臺主機的位置，而port是用來標識這臺機器上的一個應用程式，ip地址是配置到網卡上的，而port是應用程式開啟的，ip與port的系結就標識了互聯網中獨一無二的一個應用程式，
而程式的pid是同一臺機器上不同行程或者執行緒的標識
2、socket編程是 ：基于套接字（傳輸層及其以下）封裝以上的 應用層的程式開發
------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
1、基于tcp協議實作簡單套接字通信（簡單版）
#server import socket # 1、買手機 phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # SOCK_STREAM=》TCP協議 # 2、插手機卡 phone.bind(("127.0.0.1", 8080)) # 127.0.0.1是本地回環地址，只能自己訪問自己，防止外界的干擾 ，埠8080是自己設定的（1025-65535間的任一值，前1024被作業系統占用） # 3、開機 phone.listen(5) #半鏈接池5是自己設定的，不能寫成：半鏈接池backlog=5，會報錯 print('starting %s:%s' %("127.0.0.1", 8080)) # 4、等電話鏈接 conn, client_addr = phone.accept() # 5、收/發訊息 data = https://www.cnblogs.com/guojieying/p/conn.recv(1024) # 1024指的是最大接收的位元組個數 print("收到的客戶端資料：", data.decode('utf-8')) conn.send(data.upper()) # 6、關閉 conn.close() # 掛電話 phone.close() # 關機 #client
import socket # 1、買手機 phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # SOCK_STREAM=》TCP協議 # 2、撥電話 phone.connect(("127.0.0.1", 8080)) # 3、發/收訊息 phone.send("hello".encode('utf-8')) data = phone.recv(1024) print("服務的回傳的資料：", data.decode('utf-8')) # 4、關閉 phone.close()
2、基于tcp協議實作簡單套接字通信（加上回圈改進版）
#server """ 服務端應該滿足的特性： 1、一直對外提供服務 2、并發地提供服務 """ import socket # 1、買手機 phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # SOCK_STREAM=》TCP協議 # 2、插手機卡 phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #就是它，在bind前加 phone.bind(("127.0.0.1", 8080)) # 本地回環 # 3、開機 phone.listen(5) print('starting %s:%s' %("127.0.0.1", 8080)) # 4、等電話鏈接=>鏈接回圈 while True: conn, client_addr = phone.accept() print(client_addr) # 5、收/發訊息=>通信回圈 while True: try: data = conn.recv(1024) # 最大接收的位元組個數 if len(data) == 0: # 針對linux系統 break print("收到的客戶端資料：", data.decode('utf-8')) conn.send(data.upper()) except Exception: # 針對windows系統 break # 6、關閉 conn.close() # 掛電話 phone.close() # 關機 #client import socket # 1、買手機 phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # SOCK_STREAM=》TCP協議 # 2、撥電話 phone.connect(("127.0.0.1", 8080)) # 3、發/收訊息=>通信回圈 while True: msg = input(">>: ").strip() phone.send(msg.encode('utf-8')) data = phone.recv(1024) print("服務的回傳的資料：", data.decode('utf-8')) # 4、關閉 phone.close()
3、用于測驗的 server
#與改進版server的不同之處是在于這里只是用于一直對外提供服務，缺bind前面一橫，還有適用于linux系統的那兩行判斷 """ 服務端應該滿足的特性： 1、一直對外提供服務 """ import socket # 1、買手機 phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # SOCK_STREAM=》TCP協議 # 2、插手機卡 phone.bind(("192.168.11.186", 8888)) # 本地回環 # 3、開機 phone.listen(5) print('starting %s:%s' %("127.0.0.1", 8888)) # 4、等電話鏈接=>鏈接回圈 while True: conn, client_addr = phone.accept() print(client_addr) # 5、收/發訊息=>通信回圈 while True: try: data = conn.recv(1024) # 最大接收的位元組個數 print("收到的客戶端資料：", data.decode('utf-8')) conn.send(data.upper()) except Exception: break # 6、關閉 conn.close() # 掛電話 phone.close() # 關機
4、遠程執行命令（與地球上別的計算機互動）
#server 在改進版基礎上增加了obj那一塊內容
""" 服務端應該滿足的特性： 1、一直對外提供服務 2、并發地提供服務 """ import socket import subprocess # 1、買手機 phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # SOCK_STREAM=》TCP協議 # 2、插手機卡 phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 就是它，在bind前加 phone.bind(("127.0.0.1", 8080)) # 本地回環 # 3、開機 phone.listen(5) print('starting %s:%s' % ("127.0.0.1", 8080)) # 4、等電話鏈接=>鏈接回圈 while True: conn, client_addr = phone.accept() print(client_addr) # 5、收/發訊息=>通信回圈 while True: try: cmd = conn.recv(1024) # 最大接收的位元組個數 if len(cmd) == 0: # 針對linux系統 break obj = subprocess.Popen(cmd.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE ) res=obj.stdout.read()+obj.stderr.read() # ??? print(res) conn.send(res) except Exception: # 針對windows系統 break # 6、關閉 conn.close() # 掛電話 phone.close() # 關機
#client
同改進版的client
5、 補充的要點：
（1）服務端滿足的條件：一直服務，并發的提供服務
（2）例外處理
（3）判斷data長度，在linux系統上用
（4）ip地址重用問題（就是把軟體關了，會發現還沒關）解決：
一，系統回收資源慢那就慢慢等會；
二，換一個埠號試試；
三，加入一條socket配置，重用ip和埠
phone.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它，在bind前加
四，發現系統存在大量TIME_WAIT狀態的連接，通過調整linux內核引數解決
vi /etc/sysctl.conf 編輯檔案，加入以下內容： net.ipv4.tcp_syncookies = 1 net.ipv4.tcp_tw_reuse = 1 net.ipv4.tcp_tw_recycle = 1 net.ipv4.tcp_fin_timeout = 30 然后執行 /sbin/sysctl -p 讓引數生效， net.ipv4.tcp_syncookies = 1 表示開啟SYN Cookies，當出現SYN等待佇列溢位時，啟用cookies來處理，可防范少量SYN攻擊，默認為0，表示關閉； net.ipv4.tcp_tw_reuse = 1 表示開啟重用，允許將TIME-WAIT sockets重新用于新的TCP連接，默認為0，表示關閉； net.ipv4.tcp_tw_recycle = 1 表示開啟TCP連接中TIME-WAIT sockets的快速回收，默認為0，表示關閉， net.ipv4.tcp_fin_timeout 修改系統默認的 TIMEOUT 時間linux系統解決方案
-----31-----
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/55151.html
標籤：Python