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()

運(yùn)行結(jié)果：

server

[work@db-testing-com06-vm3.db01.baidu.com 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

[work@db-testing-com06-vm3.db01.baidu.com python]$ python udp_cc.py
aaaaaa
123456
abcdef

[work@db-testing-com06-vm3.db01.baidu.com python]$

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

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

前言

python實(shí)在是太方便，太易用了，三方庫(kù)的支持又全，語(yǔ)法又簡(jiǎn)單，對(duì)開(kāi)發(fā)人員來(lái)說(shuō)，實(shí)在是居家旅行，XXXX的必備利器。周末研究了下python的網(wǎng)絡(luò)支持，做一下記錄，以備隨后翻閱。

python支持BSD的socket進(jìn)行網(wǎng)絡(luò)編程，其API跟C中的大同小異，先看看TCP方式的，說(shuō)到網(wǎng)絡(luò)編程，肯定會(huì)設(shè)計(jì)到server和client，分別來(lái)看下

TCP方式

server端

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

1. 建立一個(gè)socket(可以選擇socket類型INET,UNIX等，以及連接方式TCP/UDP)
2. 使用bind公開(kāi)一個(gè)端口，使得client可以方便連接
3. 設(shè)置一個(gè)listen隊(duì)列的大小
4. 進(jìn)入一個(gè)無(wú)限循環(huán)，在此無(wú)限循環(huán)中，使用accept函數(shù)來(lái)等待客戶連接，此函數(shù)返回一個(gè)新的socket, 對(duì)應(yīng)于客戶端的socket，建立通信信道。對(duì)socket的處理一般放在外部單獨(dú)的函數(shù)中(并發(fā))
5. 通過(guò)send()/recv()來(lái)對(duì)socket進(jìn)行讀寫(xiě)操作

好了，下面看一下例子：

Python代碼

1. def tcpServer():
2. srvsock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
3. srvsock.bind(( '' , 9527 ))
4. srvsock.listen( 5 )
6. while True :
7. clisock,(remoteHost,remotePort)=srvsock.accept()
8. print "[%s:%s]connected" %(remoteHost,remotePort)
9. #dosomethingontheclisock
10. clisock.close()
13. if __name__== "__main__" :
14. 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. 建立一個(gè)新的socket
2. 使用connect函數(shù)與遠(yuǎn)程主機(jī)獲得連接
3. 在此socket上進(jìn)行I/O操作

Python代碼

1. def tcpClient():
2. clisock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
3. clisock.connect(( 'localhost' , 9527 ))
5. #I/Oonthisclisock
6. #clisock.send("")
7. #dat=clisock.recv(len)
9. print dat
11. if __name__== "__main__" :
12. 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()
  

由代碼量可見(jiàn)python之簡(jiǎn)單，想要將這個(gè)例子改造成一個(gè)文件傳輸器，估計(jì)只需要增加不到20行代碼即可。

UDP方式

UDP號(hào)稱無(wú)連接傳輸，全然沒(méi)有TCP那么復(fù)雜，三次握手，錯(cuò)誤重傳之類的機(jī)制都沒(méi)有，發(fā)的只管發(fā)，收得只管收，收到?jīng)]有？不知道，順序不對(duì)怎么辦？不管！就是這樣，但是速度就要比TCP高得多了。在對(duì)數(shù)據(jù)幀要求不是很高的地方，這確實(shí)是很好用的，比如網(wǎng)絡(luò)上的視頻傳輸，音頻傳輸?shù)取?

server端

1. 建立數(shù)據(jù)報(bào)形式的socket
2. 公開(kāi)一個(gè)端口，一邊客戶端連接
3. 開(kāi)始接收數(shù)據(jù)

Python代碼

1. def udpServer():
2. address=( '' , 9527 )
3. srvsock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
4. srvsock.bind(address)
5. #data,addr=srvsock.recvfrom(2048)
7. if __name__== "__main__" :
8. 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元組中的引號(hào)表示可以接受任何地址來(lái)的數(shù)據(jù)報(bào)，TCP例子中的則表示可以接受任意地址發(fā)起的連接。

client端

1. 新建一個(gè)數(shù)據(jù)報(bào)socket
2. 收發(fā)數(shù)據(jù)

Python代碼

1. def udpClient():
2. address=( 'localhost' , 9527 )
3. clisock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
4. #clisock.sendto(data,address)
6. if __name__== "__main__" :
7. udpClient()

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

文中給出的例子已經(jīng)具有網(wǎng)絡(luò)程序的基本結(jié)構(gòu)，在實(shí)際應(yīng)用中，應(yīng)該自行擴(kuò)展對(duì)socket的處理，socket說(shuō)到底跟文件句柄，文件描述符，管道描述符等都是一個(gè)概念，可以對(duì)其進(jìn)行I/O處理，事實(shí)上，在UNIX類系統(tǒng)中，對(duì)socket的操作跟對(duì)文件句柄的操作沒(méi)有任何形式上的差異。

python實(shí)現(xiàn)socket通訊(UDP)