VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > temp > 简明python教程 >

  • python基础(30):黏包、socket的其他方法

1. 黏包

1.1 黏包现象

让我们基于tcp先制作一个远程执行命令的程序（命令ls -l ; lllllll ; pwd）

同时执行多条命令之后，得到的结果很可能只有一部分，在执行其他命令的时候又接收到之前执行的另外一部分结果，这种显现就是黏包。

1.1.1 基于TCP协议实现的黏包

server：


	
    
		
  1. 
			#_*_coding:utf-8_*_
    2. 
		
  2. 
			from socket import *
    3. 
		
  3. 
			import subprocess
    4. 
		
  4. 
			 
    5. 
		
  5. 
			ip_port=('127.0.0.1',8888)
    6. 
		
  6. 
			BUFSIZE=1024
    7. 
		
  7. 
			 
    8. 
		
  8. 
			tcp_socket_server=socket(AF_INET,SOCK_STREAM)
    9. 
		
  9. 
			tcp_socket_server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
    10. 
		
  10. 
			tcp_socket_server.bind(ip_port)
    11. 
		
  11. 
			tcp_socket_server.listen(5)
    12. 
		
  12. 
			 
    13. 
		
  13. 
			while True:
    14. 
		
  14. 
			conn,addr=tcp_socket_server.accept()
    15. 
		
  15. 
			print('客户端',addr)
    16. 
		
  16. 
			 
    17. 
		
  17. 
			while True:
    18. 
		
  18. 
			cmd=conn.recv(BUFSIZE)
    19. 
		
  19. 
			if len(cmd) == 0:break
    20. 
		
  20. 
			 
    21. 
		
  21. 
			res=subprocess.Popen(cmd.decode('utf-8'),shell=True,
    22. 
		
  22. 
			stdout=subprocess.PIPE,
    23. 
		
  23. 
			stdin=subprocess.PIPE,
    24. 
		
  24. 
			stderr=subprocess.PIPE)
    25. 
		
  25. 
			 
    26. 
		
  26. 
			stderr=res.stderr.read()
    27. 
		
  27. 
			stdout=res.stdout.read()
    28. 
		
  28. 
			conn.send(stderr)
    29. 
		
  29. 
			conn.send(stdout)
    30. 
	





	client：



	

	
    
		
  1. 
			#_*_coding:utf-8_*_
    2. 
		
  2. 
			import socket
    3. 
		
  3. 
			BUFSIZE=1024
    4. 
		
  4. 
			ip_port=('127.0.0.1',8888)
    5. 
		
  5. 
			 
    6. 
		
  6. 
			s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    7. 
		
  7. 
			res=s.connect_ex(ip_port)
    8. 
		
  8. 
			 
    9. 
		
  9. 
			while True:
    10. 
		
  10. 
			msg=input('>>: ').strip()
    11. 
		
  11. 
			if len(msg) == 0:continue
    12. 
		
  12. 
			if msg == 'quit':break
    13. 
		
  13. 
			 
    14. 
		
  14. 
			s.send(msg.encode('utf-8'))
    15. 
		
  15. 
			act_res=s.recv(BUFSIZE)
    16. 
		
  16. 
			 
    17. 
		
  17. 
			print(act_res.decode('utf-8'),end='')
    18. 
	





	



	1.1.2 基于UDP协议实现的黏包



	server：



	

	
    
		
  1. 
			#_*_coding:utf-8_*_
    2. 
		
  2. 
			from socket import *
    3. 
		
  3. 
			import subprocess
    4. 
		
  4. 
			 
    5. 
		
  5. 
			ip_port=('127.0.0.1',9000)
    6. 
		
  6. 
			bufsize=1024
    7. 
		
  7. 
			 
    8. 
		
  8. 
			udp_server=socket(AF_INET,SOCK_DGRAM)
    9. 
		
  9. 
			udp_server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
    10. 
		
  10. 
			udp_server.bind(ip_port)
    11. 
		
  11. 
			 
    12. 
		
  12. 
			while True:
    13. 
		
  13. 
			#收消息
    14. 
		
  14. 
			cmd,addr=udp_server.recvfrom(bufsize)
    15. 
		
  15. 
			print('用户命令----->',cmd)
    16. 
		
  16. 
			 
    17. 
		
  17. 
			#逻辑处理
    18. 
		
  18. 
			res=subprocess.Popen(cmd.decode('utf-8'),shell=True,stderr=subprocess.PIPE,stdin=subprocess.PIPE,stdout=subprocess.PIPE)
    19. 
		
  19. 
			stderr=res.stderr.read()
    20. 
		
  20. 
			stdout=res.stdout.read()
    21. 
		
  21. 
			 
    22. 
		
  22. 
			#发消息
    23. 
		
  23. 
			udp_server.sendto(stderr,addr)
    24. 
		
  24. 
			udp_server.sendto(stdout,addr) 
    25. 
		
  25. 
			udp_server.close()
    26. 
	





	client：



	

	
    
		
  1. 
			from socket import *
    2. 
		
  2. 
			ip_port=('127.0.0.1',9000)
    3. 
		
  3. 
			bufsize=1024
    4. 
		
  4. 
			 
    5. 
		
  5. 
			udp_client=socket(AF_INET,SOCK_DGRAM)
    6. 
		
  6. 
			 
    7. 
		
  7. 
			 
    8. 
		
  8. 
			while True:
    9. 
		
  9. 
			msg=input('
      



  

  
  

   
  

  
 
 

 
 
  
 
 
 
 






 






相关教程