服务器接收客户端图片上传，并保存在硬盘中

前面几小节，我们已完成了 JSON 格式的纯数据交互，在 App 服务器端的设计中，我们难免会接收客户端图片的上传，并提供端图片下载。本小节将讲解，对于客户端向服务器端上传图片，服务器端将如何处理。简单交互过程如下。

同样，在这一小节中，我们也使用工具来代替 App 客户端模拟图片的上传。我们将要用到的工具是 JMeter，它是一个强大的工具，最为熟知的是 HTTP 的测试。这里我们不去深入了解 JMeter，而只是取其一个小功能 —— HTTP POST 图片的功能来完成讲解，读者如果感兴趣，可以自行学习拓展。

下载 JMeter

通过官网下载 JMeter：Download Apache JMeter

安装 JMeter

下载完成后，解压文件夹，进入 bin 目录，点击 jmeter.bat 进行 JMeter 的安装，安装成功后的界面如下。

配置测试计划

切换语言

依次选择“Options” -> “Choose Language” -> “Chinese (Simplified)”，如下图所示。

配置 HTTP 请求

右击 “Test Plan”，点击“添加” -> “Threads (Users)” -> “线程组”

右击 “线程组”，点击 “添加” -> “Sampler” -> “HTTP 请求”

在弹出的「HTTP 请求」框中进行如下设置：

• 第 1~4 步，按照截图输入或选择；
• 第 5 步，设定我们要上传图片（文件）的 URL 路径是 upload/file；
• 第 6 步，选择 “Files Upload”；
• 第 7 步，点击 ”添加”；
• 第 8 步，点击 “浏览”，从本地随便选取一张图片（或本小节末尾提供的图片）；
• 第 9 步，输入该图片对象的参数名 image；
• 第 10 步，输入我们上传的文件类型 image。

至此，请求页面已配置完毕，点击 “文件” -> “保存测试计划” 如下。

测试请求

点击如下 “启动” 按钮，测试是否请求成功

查看服务器端

此打印说明服务器端接收客户端请求成功，但由于 /upload/file 路径的代码未实现，服务器端返回 404 找不到路径。接下来，将进行服务器端图片上传代码编写。

服务器端代码编写

调用逻辑

与第 6 小节用户注册请求服务器端实现类似，客户端上传图片，进入 main.py，将调用 url_router 转发到 upload_url.py 中，在 upload_urls.py 中，对应的 URL 将调用 upload_views.py 的 UploadFileHandle 类，UploadFileHandle 为真正的代码处理逻辑，在校验用户信息正确的情况下，返回图片 URL 给客户端，客户端加载该图片。

创建目录

在 views 下面创建 upload 目录，在 upload 下创建 upload_urls.py、upload_views.py等文件。

在 log 目录下创建 upload 目录，用于存放日志。

图片一般会放在 static 目录下，在实际项目中，static 下的图片目录也是分层级的，此次讲解，我们将简化，把图片直接放在 static/image 目录下。创建 image 目录如下：

编写逻辑代码

修改 main.py 文件，增加 views.upload.upload_urls下的 url 路由，修改 handers 如下：

        handlers = url_wrapper([
        (r"/users/", include('views.users.users_urls')),
        (r"/upload/", include('views.upload.upload_urls'))
        ])

修改 upload_urls.py，输入如下代码：

#!/usr/bin/python3
# -*- coding:utf-8 -*-


from __future__ import unicode_literals
from .upload_views import (
    UploadFileHandle
)

urls = [
    #从/upload/file过来的请求，将调用upload_views里面的UploadFileHandle类
    (r'file', UploadFileHandle)
]

修改 upload_views.py，输入如下代码：

#! /usr/bin/python3
# -*- coding:utf-8 -*-

import tornado.web
import os
from tornado.escape import json_decode
import logging
from logging.handlers import TimedRotatingFileHandler
import json


#从commons中导入http_response及save_files方法
from common.commons import (
    http_response,
    save_files
)

#从配置文件中导入错误码
from conf.base import (
    ERROR_CODE,
    SERVER_HEADER
)

########## Configure logging #############
logFilePath = "log/upload/upload.log"
logger = logging.getLogger("Upload")  
logger.setLevel(logging.DEBUG)  
handler = TimedRotatingFileHandler(logFilePath,  
                                   when="D",  
                                   interval=1,  
                                   backupCount=30)  
formatter = logging.Formatter('%(asctime)s \
%(filename)s[line:%(lineno)d] %(levelname)s %(message)s',)  
handler.suffix = "%Y%m%d"
handler.setFormatter(formatter)
logger.addHandler(handler)
 
 
class UploadFileHandle(tornado.web.RequestHandler):
    """handle /upload/file request, upload image and save it to static/image/
    :param image: upload image
    """
        
    def post(self):
        try:
            #获取入参
            image_metas = self.request.files['image']
        except:
            #获取入参失败时，抛出错误码及错误信息
            logger.info("UploadFileHandle: request argument incorrect")
            http_response(self, ERROR_CODE['1001'], 1001)
            return 
            
        image_url = ""
        image_path_list = []
        if image_metas:
            #获取当前的路径
            pwd = os.getcwd()
            save_image_path = os.path.join(pwd, "static/image/")
            logger.debug("UploadFileHandle: save image path: %s" %save_image_path)
            #调用save_file方法将图片数据流保存在硬盘中
            file_name_list = save_files(image_metas, save_image_path)
            image_path_list = [SERVER_HEADER + "/static/image/" + i for i in file_name_list]
            ret_data = {"imageUrl": image_path_list}
            #返回图片下载地址给客户端
            self.write(json.dumps({"data": {"msg": ret_data, "code": 0}}))
        else:
            #如果图片为空，返回图片为空错误信息
            logger.info("UploadFileHandle: image stream is empty")
            http_response(self, ERROR_CODE['2001'], 2001)

这里，我们从 common 导入 save_files 用于处理图片的保存，从 conf 的 base 中导入 SERVER_HEADER，定义了我们服务器的 URL 前缀。同时也看到，upload 和 users 的 Log 配置（如级别）是单独配置的，这样有助于单模块调试。下面修改 conf 目录下的 base.py 文件，增加如下：

完整代码如下：

#! /usr/bin/python3
# -*- coding:utf-8 -*-

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
engine = create_engine('mysql://root:pwd@demo@localhost:3306/demo?charset=utf8', encoding="utf8", echo=False)
BaseDB = declarative_base()

#服务器端 IP+Port，请修改对应的IP
SERVER_HEADER = "http://150.109.33.132:8000"

ERROR_CODE = {
    "0": "ok",
    #Users error code
    "1001": "入参非法",
    "1002": "用户已注册，请直接登录",
    
    "2001": "上传图片不能为空"
}

commons.py 下，导入 os 模块（ import os ），并增加 save_files 方法：

import os

def save_files(file_metas, in_rel_path, type='image'):
    """
    Save file stream to server
    """
    file_path = ""
    file_name_list = []
    for meta in file_metas:
        file_name = meta['filename']
        file_path = os.path.join( in_rel_path, file_name )
        file_name_list.append( file_name )
        #save image as binary
        with open( file_path, 'wb' ) as up:
            up.write( meta['body'] )
    return file_name_list

至此，服务器端的代码已完成。再次从 JMeter 触发图片上传，在触发图片上传之前，我们先创建 JMeter 的结果树。所谓结果树，就是在触发请求之后，查看服务器端返回的结构。右击 “HTTP 请求”，依次选择“添加” -> ”监听器” -> “查看结果树”，如下图所示。

触发 JMeter 图片上传，点击 “察看结果树”，切到 “响应数据” 页面，可以看到服务器端返回的数据信息：

{"data": {"msg": {"imageUrl": ["http://150.109.33.132:8000/static/image/demo.jpg"]}, "code": 0}}

查看服务器端进程打印：

查看图片是否上传：

查看 log 是否成功写入：

此时，客户端就可以通过服务器端返回的图片 URL（http://150.109.33.132:8000/static/image/demo.jpg）加载图片了，在浏览器中输入图片 URL，查看加载是否成功。

代码下载

到目前为止，服务器端代码及图片如下：
demo9

小结

至此，我们完成了服务器端图片上传的接收及图片 URL 返回，客户端根据服务器返回的图片 URL，即可加载该图片。这里没有写数据库的操作，读者可以尝试参考第 8 节的讲解，定义图片的 models，并将图片 URL 和其他信息写入数据库中。