pythonsocketudp編程

① python udp發送數據的問題

一個簡單的python socket編程

一、套接字

套接字是為特定網路協議（例如TCP/IP，ICMP/IP，UDP/IP等）套件對上的網路應用程序提供者提供當前可移植標準的對象。它們允許程序接受並進行連接，如發送和接受數據。為了建立通信通道，網路通信的每個端點擁有一個套接字對象極為重要。

套接字為BSD UNIX系統核心的一部分，而且他們也被許多其他類似UNIX的操作系統包括Linux所採納。許多非BSD UNIX系統（如ms-dos，windows，os/2，mac os及大部分主機環境）都以庫形式提供對套接字的支持。

三種最流行的套接字類型是:stream,datagram和raw。stream和datagram套接字可以直接與TCP協議進行介面，而raw套接字則介面到IP協議。但套接字並不限於TCP/IP。

二、套接字模塊

套接字模塊是一個非常簡單的基於對象的介面，它提供對低層BSD套接字樣式網路的訪問。使用該模塊可以實現客戶機和伺服器套接字。要在python 中建立具有TCP和流套接字的簡單伺服器，需要使用socket模塊。利用該模塊包含的函數和類定義，可生成通過網路通信的程序。一般來說，建立伺服器連接需要六個步驟。

第1步是創建socket對象。調用socket構造函數。

socket=socket.socket(familly,type)

family的值可以是AF_UNIX(Unix域，用於同一台機器上的進程間通訊)，也可以是AF_INET（對於IPV4協議的TCP和 UDP），至於type參數，SOCK_STREAM（流套接字）或者 SOCK_DGRAM（數據報文套接字）,SOCK_RAW（raw套接字）。

第2步則是將socket綁定（指派）到指定地址上，socket.bind(address)

address必須是一個雙元素元組,((host,port)),主機名或者ip地址+埠號。如果埠號正在被使用或者保留，或者主機名或ip地址錯誤，則引發socke.error異常。

第3步，綁定後，必須准備好套接字，以便接受連接請求。

socket.listen(backlog)

backlog指定了最多連接數，至少為1，接到連接請求後，這些請求必須排隊，如果隊列已滿，則拒絕請求。

第4步，伺服器套接字通過socket的accept方法等待客戶請求一個連接：

connection,address=socket.accept()

調用accept方法時，socket會進入'waiting'（或阻塞）狀態。客戶請求連接時，方法建立連接並返回伺服器。accept方法返回一個含有倆個元素的元組，形如(connection,address)。第一個元素（connection）是新的socket對象，伺服器通過它與客戶通信；第二個元素（address）是客戶的internet地址。

第5步是處理階段，伺服器和客戶通過send和recv方法通信（傳輸數據）。伺服器調用send，並採用字元串形式向客戶發送信息。send方法返回已發送的字元個數。伺服器使用recv方法從客戶接受信息。調用recv時，必須指定一個整數來控制本次調用所接受的最大數據量。recv方法在接受數據時會進入'blocket'狀態，最後返回一個字元串，用它來表示收到的數據。如果發送的量超過recv所允許，數據會被截斷。多餘的數據將緩沖於接受端。以後調用recv時，多餘的數據會從緩沖區刪除。

第6步，傳輸結束，伺服器調用socket的close方法以關閉連接。

建立一個簡單客戶連接則需要4個步驟。

第1步，創建一個socket以連接伺服器 socket=socket.socket(family,type)

第2步，使用socket的connect方法連接伺服器 socket.connect((host,port))

第3步，客戶和伺服器通過send和recv方法通信。

第4步，結束後，客戶通過調用socket的close方法來關閉連接。

python 編寫server的步驟：

第一步是創建socket對象。調用socket構造函數。如：

socket = socket.socket( family, type )

family參數代表地址家族，可為AF_INET或AF_UNIX。AF_INET家族包括Internet地址，AF_UNIX家族用於同一台機器上的進程間通信。
type參數代表套接字類型，可為SOCK_STREAM(流套接字)和SOCK_DGRAM(數據報套接字)。

第二步是將socket綁定到指定地址。這是通過socket對象的bind方法來實現的：

socket.bind( address )

由AF_INET所創建的套接字，address地址必須是一個雙元素元組，格式是(host,port)。host代表主機，port代表埠號。如果埠號正在使用、主機名不正確或埠已被保留，bind方法將引發socket.error異常。

第三步是使用socket套接字的listen方法接收連接請求。

socket.listen( backlog )

backlog指定最多允許多少個客戶連接到伺服器。它的值至少為1。收到連接請求後，這些請求需要排隊，如果隊列滿，就拒絕請求。

第四步是伺服器套接字通過socket的accept方法等待客戶請求一個連接。

connection, address = socket.accept()

調用accept方法時，socket會時入「waiting」狀態。客戶請求連接時，方法建立連接並返回伺服器。accept方法返回一個含有兩個元素的元組(connection,address)。第一個元素connection是新的socket對象，伺服器必須通過它與客戶通信；第二個元素 address是客戶的Internet地址。
第五步是處理階段，伺服器和客戶端通過send和recv方法通信(傳輸數據)。伺服器調用send，並採用字元串形式向客戶發送信息。send方法返回已發送的字元個數。伺服器使用recv方法從客戶接收信息。調用recv 時，伺服器必須指定一個整數，它對應於可通過本次方法調用來接收的最大數據量。recv方法在接收數據時會進入「blocked」狀態，最後返回一個字元串，用它表示收到的數據。如果發送的數據量超過了recv所允許的，數據會被截短。多餘的數據將緩沖於接收端。以後調用recv時，多餘的數據會從緩沖區刪除(以及自上次調用recv以來，客戶可能發送的其它任何數據)。
傳輸結束，伺服器調用socket的close方法關閉連接。
python編寫client的步驟：
創建一個socket以連接伺服器：socket = socket.socket( family, type )

使用socket的connect方法連接伺服器。對於AF_INET家族,連接格式如下：

socket.connect( (host,port) )

host代表伺服器主機名或IP，port代表伺服器進程所綁定的埠號。如連接成功，客戶就可通過套接字與伺服器通信，如果連接失敗，會引發socket.error異常。
處理階段，客戶和伺服器將通過send方法和recv方法通信。
傳輸結束，客戶通過調用socket的close方法關閉連接。
下面給個簡單的例子：

server.py
python 代碼

if __name__ == '__main__':
import socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('localhost', 8001))
sock.listen(5)
while True:
connection,address = sock.accept()
try:
connection.settimeout(5)
buf = connection.recv(1024)
if buf == '1':
connection.send('welcome to server!')
else:
connection.send('please go out!')
except socket.timeout:
print 'time out'
connection.close()

client.py
python 代碼

if __name__ == '__main__':
import socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('localhost', 8001))
import time
time.sleep(2)
sock.send('1')
print sock.recv(1024)
sock.close()

在終端運行server.py，然後運行clien.py，會在終端列印「welcome to server!"。如果更改client.py的sock.send('1')為其它值在終端會列印」please go out!「，更改time.sleep(2)為大於5的數值， 伺服器將會超時。

舉例：

服務端:

#socket server端
#獲取socket構造及常量
from socket import *
#''代表伺服器為localhost
myHost = ''
#在一個非保留埠號上進行監聽
myPort = 50007

#設置一個TCP socket對象
sockobj = socket(AF_INET, SOCK_STREAM)
#綁定它至埠號
sockobj.bind((myHost, myPort))
#監聽，允許5個連結
sockobj.listen(5)

#直到進程結束時才結束循環
while True:
#等待下一個客戶端連結
connection, address = sockobj.accept( )
#連結是一個新的socket
print 'Server connected by', address
while True:
#讀取客戶端套接字的下一行
data = connection.recv(1024)
#如果沒有數量的話，那麼跳出循環
if not data: break
#發送一個回復至客戶端
connection.send('Echo=>' + data)
#當socket關閉時eof
connection.close( )

客戶端:

import sys
from socket import *
serverHost = 'localhost'
serverPort = 50007

#發送至服務端的默認文本
message = ['Hello network world']
#如果參數大於1的話，連結的服務端為第一個參數
if len(sys.argv) > 1:
serverHost = sys.argv[1]
#如果參數大於2的話，連結的文字為第二個參數
if len(sys.argv) > 2:
message = sys.argv[2:]

#建立一個tcp/ip套接字對象
sockobj = socket(AF_INET, SOCK_STREAM)
#連結至伺服器及埠
sockobj.connect((serverHost, serverPort))

for line in message:
#經過套按字發送line至服務端
sockobj.send(line)
#從服務端接收到的數據，上限為1k
data = sockobj.recv(1024)
#確認他是引用的，是'x'
print 'Client received:', repr(data)

#關閉套接字
sockobj.close( )

② python中使用socket編程，如何能夠通過UDP傳遞一個列表類型的數據

Python中的 list 或者 dict 都可以轉成JSON字元串來發送，接收後再轉回來。

首先

importjson

然後，把 list 或 dict 轉成 JSON

json_string=json.mps(list_or_dict)

如果你用的是Python3，這里的 json_string 會是 str 類型（即Python2的unicode類型），可能需要編碼一下：

if type(json_string) == six.text_type:

json_string = json_string.encode('UTF-8')

用socket發送過去，例如

s.sendto(json_string,address)

對方用socket接收，例如

json_string,addr=s.recvfrom(2048)

把JSON轉成 list 或 dict

list_or_dict=json.loads(json_string)

下面是個完整的例子：

client.py

#!/usr/bin/envpython
#-*-coding:UTF-8-*-

importsocket
importjson
importsix

address=('127.0.0.1',31500)
s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
mylist=[1,2,3,4,5,6,7,8,9,10]
json_string=json.mps(mylist)
iftype(json_string)==six.text_type:
json_string=json_string.encode('UTF-8')
s.sendto(json_string,address)
s.close()

server.py

#!/usr/bin/envpython
#-*-coding:UTF-8-*-

importsocket
importjson

address=('127.0.0.1',31500)
s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
s.bind(address)
json_string,addr=s.recvfrom(2048)
mylist=json.loads(json_string)
print(mylist)
s.close()

請先運行server.py，再運行client.py

③ 如何用python方法檢測UDP埠

本文實例講述了python檢測遠程udp埠是否打開的方法。分享給大家供大家參考。具體實現方法如下：

復制代碼代碼如下:
import socket
import threading
import time
import struct
import Queue
queue = Queue.Queue()
def udp_sender(ip,port):
try:
ADDR = (ip,port)
sock_udp = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
sock_udp.sendto("abcd...",ADDR)
sock_udp.close()
except:
pass
def icmp_receiver(ip,port):
icmp = socket.getprotobyname("icmp")
try:
sock_icmp = socket.socket(socket.AF_INET, socket.SOCK_RAW, icmp)
except socket.error, (errno, msg):
if errno == 1:
# Operation not permitted
msg = msg + (
" - Note that ICMP messages can only be sent from processes"
" running as root."
)
raise socket.error(msg)
raise # raise the original error
sock_icmp.settimeout(3)
try:
recPacket,addr = sock_icmp.recvfrom(64)
except:
queue.put(True)
return
icmpHeader = recPacket[20:28]
icmpPort = int(recPacket.encode('hex')[100:104],16)
head_type, code, checksum, packetID, sequence = struct.unpack(
"bbHHh", icmpHeader
)
sock_icmp.close()
if code == 3 and icmpPort == port and addr[0] == ip:
queue.put(False)
return
def checker_udp(ip,port):
thread_udp = threading.Thread(target=udp_sender,args=(ip,port))
thread_icmp = threading.Thread(target=icmp_receiver,args=(ip,port))
thread_udp.daemon= True
thread_icmp.daemon = True
thread_icmp.start()
time.sleep(0.1)
thread_udp.start()

thread_icmp.join()
thread_udp.join()
return queue.get(False)
if __name__ == '__main__':
import sys
print checker_udp(sys.argv[1],int(sys.argv[2]))

希望本文所述對大家的Python程序設計有所幫助。

④ Socket 通信之 UDP 通信

前段時間，我們在 這篇文章 中談到了多進程和進程之間的通信方式，主要談到了本地進程之間使用隊列（Queue）進程通信，如果我們要通信的進程不在同一台主機上，我們就無法使用隊列進行通信了，這時就需要使用 Socket（套接字）。
Socket 是應用層和傳輸層之間的一層抽象協議，可以用來進行進程間通信，一般有 UDP 和 TCP 兩種通信方式，前者速度稍快，穩定性不好，無法丟包重傳。後者速度稍慢一點，但穩定性很好，可以丟包重傳。
本文首先介紹使用 Socket 進行 UDP 通信。

使用 Socket 進行 UDP 通信的流程如下：

下面依次進行講解。

要進行 Socket 通信，我們需要使用 socket 模塊，首先需要創建一個 Socket 對象。下面是兩種創建方式：

如果我們需要向別的主機發送數據，我們需要改主機的 IP 地址和相應的埠號。在使用 Socket 進行通信時，需要將兩個信息寫在一元組中，元組的第一項為目標主機 IP 地址，第二項為接受數據的埠號：

其中，IP 地址使用字元串類型，埠號使用數字類型。

如果不綁定埠，每次使用 Socket 時都會由操作系統動態分配一個埠，我們也可以綁定為某個固定的埠。這樣做的好處是：如果我們想要接受其他主機的信息，其他主機可以直接向這個埠發送數據，如果使用動態埠的話，發送方並不知道目標埠是什麼，因此無法向接收方發送數據。
綁定埠需要使用 Socket 對象的 bind 方法：

bind 方法接受一個元組作為參數，元組的第一項為綁定的 IP 地址，第二項為綁定的埠號。我們可以把第一項指定為本機上的任意一個 IP 地址，也可以設置為一個空字元串 "" ，表示本機上任意合法的 IP 地址。

使用 UDP 套接字協議時，發送數據使用 Socket 對象的 sendto 方法，接受數據使用 Socket 對象的 recvfrom 方法。這兩個方法的使用方式如下：

sendto 方法接受兩個參數：發送的數據和目標主機的 IP 和埠元組，在 Python3 中，發送的數據應該轉為 byte 類型發送，Python2 中可以直接發送字元串。
recvfrom 接受一個參數：本次接受的最大數據尺寸。該方法是阻塞的，只有在接收到數據後才能進行後續的操作。

就像使用文件那樣，在使用完套接字後，需要關閉它，調用 close 方法即可。

上面我們介紹了 Socket 的使用方式，下面我們來做一個單工通信的例子（一方負責發送信息，一方負責接收信息）。
我們這里來創建兩個文件：用以發送信息的 send.py 和用以接收信息的 recv.py。該實例在虛擬機中模擬（注意將虛擬機設置為橋接模式）。
創建 send.py：

創建 recv.py：

運行結果如下：

上面實現了一個單工通信的例子：一方負責發，一方負責接收。下面我們繼續實現一個雙工通信的例子，使雙方都能夠收發消息。
由於接收和發送消息時是使用 while 循環不斷輪詢的，因此要實現同時發送和接受，我們需要進行多任務處理。
新建一個 msg.py：

這里我們使用 3000 埠發送數據，3001 埠接收數據，運行程序時只需填寫目標主機的 IP 地址，就可以進行通信。
運行效果：

我們還可以進行區域網內的廣播，只需對 Socket 加上一條設置：

同時，發送廣播需要一個廣播地址，以及目標主機接受廣播的埠：

上面的設置只能給 0 網段的主機發送廣播，要想給區域網中所有的主機發送廣播，可以這樣設置：

下面我們新建一個 send.py 用來發送廣播：

新建一個 recv.py 用來接收廣播：

運行效果如圖：

完。

⑤ 如何用Python編寫一個聊天室

python聊天室(python2.7版本)：

暫時先給出兩種版本的,tcp+udp

都是分別運行server.py和client.py，就可以進行通訊了。

別外還有websocket版本，這個是有web界面的和基本web服務的，如果需要的話，我會把基本的代碼貼一版上來。

TCP版本：

socket-tcp-server.py（服務端）:

#-*-encoding:utf-8-*-
#socket.getaddrinfo(host,port,family=0,socktype=0,proto=0,flags=0)
#根據給定的參數host/port，相應的轉換成一個包含用於創建socket對象的五元組，
#參數host為域名，以字元串形式給出代表一個IPV4/IPV6地址或者None.
#參數port如果字元串形式就代表一個服務名，比如「http」"ftp""email"等，或者為數字，或者為None
#參數family為地主族，可以為AF_INET，AF_INET6，AF_UNIX.
#參數socktype可以為SOCK_STREAM(TCP)或者SOCK_DGRAM(UDP)
#參數proto通常為0可以直接忽略
#參數flags為AI_*的組合，比如AI_NUMERICHOST，它會影響函數的返回值
#附註：給參數host,port傳遞None時建立在C基礎，通過傳遞NULL。
#該函數返回一個五元組(family,socktype,proto,canonname,sockaddr)，同時第五個參數sockaddr也是一個二元組(address,port)
#更多的方法及鏈接請訪問
#Echoserverprogram
fromsocketimport*
importsys
importthreading
fromtimeimportctime
fromtimeimportlocaltime
importtraceback
importtime
importsubprocess
reload(sys)
sys.setdefaultencoding("utf8")


HOST='127.0.0.1'
PORT=8555#設置偵聽埠
BUFSIZ=1024

classTcpServer():
def__init__(self):
self.ADDR=(HOST,PORT)
try:
self.sock=socket(AF_INET,SOCK_STREAM)
print'%disopen'%PORT

self.sock.bind(self.ADDR)
self.sock.listen(5)
#設置退出條件
self.STOP_CHAT=False

#所有監聽的客戶端
self.clients={}
self.thrs={}
self.stops=[]

exceptException,e:
print"%disdown"%PORT
returnFalse

defIsOpen(ip,port):

s=socket(AF_INET,SOCK_STREAM)
try:
s.connect((ip,int(port)))
#s.shutdown(2)
#利用shutdown()函數使socket雙向數據傳輸變為單向數據傳輸。shutdown()需要一個單獨的參數，
#該參數表示s了如何關閉socket。具體為：0表示禁止將來讀；1表示禁止將來寫；2表示禁止將來讀和寫。
print'%disopen'%port
returnTrue
except:
print'%disdown'%port
returnFalse

deflisten_client(self):
whilenotself.STOP_CHAT:
print(u'等待接入，偵聽埠:%d'%(PORT))
self.tcpClientSock,self.addr=self.sock.accept()
print(u'接受連接，客戶端地址：',self.addr)
address=self.addr
#將建立的clientsocket鏈接放到列表self.clients中
self.clients[address]=self.tcpClientSock
#分別將每個建立的鏈接放入進程中，接收且分發消息
self.thrs[address]=threading.Thread(target=self.readmsg,args=[address])
self.thrs[address].start()
time.sleep(0.5)defreadmsg(self,address):
#如果地址不存在，則返回False
ifaddressnotinself.clients:
returnFalse
#得到發送消息的clientsocket
client=self.clients[address]
whileTrue:
try:
#獲取到消息內容data
data=client.recv(BUFSIZ)
except:
print(e)
self.close_client(address)
break
ifnotdata:
break
#python3使用bytes，所以要進行編碼
#s='%s發送給我的信息是:[%s]%s'%(addr[0],ctime(),data.decode('utf8'))
#對日期進行一下格式化
ISOTIMEFORMAT='%Y-%m-%d%X'
stime=time.strftime(ISOTIMEFORMAT,localtime())
s=u'%s發送給我的信息是:%s'%(str(address),data.decode('utf8'))
#將獲得的消息分發給鏈接中的clientsocket
forkinself.clients:
self.clients[k].send(s.encode('utf8'))
self.clients[k].sendall('sendall:'+s.encode('utf8'))
printstr(k)
print([stime],':',data.decode('utf8'))
#如果輸入quit(忽略大小寫),則程序退出
STOP_CHAT=(data.decode('utf8').upper()=="QUIT")
ifSTOP_CHAT:
print"quit"
self.close_client(address)
print"alreadyquit"
break

defclose_client(self,address):
try:
client=self.clients.pop(address)
self.stops.append(address)
client.close()
forkinself.clients:
self.clients[k].send(str(address)+u"已經離開了")
except:
pass
print(str(address)+u'已經退出')


if__name__=='__main__':
tserver=TcpServer()
tserver.listen_client()

——————————華麗的分割線——————————

socket-tcp-client.py（客戶端）：

#-*-encoding:utf-8-*-
fromsocketimport*
importsys
importthreading
importtime
reload(sys)
sys.setdefaultencoding("utf8")


#測試，連接本機
HOST='127.0.0.1'
#設置偵聽埠
PORT=8555
BUFSIZ=1024

classTcpClient:

ADDR=(HOST,PORT)
def__init__(self):
self.HOST=HOST
self.PORT=PORT
self.BUFSIZ=BUFSIZ
#創建socket連接
self.client=socket(AF_INET,SOCK_STREAM)
self.client.connect(self.ADDR)
#起一個線程，監聽接收的信息
self.trecv=threading.Thread(target=self.recvmsg)
self.trecv.start()

defsendmsg(self):
#循環發送聊天消息，如果socket連接存在則一直循環，發送quit時關閉鏈接
whileself.client.connect_ex(self.ADDR):
data=raw_input('>:')
ifnotdata:
break
self.client.send(data.encode('utf8'))
print(u'發送信息到%s：%s'%(self.HOST,data))
ifdata.upper()=="QUIT":
self.client.close()
printu"已關閉"
break
defrecvmsg(self):
#接收消息，如果鏈接一直存在，則持續監聽接收消息
try:
whileself.client.connect_ex(self.ADDR):
data=self.client.recv(self.BUFSIZ)
print(u'從%s收到信息：%s'%(self.HOST,data.decode('utf8')))
exceptException,e:
printstr(e)

if__name__=='__main__':
client=TcpClient()
client.sendmsg()

UDP版本：

socket-udp-server.py

#-*-coding:utf8-*-

importsys
importtime
importtraceback
importthreading
reload(sys)
sys.setdefaultencoding('utf-8')

importsocket
importtraceback

HOST="127.0.0.1"
PORT=9555
CHECK_PERIOD=20
CHECK_TIMEOUT=15

classUdpServer(object):
def__init__(self):
self.clients=[]
self.beats={}
self.ADDR=(HOST,PORT)
try:
self.sock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
self.sock.bind(self.ADDR)#綁定同一個域名下的所有機器
self.beattrs=threading.Thread(target=self.checkheartbeat)
self.beattrs.start()
exceptException,e:
traceback.print_exc()
returnFalse

deflisten_client(self):
whileTrue:
time.sleep(0.5)
print"hohohohohoo"
try:
recvData,address=self.sock.recvfrom(2048)
ifnotrecvData:
self.close_client(address)
break
ifaddressinself.clients:
senddata=u"%s發送給我的信息是:%s"%(str(address),recvData.decode('utf8'))
ifrecvData.upper()=="QUIT":
self.close_client(address)
ifrecvData=="HEARTBEAT":
self.heartbeat(address)
continue
else:
self.clients.append(address)
senddata=u"%s發送給我的信息是:%s"%(str(address),u'進入了聊天室')
forcinself.clients:
try:
self.sock.sendto(senddata,c)
exceptException,e:
printstr(e)
self.close_client(c)
exceptException,e:
#traceback.print_exc()
printstr(e)
pass

defheartbeat(self,address):
self.beats[address]=time.time()

defcheckheartbeat(self):

whileTrue:
print"checkheartbeat"
printself.beats
try:
forcinself.clients:
printtime.time()
printself.beats[c]
ifself.beats[c]+CHECK_TIMEOUT<time.time():
printu"%s心跳超時，連接已經斷開"%str(c)
self.close_client(c)
else:
printu"checkp%s,沒有斷開"%str(c)
exceptException,e:
traceback.print_exc()
printstr(e)
pass
time.sleep(CHECK_PERIOD)

defclose_client(self,address):
try:
ifaddressinself.clients:
self.clients.remove(address)
ifself.beats.has_key(address):
delself.beats[address]
printself.clients
forcinself.clients:
self.sock.sendto(u'%s已經離開了'%str(address),c)
print(str(address)+u'已經退出')
exceptException,e:
printstr(e)
raise

if__name__=="__main__":
udpServer=UdpServer()
udpServer.listen_client()

——————————華麗的分割線——————————
socket-udp-client.py:
#-*-coding:utf8-*-

importsys
importthreading
importtime
reload(sys)
sys.setdefaultencoding('utf-8')

importsocket

HOST="127.0.0.1"
PORT=9555
#BEAT_PORT=43278
BEAT_PERIOD=5


classUdpClient(object):
def__init__(self):
self.clientsock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
self.HOST=HOST
self.ADDR=(HOST,PORT)
self.clientsock.sendto(u'請求建立鏈接',self.ADDR)
self.recvtrs=threading.Thread(target=self.recvmsg)
self.recvtrs.start()
self.hearttrs=threading.Thread(target=self.heartbeat)
self.hearttrs.start()

defsendmsg(self):
whileTrue:
data=raw_input(">:")
ifnotdata:
break
self.clientsock.sendto(data.encode('utf-8'),self.ADDR)
ifdata.upper()=='QUIT':
self.clientsock.close()
break

defheartbeat(self):
whileTrue:
self.clientsock.sendto('HEARTBEAT',self.ADDR)
time.sleep(BEAT_PERIOD)

defrecvmsg(self):
whileTrue:
recvData,addr=self.clientsock.recvfrom(1024)
ifnotrecvData:
break
print(u'從%s收到信息：%s'%(self.HOST,recvData.decode('utf8')))if__name__=="__main__":
udpClient=UdpClient()
udpClient.sendmsg()

⑥ Python 之 Socket編程(TCP/UDP)

socket(family,type[,protocal]) 使用給定的地址族、套接字類型、協議編號（默認為0）來創建套接字。

有效的埠號： 0～ 65535
但是小於1024的埠號基本上都預留給了操作系統
POSIX兼容系統(如Linux、Mac OS X等)，在/etc/services文件中找到這些預留埠與的列表

面向連接的通信提供序列化、可靠的和不重復的數據交付，而沒有記錄邊界。意味著每條消息都可以拆分多個片段，並且每個消息片段都能到達目的地，然後將它們按順序組合在一起,最後將完整的信息傳遞給等待的應用程序。
實現方式(TCP)：
傳輸控制協議（TCP）， 創建TCP必須使用SOCK_STREAM作為套接字類型
因為這些套接字（AF_INET）的網路版本使用網際網路協議(IP)來搜尋網路中的IP,
所以整個系統通常結合這兩種協議(TCP/IP)來進行網路間數據通信。

數據報類型的套接字, 即在通信開始之前並不需要建議連接,當然也無法保證它的順序性、可靠性或重復性
實現方式(UDP)
用戶數據包協議（UDP), 創建UDP必須使用SOCK_DGRAM (datagram)作為套接字類型
它也使用網際網路來尋找網路中主機，所以是UDP和IP的組合名字UDP/IP

注意點:
1）TCP發送數據時，已建立好TCP連接，所以不需要指定地址。UDP是面向無連接的，每次發送要指定是發給誰。
2）服務端與客戶端不能直接發送列表，元組，字典。需要字元串化repr(data)。

TCP的優點： 可靠，穩定 TCP的可靠體現在TCP在傳遞數據之前，會有三次握手來建立連接，而且在數據傳遞時，有確認、窗口、重傳、擁塞控制機制，在數據傳完後，還會斷開連接用來節約系統資源。

TCP的缺點： 慢，效率低，佔用系統資源高，易被攻擊 TCP在傳遞數據之前，要先建連接，這會消耗時間，而且在數據傳遞時，確認機制、重傳機制、擁塞控制機制等都會消耗大量的時間，而且要在每台設備上維護所有的傳輸連接，事實上，每個連接都會佔用系統的CPU、內存等硬體資源。 而且，因為TCP有確認機制、三次握手機制，這些也導致TCP容易被人利用，實現DOS、DDOS、CC等攻擊。

什麼時候應該使用TCP : 當對網路通訊質量有要求的時候，比如：整個數據要准確無誤的傳遞給對方，這往往用於一些要求可靠的應用，比如HTTP、HTTPS、FTP等傳輸文件的協議，POP、SMTP等郵件傳輸的協議。 在日常生活中，常見使用TCP協議的應用如下： 瀏覽器，用的HTTP FlashFXP，用的FTP Outlook，用的POP、SMTP Putty，用的Telnet、SSH QQ文件傳輸.

UDP的優點： 快，比TCP稍安全 UDP沒有TCP的握手、確認、窗口、重傳、擁塞控制等機制，UDP是一個無狀態的傳輸協議，所以它在傳遞數據時非常快。沒有TCP的這些機制，UDP較TCP被攻擊者利用的漏洞就要少一些。但UDP也是無法避免攻擊的，比如：UDP Flood攻擊……

UDP的缺點： 不可靠，不穩定 因為UDP沒有TCP那些可靠的機制，在數據傳遞時，如果網路質量不好，就會很容易丟包。

什麼時候應該使用UDP： 當對網路通訊質量要求不高的時候，要求網路通訊速度能盡量的快，這時就可以使用UDP。 比如，日常生活中，常見使用UDP協議的應用如下： QQ語音 QQ視頻 TFTP ……

⑦ python3套接字udp設置接受數據超時

Sometimes，you need to manipulate the default values of certain properties of a socket library, for example, the socket timeout.

設定並獲取默認的套接字超時時間。

1.代碼

1 import socket
2
3
4 def test_socket_timeout():
5 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
6 print("Default socket timeout: %s" % s.gettimeout())
7 # 獲取套接字默認超時時間
8 s.settimeout(100)
9 # 設置超時時間
10 print("Current socket timeout: %s" % s.gettimeout())
11 # 讀取修改後的套接字超時時間
12
13
14 if __name__ == '__main__':
15 test_socket_timeout()
2. AF_INET和SOCK_STREAM解釋

1 # 地址簇
2 # socket.AF_INET IPv4(默認)
3 # socket.AF_INET6 IPv6
4 # socket.AF_UNIX 只能夠用於單一的Unix系統進程間通信
5
6 # socket.SOCK_STREAM(數據流) 提供面向連接的穩定數據傳輸，即TCP/IP協議.多用於資料（如文件）傳送。
3.gettimeout()和settimeout()解釋

1 def gettimeout(self): # real signature unknown; restored from __doc__
2 """
3 gettimeout() -> timeout
4
5 Returns the timeout in seconds (float) associated with socket
6 operations. A timeout of None indicates that timeouts on socket
7 operations are disabled.
8 """
9 return timeout
10
11
12 def settimeout(self, timeout): # real signature unknown; restored from __doc__
13 """
14 settimeout(timeout)
15
16 Set a timeout on socket operations. 'timeout' can be a float,
17 giving in seconds, or None. Setting a timeout of None disables
18 the timeout feature and is equivalent to setblocking(1).
19 Setting a timeout of zero is the same as setblocking(0).
20 """
21 pass
22 # 設置套接字操作的超時期，timeout是一個浮點數，單位是秒。值為None表示沒有超時期。
23 # 一般，超時期應該在剛創建套接字時設置，因為它們可能用於連接的操作（如 client 連接最多等待5s ）
4.運行結果

1 Default socket timeout: None
2 Current socket timeout: 100.0