python实现socket通讯(UDP)

marty001

　　
　　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
　　[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实在是太方便，太易用了，三方库的支持又全，语法又简单，对开发人员来说，实在是居家旅行，XXXX的必备利器。周末研究了下python的网络支持，做一下记录，以备随后翻阅。
　　
　　python支持BSD的socket进行网络编程，其API跟C中的大同小异，先看看TCP方式的，说到网络编程，肯定会设计到server和client，分别来看下

TCP方式

server端
　　server端的socket一般流程是这样：

• 建立一个socket(可以选择socket类型INET,UNIX等，以及连接方式TCP/UDP)
  
• 使用bind公开一个端口，使得client可以方便连接
  
• 设置一个listen队列的大小
  
• 进入一个无限循环，在此无限循环中，使用accept函数来等待客户连接，此函数返回一个新的socket, 对应于客户端的socket，建立通信信道。对socket的处理一般放在外部单独的函数中(并发)
  
• 通过send()/recv()来对socket进行读写操作
  

　　好了，下面看一下例子：






Python代码

• 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端

• 建立一个新的socket
  
• 使用connect函数与远程主机获得连接
  
• 在此socket上进行I/O操作
  

Python代码

• 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端

• 建立数据报形式的socket
  
• 公开一个端口，一边客户端连接
  
• 开始接收数据
  

Python代码

• 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端

• 新建一个数据报socket
  
• 收发数据
  

Python代码

• 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的操作跟对文件句柄的操作没有任何形式上的差异。