管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2022-10-08 e7b3a5e891287b1291d2ac38f7c83d5d73bc7906
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
package com.lf.server.service.all;
 
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.tomcat.util.http.fileupload.FileItem;
import org.apache.tomcat.util.http.fileupload.disk.DiskFileItemFactory;
import org.apache.tomcat.util.http.fileupload.servlet.ServletFileUpload;
import org.apache.tomcat.util.http.fileupload.servlet.ServletRequestContext;
import org.springframework.stereotype.Service;
 
import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.util.List;
import java.util.UUID;
 
/**
 * 文件服务类
 * @author WWW
 */
@Service
public class FileService {
    private final static Log log = LogFactory.getLog(FileService.class);
 
    /**
     * 上传文件
     *
     * @param req
     * @param res
     */
    public void upload(HttpServletRequest req, HttpServletResponse res) {
        try {
            // 处理中文乱码问题
            req.setCharacterEncoding("utf-8");
            res.setContentType("text/html;charset=utf-8");
 
            // 检查请求是/否是multipart/form-data类型
            if (!ServletFileUpload.isMultipartContent(req)) {
                throw new RuntimeException("表单的enctype属性不是multipart/form-data类型!!");
            }
 
            // 创建上传所需要的两个对象:磁盘文件对象+文件上传对象
            DiskFileItemFactory factory = new DiskFileItemFactory();
            ServletFileUpload sfu = new ServletFileUpload(factory);
            ServletRequestContext ctx = new ServletRequestContext(req);
 
            //限制单个文件的大小
            sfu.setFileSizeMax(1024 * 10);
 
            //限制上传的总文件大小
            sfu.setSizeMax(1024 * 200);
 
            // 设置编码方式
            sfu.setHeaderEncoding("utf-8");
 
            // list容器用来保存表单中的所有数据信息
            List<FileItem> items = sfu.parseRequest(ctx);
 
            // 遍历容器,处理解析的内容:一个处理普通表单域,一个处理文件的表单域
            for (FileItem item : items) {
                if (item.isFormField()) {
                    handleFormField(item);
                } else {
                    handleFileField(item, req);
                }
            }
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
        }
    }
 
    /**
     * 处理 普通数据项
     *
     * @param item
     */
    private void handleFormField(FileItem item) {
        // 获取 普通数据项中的 name值
        String fieldName = item.getFieldName();
 
        // 获取 普通数据项中的 value值
        String value = "";
        try {
            // 以 utf-8的编码格式来解析 value值
            value = item.getString("utf-8");
        } catch (Exception ex) {
            log.error(ex.getStackTrace());
        }
 
        // 输出到控制台
        System.out.println("fieldName:" + fieldName + "--value:" + value);
    }
 
    /**
     * 处理 文件数据项
     *
     * @param item
     */
    private void handleFileField(FileItem item, HttpServletRequest req) {
        // 获取 文件数据项中的 文件名
        String fileName = item.getName();
 
        // 判断 此文件的文件名是否合法
        if (fileName == null || "".equals(fileName)) {
            return;
        }
 
        // 控制只能上传图片
        String img = "image";
        if (!item.getContentType().startsWith(img)) {
            return;
        }
 
        // 将文件信息输出到控制台:文件名+文件大小
        System.out.println("fileName:" + fileName);
        System.out.println("fileSize:" + item.getSize());
 
        // 获取 当前项目下的 /files 目录的绝对位置
        ServletContext ctx = req.getSession().getServletContext();
        String path = ctx.getRealPath("/files");
 
        // 创建 file对象
        File file = new File(path);
        if (!file.exists()) {
            // 创建目录
            file.mkdir();
        }
 
        // 将文件保存到服务器上(UUID是通用唯一标识码)
        try {
            item.write(new File(file.toString(), UUID.randomUUID() + "_" + fileName));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}