摘要：擴(kuò)展支持多用戶并發(fā)訪問(wèn)與線程池。項(xiàng)目請(qǐng)見(jiàn)初學(xué)網(wǎng)絡(luò)編程之服務(wù)器。不允許超過(guò)磁盤配額。該文件是一個(gè)使用模塊編寫的線程池類。這一步就做到了線程池的作用。

對(duì)MYFTP項(xiàng)目進(jìn)行升級(jí)。擴(kuò)展支持多用戶并發(fā)訪問(wèn)與線程池。MYFTP項(xiàng)目請(qǐng)見(jiàn)python初學(xué)——網(wǎng)絡(luò)編程之FTP服務(wù)器。

1.在之前開(kāi)發(fā)的FTP基礎(chǔ)上，開(kāi)發(fā)支持多并發(fā)的功能
2.不能使用SocketServer模塊，必須自己實(shí)現(xiàn)多線程
3.必須用到隊(duì)列Queue模塊，實(shí)現(xiàn)線程池
4.允許配置最大并發(fā)數(shù)，比如允許只有10個(gè)并發(fā)用戶

MYFTP

when：任意時(shí)間

where：任何地點(diǎn)

who：FTP用戶

ftp使用用戶名密碼登錄。密碼需要加密認(rèn)證、允許支持多用戶登錄。

每個(gè)用戶有自己的家目錄，所有的訪問(wèn)必須限制在用戶的家目錄。但在家目錄中創(chuàng)建的目錄可以進(jìn)行目錄切換。

用戶的目錄有磁盤配額。不允許超過(guò)磁盤配額。

用戶可以查看當(dāng)前目錄下的文件列表。

用戶可以上傳和下載文件，并且保證文件的一致性。

文件的傳輸過(guò)程中顯示精度條。

支持?jǐn)帱c(diǎn)續(xù)傳。

支持多用戶并發(fā)訪問(wèn)

支持線程池

實(shí)現(xiàn)一套自己的FTP服務(wù)端與客戶端。

線程池使用Queue模塊實(shí)現(xiàn)

登錄順序圖

請(qǐng)從github下載后使用
MYFTP
README

在原來(lái)的lib目錄中增加一個(gè)mythread.py的文件。該文件是一個(gè)使用Queue模塊編寫的線程池類。

+---bin                     # 執(zhí)行程序目錄
|       create_user.py      # 創(chuàng)建用戶程序
|       myftpc.py           # ftp_server啟動(dòng)程序
|       myftps.py           # ftp_client啟動(dòng)程序
|       __init__.py
|
+---conf
|   |   settings.py         # 配置文件
|   |   __init__.py
|   |
|   ---__pycache__
|
+---core
|   |   logger.py           # 日志生成文件
|   |   main.py             # 主程序文件
|   |   __init__.py 
|   |
|   ---__pycache__
|
+---db                      # 數(shù)據(jù)庫(kù)目錄
|   ---accounts            # 賬號(hào)表目錄
|---id_user_rs.json         # 賬號(hào)ID與用戶名對(duì)應(yīng)關(guān)系
+---file_upload             # ftp文件服務(wù)器目錄
+---lib                     # 類文件
|   |   account.py          # 賬號(hào)類
|   |   db.py               # 數(shù)據(jù)庫(kù)類
|   |   myftp_client.py     # ftp客戶端類
|   |   myftp_server.py     # ftp服務(wù)端類
|   |   mythread.py         # 線程池類（新增加內(nèi)容）
|   |   process.py          # 進(jìn)度條展示類（暫時(shí)未使用）
|   |   __init__.py
|   |
|   ---__pycache__
---log
        __init__.py

mythread使用隊(duì)列簡(jiǎn)單實(shí)現(xiàn)了一個(gè)線程池的功能。
實(shí)現(xiàn)的方式比較簡(jiǎn)單，就是通過(guò)在隊(duì)列中存放maxsize的線程對(duì)象。當(dāng)客戶端連接服務(wù)端后時(shí)從隊(duì)列中拿取一個(gè)線程對(duì)象，創(chuàng)建自己的任務(wù)。執(zhí)行完任務(wù)后再往隊(duì)列中添加一個(gè)新的線程對(duì)象。

# -*-coding: utf-8 -*-
# Auther： Henry Yuan
import threading
import time
import queue

class MyThread():
    """
        自定義的線程類，使用queue支持簡(jiǎn)單的線程池
    """
    def __init__(self,maxsize):
        """

        :param maxsize:  隊(duì)列的數(shù)量
        """
        self.maxsize=maxsize
        self.q=queue.Queue(maxsize)  # 初始化一個(gè)隊(duì)列對(duì)象
        # 在隊(duì)列中先存放maxsize個(gè)隊(duì)列對(duì)象。這一步就做到了線程池的作用。
        for i in range(maxsize):
            self.q.put(threading.Thread)  # 在隊(duì)列中先存放線程對(duì)象

    def get_thread(self):
        """  從隊(duì)列中拿取線程對(duì)象

        :return:
        """
        return self.q.get()

    def put_thread(self):
        """  往隊(duì)列中存放線程對(duì)象

        :return:
        """
        self.q.put(threading.Thread)

本系統(tǒng)基于python 3.6版本開(kāi)發(fā)?？蛇\(yùn)行在安裝了python 3.6版本的linux或windows系統(tǒng)中。

進(jìn)入bin目錄:

> cd bin

執(zhí)行create_user.py:

> python ./create_user.py

Account:test2       # 用戶名
Password:test2      # 密碼
Home directory(test2):    # 賬號(hào)的根目錄。默認(rèn)為賬號(hào)名稱
Quota(bytes):10           # 賬號(hào)的quota。默認(rèn)為1G

===================ACCOUNT INFO===================
             Account:      test2
             Home Dir:     test2
             Quota:        10
==================================================

進(jìn)入bin目錄:

> cd bin

執(zhí)行create_user.py:

> python ./myftps.py

進(jìn)入bin目錄:

> cd bin

執(zhí)行create_user.py:

> python ./myftpc.py

FTP用于登錄：

Name:test2
Password:test2
Account [test2] login successful
ftp>: 

ls: 查看用戶當(dāng)前目錄的文件和目錄列表

 ftp>: ls
  驅(qū)動(dòng)器 D 中的卷是 新加卷
  卷的序列號(hào)是 020D-6062
 
  D:deploymentMYFTPfile_upload	est2 的目錄
 
 2018/04/16  12:17              .
 2018/04/16  12:17              ..
                0 個(gè)文件              0 字節(jié)
                2 個(gè)目錄 45,605,543,936 可用字節(jié)
 Directory [test2] list successful.
 ftp>: 

pwd: 查看當(dāng)前所在目錄

ftp>: pwd
Directory [] show successful.

mdir: 創(chuàng)建目錄

 ftp>: mdir temp_dir
 Directory [temp_dir] create successful.

cd：切換目錄

ftp>: cd temp_dir
Directory [temp_dir] change successful.

put: 上傳文件-支持?jǐn)帱c(diǎn)續(xù)傳

ftp>: get temp_file.md
Start download -----> temp_file.md
trandata: %s b"test123"
[>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>]100% recvsize:7, filesize:7
File [temp_file.md] download successful.

get: 下載文件-支持?jǐn)帱c(diǎn)續(xù)傳

ftp>: put temp_file.md
[>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>]100%
File [temp_file.md] upload successful.