文章目錄

• • • socket的定義
    • 套接字的工作流程
    • socket函數(shù)使用
    • • socket函數(shù)用法
      • 服務(wù)端套接字函數(shù)
      • 客戶端套接字函數(shù)
      • 公共用途的套接字函數(shù)
      • 面向文件的套接字方法
      • 打電話的流程演示
      • • 服務(wù)端.py
        • 客戶端.py
    • 基于TCP的套接字
    • 基于UDP的套接字
    • • udp服務(wù)端
      • udp客戶端
      • 示例
      • • 服務(wù)端
        • 客戶端
    • 模擬QQ聊天，多個客戶端和服務(wù)端通信
    • 其他常見問題如粘包等

socket的定義

Socket是應(yīng)用層與TCP/IP協(xié)議族通信的中間軟件抽象層，它是一組接口。在設(shè)計模式中，Socket其實就是一個門面模式，它把復(fù)雜的TCP/IP協(xié)議族隱藏在Socket接口后面，對用戶來說，一組簡單的接口就是全部，讓Socket去組織數(shù)據(jù)，以符合指定的協(xié)議。所以，我們無需深入理解tcp/udp協(xié)議，socket已經(jīng)為我們封裝好了，我們只需要遵循socket的規(guī)定去編程，寫出的程序自然就是遵循tcp/udp標(biāo)準(zhǔn)的。

補(bǔ)充：也有人將socket說成ip+port，ip是用來標(biāo)識互聯(lián)網(wǎng)中的一臺主機(jī)的位置，而port是用來標(biāo)識這臺機(jī)器上的一個應(yīng)用程序，ip地址是配置到網(wǎng)卡上的，而port是應(yīng)用程序開啟的，ip與port的綁定就標(biāo)識了互聯(lián)網(wǎng)中獨一無二的一個應(yīng)用程序，而程序的pid是同一臺機(jī)器上不同進(jìn)程或者線程的標(biāo)識

套接字的工作流程

先從服務(wù)器端說起。服務(wù)器端先初始化Socket，然后與端口綁定(bind)，對端口進(jìn)行監(jiān)聽(listen)，調(diào)用accept阻塞，等待客戶端連接。在這時如果有個客戶端初始化一個Socket，然后連接服務(wù)器(connect)，如果連接成功，這時客戶端與服務(wù)器端的連接就建立了。客戶端發(fā)送數(shù)據(jù)請求，服務(wù)器端接收請求并處理請求，然后把回應(yīng)數(shù)據(jù)發(fā)送給客戶端，客戶端讀取數(shù)據(jù)，最后關(guān)閉連接，一次交互結(jié)束。

socket函數(shù)使用

socket函數(shù)用法

import socket socket.socket(socket_family,socket_type,protocal=0) # socket_family 可以是 AF_UNIX 或 AF_INET。 # socket_type 可以是 SOCK_STREAM 或 SOCK_DGRAM。protocol 一般不填,默認(rèn)值為 0。# 獲取tcp/ip套接字 tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 獲取udp/ip套接字 udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)# 由于 socket 模塊中有太多的屬性。我們在這里破例使用了'from module import *'語句。 # 使用 'from socket import *',我們就把 socket 模塊里的所有屬性都帶到我們的命名空間里了,這樣能 大幅減短我們的代碼。 # 例如tcpSock = socket(AF_INET, SOCK_STREAM)

服務(wù)端套接字函數(shù)

s.bind() #綁定(主機(jī),端口號)到套接字 s.listen() #開始TCP監(jiān)聽 s.accept() #被動接受TCP客戶的連接,(阻塞式)等待連接的到來

客戶端套接字函數(shù)

s.connect() #主動初始化TCP服務(wù)器連接 s.connect_ex() #connect()函數(shù)的擴(kuò)展版本,出錯時返回出錯碼,而不是拋出異常

公共用途的套接字函數(shù)

s.recv() #接收TCP數(shù)據(jù) s.send() #發(fā)送TCP數(shù)據(jù)(send在待發(fā)送數(shù)據(jù)量大于己端緩存區(qū)剩余空間時,數(shù)據(jù)丟失,不會發(fā)完) s.sendall() #發(fā)送完整的TCP數(shù)據(jù)(本質(zhì)就是循環(huán)調(diào)用send,sendall在待發(fā)送數(shù)據(jù)量大于己端緩存區(qū)剩余空間時,數(shù)據(jù)不丟失,循環(huán)調(diào)用send直到發(fā)完) s.recvfrom() #接收UDP數(shù)據(jù) s.sendto() #發(fā)送UDP數(shù)據(jù) s.getpeername() #連接到當(dāng)前套接字的遠(yuǎn)端的地址 s.getsockname() #當(dāng)前套接字的地址 s.getsockopt() #返回指定套接字的參數(shù) s.setsockopt() #設(shè)置指定套接字的參數(shù) s.close() #關(guān)閉套接字

面向文件的套接字方法

s.fileno() #套接字的文件描述符 s.makefile() #創(chuàng)建一個與該套接字相關(guān)的文件

打電話的流程演示

服務(wù)端.py

import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 買手機(jī) phone.bind(('127.0.0.1',8080)) # 插電話卡phone.listen(5) # 開機(jī)，backlogprint('starting....') conn,addr=phone.accept() # 接電話 print(conn) print('client addr',addr) print('ready to read msg') client_msg=conn.recv(1024) # 收消息 print('client msg: %s' %client_msg) conn.send(client_msg.upper()) #發(fā)消息conn.close() phone.close()

客戶端.py

import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) phone.connect(('127.0.0.1',8080)) # 撥通電話phone.send('hello'.encode('utf-8')) # 發(fā)消息back_msg=phone.recv(1024) print(back_msg)phone.close()

基于TCP的套接字

略

基于UDP的套接字

udp服務(wù)端

ss = socket() # 創(chuàng)建一個服務(wù)器的套接字
ss.bind() # 綁定服務(wù)器套接字
inf_loop: # 服務(wù)器無限循環(huán)
cs = ss.recvfrom()/ss.sendto() # 對話(接收與發(fā)送)
ss.close() # 關(guān)閉服務(wù)器套接字

udp客戶端

cs = socket() # 創(chuàng)建客戶套接字
comm_loop: # 通訊循環(huán)
cs.sendto()/cs.recvfrom() # 對話(發(fā)送/接收)
cs.close() # 關(guān)閉客戶套接字

示例

服務(wù)端

# -*- coding: utf-8 -*- """ @File : 191226_基于UDP協(xié)議的socket_server端.py @Time : 2019/12/26 23:32 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """ import socketip_port = ('192.168.1.49', 9000) BUFSIZE = 1024 udp_server_client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)udp_server_client.bind(ip_port)while True:msg, addr = udp_server_client.recvfrom(BUFSIZE)print(msg.decode('utf-8'), addr)udp_server_client.sendto(msg.upper(), addr)

客戶端

# -*- coding: utf-8 -*- """ @File : 191226_基于UDP協(xié)議的socket_client端.py @Time : 2019/12/26 23:32 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """import socketip_port = ('192.168.1.49', 9000) BUFSIZE = 1024 udp_server_client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)while True:msg = input('>>: ').strip()if not msg:continueudp_server_client.sendto(msg.encode('utf-8'), ip_port)back_msg, addr = udp_server_client.recvfrom(BUFSIZE)print(back_msg.decode('utf-8'), addr)

模擬QQ聊天，多個客戶端和服務(wù)端通信

服務(wù)端：

# -*- coding: utf-8 -*- """ @File : 191228_多個客戶端與服務(wù)端通信_server端.py @Time : 2019/12/28 10:46 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """ import socketip_port = ('192.168.1.49', 9000) udp_server_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) udp_server_sock.bind(ip_port)while True:qq_msg, addr = udp_server_sock.recvfrom(1024)print('來自[{}:{}]的一條消息:{}'.format(addr[0], addr[1], qq_msg.decode('utf-8')))back_msg = input('回復(fù)消息: ').strip()udp_server_sock.sendto(back_msg.encode('utf-8'), addr)

客戶端：

# -*- coding: utf-8 -*- """ @File : 191228_多個客戶端與服務(wù)端通信_client端1.py @Time : 2019/12/28 10:51 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """ import socketBUFSIZE = 1024 udp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)qq_name_dic = {'TOM': ('192.168.1.49', 9000),'JACK': ('192.168.1.49', 9000),'一棵樹': ('192.168.1.49', 9000),'武大郎': ('192.168.1.49', 9000), }while True:qq_name = input('請選擇聊天對象: ').strip()while True:if not qq_name or qq_name not in qq_name_dic:breakmsg = input('請輸入消息,回車發(fā)送: ').strip()if msg == 'quit':breakif not msg:continueudp_client_socket.sendto(msg.encode('utf-8'), qq_name_dic[qq_name])back_msg, addr = udp_client_socket.recvfrom(BUFSIZE)print('來自[{}:{}]的一條消息:{}'.format(addr[0], addr[1], back_msg.decode('utf-8')))# udp_client_socket.close()

其他常見問題如粘包等

略

引用文章1：【Python3之socket編程】

總結(jié)

以上是生活随笔為你收集整理的python socket.socket()函数 套接字详解及TCP、UDP程序示例（粘包等）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。