分析python并發(fā)網(wǎng)絡(luò)通信模型

from socket import *
import os
import signal

# 創(chuàng)建監(jiān)聽套接字
HOST = '0.0.0.0'
PORT = 8888
ADDR = (HOST,PORT)

# 客戶端服務(wù)函數(shù)
def handle(c):
  while True:
    data = c.recv(1024)
    if not data:
      break
    print(data.decode())
    c.send(b'OK')
  c.close()

s = socket()  # tcp套接字
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)   # 設(shè)置套接字端口重用
s.bind(ADDR)
s.listen(3)

signal.signal(signal.SIGCHLD,signal.SIG_IGN)    # 處理僵尸進(jìn)程

print("Listen the port %d..." % PORT)

# 循環(huán)等待客戶端連接
while True:
  try:
    c,addr = s.accept()
  except KeyboardInterrupt:
    os._exit(0)
  except Exception as e:
    print(e)
    continue

  # 創(chuàng)建子進(jìn)程處理這個(gè)客戶端
  pid = os.fork()
  if pid == 0:  # 處理客戶端請(qǐng)求
    s.close()
    handle(c)
    os._exit(0)  # handle處理完客戶端請(qǐng)求子進(jìn)程也退出

  # 無論出錯(cuò)或者父進(jìn)程都要循環(huán)回去接受請(qǐng)求
  # c對(duì)于父進(jìn)程沒用
  c.close()

from socket import *
from threading import Thread
import sys

# 創(chuàng)建監(jiān)聽套接字
HOST = '0.0.0.0'
PORT = 8888
ADDR = (HOST,PORT)

# 處理客戶端請(qǐng)求
def handle(c):
  while True:
    data = c.recv(1024)
    if not data:
      break
    print(data.decode())
    c.send(b'OK')
  c.close()

s = socket()  # tcp套接字
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
s.bind(ADDR)
s.listen(3)

print("Listen the port %d..."%PORT)
# 循環(huán)等待客戶端連接
while True:
  try:
    c,addr = s.accept()
  except KeyboardInterrupt:
    sys.exit("服務(wù)器退出")
  except Exception as e:
    print(e)
    continue

  # 創(chuàng)建線程處理客戶端請(qǐng)求
  t = Thread(target=handle, args=(c,))
  t.setDaemon(True)   # 父進(jìn)程結(jié)束則所有進(jìn)程終止
  t.start()

from socket import *
from threading import Thread
import os
import time

#　全局變量
HOST = '0.0.0.0'
PORT = 8080
ADDR = (HOST,PORT)
FTP = "/home/tarena/FTP/"  #　文件庫位置

# 創(chuàng)建文件服務(wù)器服務(wù)端功能類
class FTPServer(Thread):
  def __init__(self,connfd):
    self.connfd = connfd
    super().__init__()

  def do_list(self):
    #　獲取文件列表
    files = os.listdir(FTP)
    if not files:
      self.connfd.send("文件庫為空".encode())
      return
    else:
      self.connfd.send(b'OK')
      time.sleep(0.1)  #　防止和后面發(fā)送內(nèi)容粘包

    #　拼接文件列表
    files_ = ""
    for file in files:
      if file[0] != '.' and \

              os.path.isfile(FTP+file):
        files_ += file + '\n'
    self.connfd.send(files_.encode())

  def do_get(self,filename):
    try:
      fd = open(FTP+filename,'rb')
    except Exception:
      self.connfd.send("文件不存在".encode())
      return
    else:
      self.connfd.send(b'OK')
      time.sleep(0.1)
    #　文件發(fā)送
    while True:
      data = fd.read(1024)
      if not data:
        time.sleep(0.1)
        self.connfd.send(b'##')
        break
      self.connfd.send(data)

  #　循環(huán)接收客戶端請(qǐng)求
  def run(self):
    while True:
      data = self.connfd.recv(1024).decode()
      if not data or data == 'Q':
        return 
      elif data == 'L':
        self.do_list()
      elif data[0] == 'G':   # G filename
        filename = data.split(' ')[-1]
        self.do_get(filename)

# 網(wǎng)絡(luò)搭建
def main():
  # 創(chuàng)建套接字
  sockfd = socket()
  sockfd.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
  sockfd.bind(ADDR)
  sockfd.listen(3)
  print("Listen the port %d..."%PORT)
  while True:
    try:
      connfd,addr = sockfd.accept()
      print("Connect from",addr)
    except KeyboardInterrupt:
      print("服務(wù)器程序退出")
      return
    except Exception as e:
      print(e)
      continue

    #　創(chuàng)建新的線程處理客戶端
    client = FTPServer(connfd)
    client.setDaemon(True)
    client.start()   #　運(yùn)行ｒｕｎ方法


if __name__ == "__main__":
  main()

from socket import *
import sys

ADDR = ('127.0.0.1',8080) # 服務(wù)器地址

#　客戶端功能處理類
class FTPClient:
  def __init__(self,sockfd):
    self.sockfd = sockfd

  def do_list(self):
    self.sockfd.send(b'L')  #　發(fā)送請(qǐng)求
    # 等待回復(fù)
    data = self.sockfd.recv(128).decode()
    if data == 'OK':
      #　一次接收文件列表字符串
      data = self.sockfd.recv(4096)
      print(data.decode())
    else:
      print(data)

  def do_get(self,filename):
    #　發(fā)送請(qǐng)求
    self.sockfd.send(('G '+filename).encode())
    # 等待回復(fù)
    data = self.sockfd.recv(128).decode()
    if data == 'OK':
      fd = open(filename,'wb')
      #　接收文件
      while True:
        data = self.sockfd.recv(1024)
        if data == b'##':
          break
        fd.write(data)
      fd.close()
    else:
      print(data)

  def do_quit(self):
    self.sockfd.send(b'Q')
    self.sockfd.close()
    sys.exit("謝謝使用")

#　創(chuàng)建客戶端網(wǎng)絡(luò)
def main():
  sockfd = socket()
  try:
    sockfd.connect(ADDR)
  except Exception as e:
    print(e)
    return

  ftp = FTPClient(sockfd) #　實(shí)例化對(duì)象

  #　循環(huán)發(fā)送請(qǐng)求
  while True:
    print("\n=========命令選項(xiàng)==========")
    print("****      list         ****")
    print("****    get file       ****")
    print("****    put file       ****")
    print("****      quit         ****")
    print("=============================")

    cmd = input("輸入命令：")

    if cmd.strip() == 'list':
      ftp.do_list()
    elif cmd[:3] == 'get':
      #　get filename
      filename = cmd.strip().split(' ')[-1]
      ftp.do_get(filename)
    elif cmd[:3] == 'put':
      #　put ../filename
      filename = cmd.strip().split(' ')[-1]
      ftp.do_put(filename)
    elif cmd.strip() == 'quit':
      ftp.do_quit()
    else:
      print("請(qǐng)輸入正確命令")



if __name__ == "__main__":
  main()

from socket import *
from select import select

#　創(chuàng)建一個(gè)監(jiān)聽套接字作為關(guān)注的ＩＯ
s = socket()
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
s.bind(('0.0.0.0',8888))
s.listen(3)

#　設(shè)置關(guān)注列表
rlist = [s]
wlist = []
xlist = [s]

#　循環(huán)監(jiān)控ＩＯ
while True:
  rs,ws,xs = select(rlist,wlist,xlist)
  # 遍歷三個(gè)返回列表,處理ＩＯ
  for r in rs:
    # 根據(jù)遍歷到ＩＯ的不同使用ｉｆ分情況處理
    if r is s:
      c,addr = r.accept()
      print("Connect from",addr)
      rlist.append(c) #　增加新的ＩＯ事件
    # else為客戶端套接字就緒情況
    else:
      data = r.recv(1024)
      # 客戶端退出
      if not data:
        rlist.remove(r) #　從關(guān)注列表移除
        r.close()
        continue # 繼續(xù)處理其他就緒ＩＯ
      print("Receive:",data.decode())
      # r.send(b'OK')
      #　我們希望主動(dòng)處理這個(gè)ＩＯ對(duì)象
      wlist.append(r)

  for w in ws:
    w.send(b'OK')
    wlist.remove(w) #　使用后移除

  for x in xs:
    pass

from socket import *
from select import *

#　創(chuàng)建套接字
s = socket()
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
s.bind(('0.0.0.0',8888))
s.listen(3)

# 創(chuàng)建ｐｏｌｌ對(duì)象關(guān)注ｓ
p = poll()

#　建立查找字典，用于通過ｆｉｌｅｎｏ查找ＩＯ對(duì)象
fdmap = {s.fileno():s}

# 關(guān)注ｓ
p.register(s,POLLIN|POLLERR)

#　循環(huán)監(jiān)控
while True:
  events = p.poll()
  #　循環(huán)遍歷發(fā)生的事件　ｆｄ-->fileno
  for fd,event in events:
    #　區(qū)分事件進(jìn)行處理
    if fd == s.fileno():
      c,addr = fdmap[fd].accept()
      print("Connect from",addr)
      #　添加新的關(guān)注ＩＯ
      p.register(c,POLLIN|POLLERR)
      fdmap[c.fileno()] = c #　維護(hù)字典
    #　按位與判定是ＰＯＬＬＩＮ就緒
    elif event  POLLIN:
      data = fdmap[fd].recv(1024)
      if not data:
        p.unregister(fd) #　取消關(guān)注
        fdmap[fd].close()
        del fdmap[fd]  #　從字典中刪除
        continue
      print("Receive:",data.decode())
      fdmap[fd].send(b'OK')

from socket import *
from select import *

#　創(chuàng)建套接字
s = socket()
s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
s.bind(('0.0.0.0',8888))
s.listen(3)

# 創(chuàng)建eｐｏｌｌ對(duì)象關(guān)注ｓ
ep = epoll()

#　建立查找字典，用于通過ｆｉｌｅｎｏ查找ＩＯ對(duì)象
fdmap = {s.fileno():s}

# 關(guān)注ｓ
ep.register(s,EPOLLIN|EPOLLERR)

#　循環(huán)監(jiān)控
while True:
  events = ep.poll()
  #　循環(huán)遍歷發(fā)生的事件?。妫?->fileno
  for fd,event in events:
    print("親，你有ＩＯ需要處理哦")
    #　區(qū)分事件進(jìn)行處理
    if fd == s.fileno():
      c,addr = fdmap[fd].accept()
      print("Connect from",addr)
      #　添加新的關(guān)注ＩＯ
      #　將觸發(fā)方式變?yōu)檫吘売|發(fā)
      ep.register(c,EPOLLIN|EPOLLERR|EPOLLET)
      fdmap[c.fileno()] = c #　維護(hù)字典
    #　按位與判定是EＰＯＬＬＩＮ就緒
    # elif event  EPOLLIN:
    #   data = fdmap[fd].recv(1024)
    #   if not data:
    #     ep.unregister(fd) #　取消關(guān)注
    #     fdmap[fd].close()
    #     del fdmap[fd]  #　從字典中刪除
    #     continue
    #   print("Receive:",data.decode())
    #   fdmap[fd].send(b'OK')