python實現socket通訊(UDP)

 

Server：

import socket address = ('127.0.0.1', 31500) s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) s.bind(address) while True: data, addr = s.recvfrom(2048) if not data: print "client has exist" break print "received:", data, "from", addr s.close()   

Client：

import socket address = ('127.0.0.1', 31500) s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) while True: msg = raw_input() if not msg: break s.sendto(msg, address) s.close()   

 

運行結果：

 

server

[[e-mail] python]$ python udp_ss.py
received: aaaaaa from ('127.0.0.1', 10169)
received: 123456 from ('127.0.0.1', 10169)
received: abcdef from ('127.0.0.1', 10169)

 

 

client

[[e-mail] python]$ python udp_cc.py
aaaaaa
123456
abcdef

[[e-mail] python]$

 

===============================================================================

 

參考：http://www.javaeye.com/topic/401391

前言

python實在是太方便，太易用了，三方庫的支持又全，語法又簡單，對開發人員來說，實在是居家旅行，XXXX的必備利器。周末研究了下python的網絡支持，做一下記錄，以備隨后翻閱。

 

python支持BSD的socket進行網絡編程，其API跟C中的大同小異，先看看TCP方式的，說到網絡編程，肯定會設計到server和client，分別來看下

TCP方式

server端

server端的socket一般流程是這樣：

1. 建立一個socket(可以選擇socket類型INET,UNIX等，以及連接方式TCP/UDP)
2. 使用bind公開一個端口，使得client可以方便連接
3. 設置一個listen隊列的大小
4. 進入一個無限循環，在此無限循環中，使用accept函數來等待客戶連接，此函數返回一個新的socket, 對應於客戶端的socket，建立通信信道。對socket的處理一般放在外部單獨的函數中(並發)
5. 通過send()/recv()來對socket進行讀寫操作

好了，下面看一下例子：

def tcpServer():
    srvsock = socket.socket( socket.AF_INET, socket.SOCK_STREAM)
    srvsock.bind(('', 9527))
    srvsock.listen(5)

    while True:
        clisock, (remoteHost, remotePort) = srvsock.accept()
        print "[%s:%s] connected" % (remoteHost, remotePort)
        #do something on the clisock
        clisock.close()


if __name__ == "__main__":
    tcpServer()

def tcpServer():
    srvsock = socket.socket( socket.AF_INET, socket.SOCK_STREAM)
    srvsock.bind(('', 9527))
    srvsock.listen(5)

    while True:
        clisock, (remoteHost, remotePort) = srvsock.accept()
        print "[%s:%s] connected" % (remoteHost, remotePort)
        #do something on the clisock
        clisock.close()


if __name__ == "__main__":
    tcpServer()

 

client端

1. 建立一個新的socket
2. 使用connect函數與遠程主機獲得連接
3. 在此socket上進行I/O操作

def tcpClient():
    clisock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    clisock.connect(('localhost', 9527))

    #I/O on this clisock
    #clisock.send("")
    #dat = clisock.recv(len)

    print dat

if __name__ == "__main__":
    tcpClient()

def tcpClient():
    clisock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    clisock.connect(('localhost', 9527))
    
    #I/O on this clisock
    #clisock.send("")
    #dat = clisock.recv(len)
    
    print dat
    
if __name__ == "__main__":
    tcpClient()

 由代碼量可見python之簡單，想要將這個例子改造成一個文件傳輸器，估計只需要增加不到20行代碼即可。

UDP方式

UDP號稱無連接傳輸，全然沒有TCP那么復雜，三次握手，錯誤重傳之類的機制都沒有，發的只管發，收得只管收，收到沒有？不知道，順序不對怎么辦？不管！就是這樣，但是速度就要比TCP高得多了。在對數據幀要求不是很高的地方，這確實是很好用的，比如網絡上的視頻傳輸，音頻傳輸等。

server端

1. 建立數據報形式的socket
2. 公開一個端口，一邊客戶端連接
3. 開始接收數據

def udpServer():
    address = ('', 9527)
    srvsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    srvsock.bind(address)
    #data,addr = srvsock.recvfrom(2048)

if __name__ == "__main__":
    udpServer()

def udpServer():
    address = ('', 9527)
    srvsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    srvsock.bind(address)
    #data,addr = srvsock.recvfrom(2048)

if __name__ == "__main__":
    udpServer()

 需要注意的是，server中address元組中的引號表示可以接受任何地址來的數據報，TCP例子中的則表示可以接受任意地址發起的連接。

client端

1. 新建一個數據報socket
2. 收發數據

def udpClient():
    address = ('localhost', 9527)
    clisock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    #clisock.sendto(data, address)

if __name__ == "__main__":
    udpClient()

def udpClient():
    address = ('localhost', 9527)
    clisock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    #clisock.sendto(data, address)
    
if __name__ == "__main__":
    udpClient()

 文中給出的例子已經具有網絡程序的基本結構，在實際應用中，應該自行擴展對socket的處理，socket說到底跟文件句柄，文件描述符，管道描述符等都是一個概念，可以對其進行I/O處理，事實上，在UNIX類系統中，對socket的操作跟對文件句柄的操作沒有任何形式上的差異。