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
















相关教程