上传图片开发

1.1.1需求分析

在很多系统都有上传图片/上传文件的需求，比如：上传课程图片、上传课程资料、上传用户头像等，为了提供系 统的可重用性专门设立文件系统服务承担图片/文件的管理，文件系统服务实现对文件的上传、删除、查询等功能 进行管理。

各各子系统不再开发上传文件的请求，各各子系统通过文件系统服务进行文件的上传、删除等操作。文件系统服务 最终会将文件存储到fastDSF文件系统中。

下图是各各子系统与文件系统服务之间的关系：

下图是课程管理中上传图片处理流程：

执行流程如下：

1、管理员进入教学管理前端，点击上传图片

2、图片上传至文件系统服务，文件系统请求fastDFS上传文件

3、文件系统将文件入库，存储到文件系统服务数据库中。

4、文件系统服务向前端返回文件上传结果，如果成功则包括文件的Url路径。

5、课程管理前端请求课程管理进行保存课程图片信息到课程数据库。

6、课程管理服务将课程图片保存在课程数据库。

1.1.2创建文件系统服务工程

导入xc-service-base-filesystem.zip工程。

1)工程目录结构

pom.xml

<?xml version="1.0" encoding="UTF‐8"?>xc‐framework‐parentcom.xuecheng1.0‐SNAPSHOT../xc‐framework‐parent/pom.xml4.0.0xc‐service‐base‐filesystemcom.xuechengxc‐service‐api1.0‐SNAPSHOTcom.xuechengxc‐framework‐model1.0‐SNAPSHOTcom.xuechengxc‐framework‐common1.0‐SNAPSHOTorg.springframework.bootspring‐boot‐starter‐webnet.oschina.zcx7878fastdfs‐client‐javaorg.springframework.bootspring‐boot‐starter‐testtestorg.apache.commonscommons‐ioorg.springframework.bootspring‐boot‐starter‐data‐mongodb

2)配置文件

原测试程序中fastdfs-client.properties的配置信息统一放在application.yml application.yml

server:port: 22100 spring:application:name: xc‐service‐base‐filesystem #mongo配置data:mongodb:database: xc_fsuri: mongodb://root:123@127.0.0.1:27017 #SpringMVC上传文件配置servlet: multipart:#默认支持文件上传.enabled: true#支持文件写入磁盘.file‐size‐threshold: 0 # 上传文件的临时目录location:# 最大支持文件大小max‐file‐size: 1MB # 最大支持请求大小max‐request‐size: 30MB xuecheng:fastdfs: connect_timeout_in_seconds: 5network_timeout_in_seconds: 30 charset: UTF‐8tracker_servers: 192.168.101.64:22122

1.1.3API接口

1.1.3.1模型类

系统的文件信息(图片、文档等小文件的信息)在mongodb中存储，下边是文件信息的模型类。

1)模型如下：

@Data@ToString@Document(collection = "filesystem") public class FileSystem {@Idprivate String fileId;//文件请求路径private String filePath;//文件大小private long fileSize;//文件名称private String fileName;//文件类型private String fileType;//图片宽度private int fileWidth;//图片高度private int fileHeight;//用户id，用于授权暂时不用private String userId;//业务keyprivate String businesskey;//业务标签private String filetag;//文件元信息private Map metadata;

说明：

fileId：fastDFS返回的文件ID。filePath：请求fastDFS浏览文件URL。

filetag：文件标签，由于文件系统服务是公共服务，文件系统服务会为使用文件系统服务的子系统分配文件标签， 用于标识此文件来自哪个系统。

businesskey：文件系统服务为其它子系统提供的一个业务标识字段，各子系统根据自己的需求去使用，比如：课 程管理会在此字段中存储课程id用于标识该图片属于哪个课程。

metadata：文件相关的元信息。

2)collection

在mongodb创建数据库xc_fs(文件系统数据库)，并创建集合 filesystem。

1.1.3.2Api接口

在api工程下创建com.xuecheng.api.filesystem包，

public interface FileSystemControllerApi {/***上传文件*@param multipartFile 文 件*@param filetag 文件标签*@param businesskey 业务key*@param metedata 元信息,json格式*@return*/public UploadFileResult upload(MultipartFile multipartFile, String filetag,String businesskey, String metadata);}

1.1.2.3Dao

将文件信息存入数据库，主要存储文件系统中的文件路径。

public interface FileSystemRepository extends MongoRepository {}

1.1.2.4Service

@Servicepublic class FileSystemService {private static final Logger LOGGER = LoggerFactory.getLogger(FileSystemService.class); @Value("${xuecheng.fastdfs.tracker_servers}")String tracker_servers; @Value("${xuecheng.fastdfs.connect_timeout_in_seconds}") int connect_timeout_in_seconds; @Value("${xuecheng.fastdfs.network_timeout_in_seconds}") int network_timeout_in_seconds; @Value("${xuecheng.fastdfs.charset}")String charset;@AutowiredFileSystemRepository fileSystemRepository;//加载fdfs的配置private void initFdfsConfig(){ try {ClientGlobal.initByTrackers(tracker_servers); ClientGlobal.setG_connect_timeout(connect_timeout_in_seconds); ClientGlobal.setG_network_timeout(network_timeout_in_seconds); ClientGlobal.setG_charset(charset);} catch (Exception e) { e.printStackTrace();//初始化文件系统出错ExceptionCast.cast(FileSystemCode.FS_INITFDFSERROR);}}//上传文件public UploadFileResult upload(MultipartFile file,String filetag, String businesskey, String metadata){if(file == null){ ExceptionCast.cast(FileSystemCode.FS_UPLOADFILE_FILEISNULL);}//上传文件到fdfsString fileId = fdfs_upload(file);//创建文件信息对象FileSystem fileSystem = new FileSystem();// 文 件 id fileSystem.setFileId(fileId);//文件在文件系统中的路径fileSystem.setFilePath(fileId);//业务标识fileSystem.setBusinesskey(businesskey);//标签fileSystem.setFiletag(filetag);//元数据if(StringUtils.isNotEmpty(metadata)){try {Map map = JSON.parseObject(metadata, Map.class); fileSystem.setMetadata(map);} catch (Exception e) { e.printStackTrace();}}//名称fileSystem.setFileName(file.getOriginalFilename());//大小fileSystem.setFileSize(file.getSize());//文件类型fileSystem.setFileType(file.getContentType()); fileSystemRepository.save(fileSystem);return new UploadFileResult(CommonCode.SUCCESS,fileSystem);}//上传文件到fdfs，返回文件idpublic String fdfs_upload(MultipartFile file) { try {//加载fdfs的配置initFdfsConfig();//创建tracker clientTrackerClient trackerClient = new TrackerClient();//获取trackerServerTrackerServer trackerServer = trackerClient.getConnection();//获取storageStorageServer storeStorage = trackerClient.getStoreStorage(trackerServer);//创建storage clientStorageClient1 storageClient1 = new StorageClient1(trackerServer,storeStorage);//上传文件//文件字节byte[] bytes = file.getBytes();//文件原始名称String originalFilename = file.getOriginalFilename();//文件扩展名String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);//文件idString file1 = storageClient1.upload_file1(bytes, extName, null);return file1;} catch (Exception e) { e.printStackTrace();}return null;}}

1.1.2.5Controller

@RestController @RequestMapping("/filesystem")public class FileSystemController implements FileSystemControllerApi { @AutowiredFileSystemService fileSystemService;@Override @PostMapping("/upload")public UploadFileResult upload(@RequestParam("file") MultipartFile file,@RequestParam(value = "filetag