Python Udp Socket

socket（套接字），傳輸層通信的端點，由IP和端口號組成（IP,Port），可以通過socket精確地找到服務器上的進程並與之通信

python2.6實現，基於AF_INET（網絡套接字）
類型SOCKET_STREAM（TCP套接字），SOCKET_DGRAM（UDP套接字）

UDP socket實現較TCP要簡單，沒有建立連接的過程，服務端無限循環接收數據，處理數據返回，客戶端也無需建立通信連接，
直接發送數據接收數據即可

UDP socket通信邏輯
UDP服務端：創建socket>>>綁定本地服務器>>>無限循環>>>接收信息返回信息
UDP客戶端：創建socket>>>發送信息接收信息

 

Python Udp Socket服務端

    #!/usr/bin/python
    #-*-coding utf-8-*-

    # filename : Udpsocket.py
    # author :
    # create date : 2015-03-25
    # modify date :
    # description : udp socket

    #import stander lib
    from socket import socket, AF_INET, SOCK_DGRAM
    import sys
    sys.path.append( '..' )


    class Udpsocket():
        '''
        Udpsocket類，建立udp socket服務端
        用法：
            p = Udpsocket.Udpsocket()
            p.listen()
            無限循環監聽端口，process重寫數據處理方式
        '''
        
        def __init__( self ):
            '''
            初始化，建立socket，ip端口綁定
            '''
            self.udpServerSocket = socket( AF_INET, SOCK_DGRAM )
            self.udpServerSocket.bind( ('127.0.0.1', 20015) )
            self.buffer_size = 1024 #緩沖區為1k
            
            
        def receive( self ):
            '''
            收取端口傳來的數據
            '''
            raw_data, addr = self.udpServerSocket.recvfrom( int(self.buffer_size) )
            print 'conn from : ', addr
            print 'receive from udp client : ', raw_data
            
            return ( raw_data, addr )
            

        def process( self, data ):
            '''
            socket傳輸的數據加工處理，繼承重寫該函數
            '''
            result = data
            return result

        
        def send( self, addr, result ):
            '''
            返回信息
            '''
            self.udpServerSocket.sendto( result, addr )
            
        
        def listen( self ):
            '''
            監聽端口，無限循環
            '''
            while True:
                print 'wait for connect'
                socket_data = self.receive()             #接收數據
                result = self.process( socket_data[0] )  #處理接收的信息
                self.send( socket_data[1], str(result) ) #返回數據
            self.close()
        
        
        def close( self ):
            '''
            關閉連接
            '''
            self.udpServerSocket.close()

            
        def __del__( self ):
            self.close()
            

    if __name__ == '__main__':
        p = Udpsocket()
        p.listen()

Python Udp Socket客戶端

    #!/usr/bin/env python
    #-*-coding:utf-8-*-

    from socket import *

    HOST = '127.0.0.1'       #主機
    PORT = 20015             #端口
    BUFFSIZE = 1024          #緩沖區大小
    ADDR = ( HOST, PORT )    #地址

    #建立socket監聽
    udpClientSocket = socket( AF_INET, SOCK_DGRAM )

    #傳送接收數據
    udpClientSocket.sendto( 'hello', ADDR )
    data, addr = udpClientSocket.recvfrom( BUFFSIZE )
    print 'receive data : ', data
    #data, addr = udpClientSocket.recvfrom( BUFFSIZE )
    udpClientSocket.close()