十三.网络编程

Posted 2021-02-15 i201102053

1.socket套接字的原理和应用

• 简单的server1和client1

  #服务器与客户端建立方式不同
  #网络连接的主要操作就是接受recv和发送send，python3里网络传输只能用byte
  #recv(128)表示一次传输的最大容量，如果传输的内容过大，需要多次recv(128)才可以接受完。即使过大，每次不一定按照128进行最大传输
  import socket
  s=socket.socket() #建立一个套接字网络单位
  #网络连接的host名称和端口需要一致才可以
  host=socket.gethostname()
  port=1234
  s.bind((host,port)) #bind绑定，说明这是服务器
  #最多监听的客户端数量
  s.listen(5)
  while True:
      #一个网络单位(服务器)可以有多个客户端连接
      c,addr=s.accept() #这是客户端连接时才执行，返回连接和地址
      data = c.recv(1024)  #服务器连接后接受到的客户端内容
      print("server get data:",data)
      print("Got connection from",addr)
      #服务器两次发送信息，客户端也需要两次接受
      c.send("Thank you for connecting".encode()) #str需要转成比特
      c.send(data) #发送接受到的信息，原本就是byte
      c.close()
  #---------------------------------------------------------------------------------
  import socket
  s=socket.socket() #建立一个套接字网络单位
  # host=socket.gethostname()
  # port=1234
  host=socket.gethostname()
  port=1234
  #s网络单位进行connect连接，说明这是客户端
  s.connect((host,port))
  #向服务器发送信息，需要变成byte
  s.send("This is client".encode())
  #由于客户端发送了两次信息，需要两次接受
  print(s.recv(1024).decode()) #把比特数据转成str
  print(s.recv(1024).decode()) #把比特数据转成str
  print(s.recv(1024).decode()) #把比特数据转成str
  print(s.recv(1024).decode()) #把比特数据转成str

• 简单的server2和client2
  

  import socket ,os,time
  server = socket.socket()
  server.bind((‘localhost‘,9999) )
  server.listen()
  
  while True:
      conn, addr = server.accept()
      print("new conn:",addr)
      while True:
          print("等待新指令")
          # recv(128)表示一次传输的最大容量，如果传输的内容过大，需要多次recv(128)才可以接受完
          data = conn.recv(128)
          if not data:
              print("客户端已断开")
              break
          print("执行指令:",data)
          cmd_res = os.popen(data.decode()).read() #接受字符串，执行结果也是字符串
          print("before send",len(cmd_res))
          if len(cmd_res) ==0:
              cmd_res = "cmd has no output..."
          # 先发内容的byte大小给客户端，用于处理传输内容大于通道时的情况
          conn.send( str(len(cmd_res.encode())).encode("utf-8")    )
          time.sleep(0.5)
          conn.send(cmd_res.encode("utf-8"))
          print("send done")
          # os.path.isfile()
          # os.stat("sock")
  server.close()
  #---------------------------------------------------------------------------------
  import socket
  client = socket.socket()
  #client.connect((‘192.168.16.200‘,9999))
  client.connect((‘localhost‘,9999))
  while True:
      cmd = input(">>:").strip()
      if len(cmd) == 0: continue
      client.send(cmd.encode("utf-8"))
      ##第一次接受内容命令结果的长度，byte数据
      cmd_res_size = client.recv(128)
      print("命令结果大小:",cmd_res_size)
      received_size = 0
      received_data = b‘‘
      TotalSize=int(cmd_res_size.decode()) #byte数据转成整数
      #开始接受内容
      while received_size < TotalSize :
          data = client.recv(128)
          # 每次收到的有可能小于1024，所以必须用len判断，返回的是byte长度
          received_size += len(data)
          print("接受内容的长度：",len(data))
          #print("接受的内容：",data) #分段打印有时候打印不出来，因为分段格式有时不完整
          received_data += data
      else:
          print("cmd res receive done...",received_size)
          print(received_data.decode())
  client.close()

  server2 and client2
• 结合select的服务器
  

  import socket,select
  s=socket.socket()
  host=socket.gethostname()
  port=1234
  s.bind((host,port))
  s.listen(5)
  Inputs=[s]
  while True:
      rs,ws,es=select.select(Inputs,[],[])
      for r in rs:
          if r is s:
              conn,addr=s.accept()
              print("Got Connection From",addr)
              Inputs.append(conn)
      else:
          try:
              data=r.recv(1024)
              disconnected=not data
          except socket.error:
              disconnected=True
          if disconnected:
              print(r.getpeername(),"disconnected")
              Inputs.remove(r)
          else:
              print(data)

  socket and select

2.读取网站

import urllib.request as class_url
#返回一个可以读取的对象
webaddress="http://www.python.org"
webpage=class_url.urlopen(webaddress)
import re
text=webpage.read()
m=re.search(b‘<a href="([^"]+)" .*?>about</a>‘,text,re.IGNORECASE) #正则表达式
print(m.group())
#获取远程文件
class_url.urlretrieve(webaddress,"download.html")
#class_url.urlcleanup() #上面不指定位置才需要用

urllib.request

3.可并发的socketserver服务器

可并发的服务器