PythonUdpSocket

2019-11-14 17:17:18

字體：大中小

供稿：網(wǎng)友

socket（套接字），傳輸層通信的端點(diǎn)，由ip和端口號(hào)組成（IP,Port），可以通過(guò)socket精確地找到服務(wù)器上的進(jìn)程并與之通信

python2.6實(shí)現(xiàn)，基于AF_INET（網(wǎng)絡(luò)套接字）
類型SOCKET_STREAM（TCP套接字），SOCKET_DGRAM（UDP套接字）

UDP socket實(shí)現(xiàn)較TCP要簡(jiǎn)單，沒(méi)有建立連接的過(guò)程，服務(wù)端無(wú)限循環(huán)接收數(shù)據(jù)，處理數(shù)據(jù)返回，客戶端也無(wú)需建立通信連接，
直接發(fā)送數(shù)據(jù)接收數(shù)據(jù)即可

UDP socket通信邏輯
UDP服務(wù)端：創(chuàng)建socket>>>綁定本地服務(wù)器>>>無(wú)限循環(huán)>>>接收信息返回信息
UDP客戶端：創(chuàng)建socket>>>發(fā)送信息接收信息

Python Udp Socket服務(wù)端

 1     #!/usr/bin/python 2     #-*-coding utf-8-*- 3  4     # filename : Udpsocket.py 5     # author : 6     # create date : 2015-03-25 7     # modify date : 8     # description : udp socket 9 10     #import stander lib11     from socket import socket, AF_INET, SOCK_DGRAM12     import sys13     sys.path.append( '..' )14 15 16     class Udpsocket():17         '''18         Udpsocket類，建立udp socket服務(wù)端19         用法：20             p = Udpsocket.Udpsocket()21             p.listen()22             無(wú)限循環(huán)監(jiān)聽(tīng)端口，PRocess重寫(xiě)數(shù)據(jù)處理方式23         '''24         25         def __init__( self ):26             '''27             初始化，建立socket，ip端口綁定28             '''29             self.udpServerSocket = socket( AF_INET, SOCK_DGRAM )30             self.udpServerSocket.bind( ('127.0.0.1', 20015) )31             self.buffer_size = 1024 #緩沖區(qū)為1k32             33             34         def receive( self ):35             '''36             收取端口傳來(lái)的數(shù)據(jù)37             '''38             raw_data, addr = self.udpServerSocket.recvfrom( int(self.buffer_size) )39             print 'conn from : ', addr40             print 'receive from udp client : ', raw_data41             42             return ( raw_data, addr )43             44 45         def process( self, data ):46             '''47             socket傳輸?shù)臄?shù)據(jù)加工處理，繼承重寫(xiě)該函數(shù)48             '''49             result = data50             return result51 52         53         def send( self, addr, result ):54             '''55             返回信息56             '''57             self.udpServerSocket.sendto( result, addr )58             59         60         def listen( self ):61             '''62             監(jiān)聽(tīng)端口，無(wú)限循環(huán)63             '''64             while True:65                 print 'wait for connect'66                 socket_data = self.receive()             #接收數(shù)據(jù)67                 result = self.process( socket_data[0] )  #處理接收的信息68                 self.send( socket_data[1], str(result) ) #返回?cái)?shù)據(jù)69             self.close()70         71         72         def close( self ):73             '''74             關(guān)閉連接75             '''76             self.udpServerSocket.close()77 78             79         def __del__( self ):80             self.close()81             82 83     if __name__ == '__main__':84         p = Udpsocket()85         p.listen()

Python Udp Socket客戶端

 1     #!/usr/bin/env python 2     #-*-coding:utf-8-*- 3  4     from socket import * 5  6     HOST = '127.0.0.1'       #主機(jī) 7     PORT = 20015             #端口 8     BUFFSIZE = 1024          #緩沖區(qū)大小 9     ADDR = ( HOST, PORT )    #地址10 11     #建立socket監(jiān)聽(tīng)12     udpClientSocket = socket( AF_INET, SOCK_DGRAM )13 14     #傳送接收數(shù)據(jù)15     udpClientSocket.sendto( 'hello', ADDR )16     data, addr = udpClientSocket.recvfrom( BUFFSIZE )17     print 'receive data : ', data18     #data, addr = udpClientSocket.recvfrom( BUFFSIZE )19     udpClientSocket.close()