python实现socket通讯

时间：2022-02-25 15:34:44

Server：

[python] view plain copy print?
  1. import socket  
  2.   
  3. address = ('127.0.0.1', 31500)  
  4. s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  
  5. s.bind(address)  
  6.   
  7. while True:  
  8.     data, addr = s.recvfrom(2048)  
  9.     if not data:  
  10.         print "client has exist"  
  11.         break  
  12.     print "received:", data, "from", addr  
  13.   
  14. s.close()  
   

Client：

[python] view plain copy print?
  1. import socket  
  2.   
  3. address = ('127.0.0.1', 31500)  
  4. s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  
  5.   
  6. while True:  
  7.     msg = raw_input()  
  8.     if not msg:  
  9.         break  
  10.     s.sendto(msg, address)  
  11.   
  12. s.close()  
   

 运行结果：

server

[work@db-testing 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 python]$ python udp_cc.py 
aaaaaa
123456
abcdef

[work@db-testing 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进行读写操作 

好了，下面看一下例子：

netserver.py

[python] view plain copy print?python实现socket通讯python实现socket通讯
  1. #!/usr/bin/env python  
  2. # -*- coding:utf8 -*-  
  3.   
  4. import sys  
  5. reload(sys)  
  6. sys.setdefaultencoding('utf-8')  
  7.   
  8. import socket  
  9.   
  10. class NetServer(object):  
  11.     def tcpServer(self):  
  12.         sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  
  13.         sock.bind(('', 9527))       # 绑定同一个域名下的所有机器  
  14.         sock.listen(5)  
  15.           
  16.         while True:  
  17.             clientSock, (remoteHost, remotePort) = sock.accept()  
  18.             print("[%s:%s] connect" % (remoteHost, remotePort))     # 接收客户端的ip, port  
  19.               
  20.             revcData = clientSock.recv(1024)  
  21.             sendDataLen = clientSock.send("this is send  data from server")  
  22.             print "revcData: ", revcData  
  23.             print "sendDataLen: ", sendDataLen  
  24.               
  25.             clientSock.close()  
  26.               
  27. if __name__ == "__main__":  
  28.     netServer = NetServer()  
  29.     netServer.tcpServer()  


client端

  1. 建立一个新的socket 
  2. 使用connect函数与远程主机获得连接 
  3. 在此socket上进行I/O操作
netclient.py [python] view plain copy print?python实现socket通讯python实现socket通讯
  1. #!/usr/bin/env python  
  2. # -*- coding:utf8 -*-  
  3.   
  4. import sys  
  5. reload(sys)  
  6. sys.setdefaultencoding('utf-8')  
  7.   
  8. import socket  
  9.   
  10. class NetClient(object):  
  11.     def tcpclient(self):  
  12.         clientSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  
  13.         clientSock.connect(('localhost', 9527))  
  14.   
  15.         sendDataLen = clientSock.send("this is send data from client")  
  16.         recvData = clientSock.recv(1024)  
  17.         print "sendDataLen: ", sendDataLen  
  18.         print "recvData: ", recvData  
  19.           
  20.         clientSock.close()  
  21.           
  22. if __name__ == "__main__":  
  23.     netClient = NetClient()  
  24.     netClient.tcpclient()  

运行结果： 1） 先启动 netserver.py， 然后启动 netclient.py，注意client先发送后接收，server是先接收后发送，顺序要交错 2） server 打印结果： [127.0.0.1:55279] connect
revcData:  this is send data from client
sendDataLen:  30
3） client 打印结果： sendDataLen:  29
recvData:  this is send  data from server

由代码量可见python之简单，想要将这个例子改造成一个文件传输器，估计只需要增加不到20行代码即可。


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

UDP方式

UDP号称无连接传输，全然没有TCP那么复杂，三次握手，错误重传之类的机制都没有，发的只管发，收得只管收，收到没有？不知道，顺序不对怎么办？不管！就是这样，但是速度就要比TCP高得多了。在对数据帧要求不是很高的地方，这确实是很好用的，比如网络上的视频传输，音频传输等。

server端

  1. 建立数据报形式的socket 
  2. 公开一个端口，一边客户端连接 
  3. 开始接收数据
udpserver.py [python] view plain copy print?python实现socket通讯python实现socket通讯
  1. #!/usr/bin/env python  
  2. # -*- coding:utf8 -*-  
  3.   
  4. import sys  
  5. reload(sys)  
  6. sys.setdefaultencoding('utf-8')  
  7.   
  8. import socket  
  9.   
  10. class UdpServer(object):  
  11.     def tcpServer(self):  
  12.         sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  
  13.         sock.bind(('', 9527))       # 绑定同一个域名下的所有机器  
  14.           
  15.         while True:  
  16.             revcData, (remoteHost, remotePort) = sock.recvfrom(1024)  
  17.             print("[%s:%s] connect" % (remoteHost, remotePort))     # 接收客户端的ip, port  
  18.               
  19.             sendDataLen = sock.sendto("this is send  data from server", (remoteHost, remotePort))  
  20.             print "revcData: ", revcData  
  21.             print "sendDataLen: ", sendDataLen  
  22.               
  23.         sock.close()  
  24.               
  25. if __name__ == "__main__":  
  26.     udpServer = UdpServer()  
  27.     udpServer.tcpServer()  

 需要注意的是，server中address元组中的引号表示可以接受任何地址来的数据报，TCP例子中的则表示可以接受任意地址发起的连接。

client端

  1. 新建一个数据报socket 
  2. 收发数据
udpclient.py [python] view plain copy print?python实现socket通讯python实现socket通讯
  1. #!/usr/bin/env python  
  2. # -*- coding:utf8 -*-  
  3.   
  4. import sys  
  5. reload(sys)  
  6. sys.setdefaultencoding('utf-8')  
  7.   
  8. import socket  
  9.   
  10. class UdpClient(object):  
  11.     def tcpclient(self):  
  12.         clientSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  
  13.   
  14.         sendDataLen = clientSock.sendto("this is send data from client", ('localhost', 9527))  
  15.         recvData = clientSock.recvfrom(1024)  
  16.         print "sendDataLen: ", sendDataLen  
  17.         print "recvData: ", recvData  
  18.           
  19.         clientSock.close()  
  20.           
  21. if __name__ == "__main__":  
  22.     udpClient = UdpClient()  
  23.     udpClient.tcpclient()  
运行结果： 1） 先启动 udpserver.py，然后启动 udpclient.py，并且保证client先发后收，server先收后发 2） server 结果（client 连续发送了三次请求）： [127.0.0.1:37219] connect
revcData:  this is send data from client
sendDataLen:  30
[127.0.0.1:57622] connect
revcData:  this is send data from client
sendDataLen:  30
[127.0.0.1:52290] connect
revcData:  this is send data from client
sendDataLen:  30
3） client 结果： sendDataLen:  29
recvData:  ('this is send  data from server', ('127.0.0.1', 9527))

 文中给出的例子已经具有网络程序的基本结构，在实际应用中，应该自行扩展对socket的处理，socket说到底跟文件句柄，文件描述符，管道描述符等都是一个概念，可以对其进行I/O处理，事实上，在UNIX类系统中，对socket的操作跟对文件句柄的操作没有任何形式上的差异。


==========================================
标签：

相关文章