基于SpringBoot实现上传2种方法工程代码实例

2023-07-18 14:09:20 314

创建SpringBoot工程：

再导入所需要的依赖：


net.oschina.zcx7878
fastdfs-client-java
1.27.0.0



org.apache.commons
commons-lang3

创建上传业务层程序：

packagecn.dzz.fastdfs.service;

importorg.apache.commons.lang3.StringUtils;
importorg.csource.fastdfs.*;
importorg.springframework.beans.factory.annotation.Value;
importorg.springframework.stereotype.Component;
importorg.springframework.web.multipart.MultipartFile;

importjava.util.HashMap;
importjava.util.Map;

/**
*@authorDaiZhiZhou
*@fileBoot-With-FastDFS
*@create2020-08-138:55
*/

//@PropertySource()
@Component
publicclassUploadService{


@Value("${fastdfs.tracker_servers}")
privateStringtracker_servers;

@Value("${fastdfs.connect_timeout_in_seconds}")
privateintconnect_timeout;

@Value("${fastdfs.network_timeout_in_seconds}")
privateintnetwork_timeout;

@Value("${fastdfs.charset}")
privateStringcharset;

publicMapupload(MultipartFilemultipartFile){
if(multipartFile==null){
thrownewRuntimeException("文件不能为空");
}
//上传至fastDFS,返回文件id
StringfileId=this.fdfsUpload(multipartFile);
if(StringUtils.isEmpty(fileId)){
System.out.println("上传失败");
thrownewRuntimeException("上传失败");
}
Mapmap=newHashMap<>();
map.put("code",200);
map.put("msg","上传成功");
map.put("fileId",fileId);
returnmap;
}


/**
*上传至fastDFS
*@parammultipartFile
*@return文件id
*/
privateStringfdfsUpload(MultipartFilemultipartFile){
//1.初始化fastDFS的环境
initFdfsConfig();
//2.获取trackerClient服务
TrackerClienttrackerClient=newTrackerClient();
try{
TrackerServertrackerServer=trackerClient.getConnection();
//3.获取storage服务
StorageServerstoreStorage=trackerClient.getStoreStorage(trackerServer);
//4.获取storageClient
StorageClient1storageClient1=newStorageClient1(trackerServer,storeStorage);
//5.上传文件(文件字节,文件扩展名,)
//5.1获取文件扩展名
StringoriginalFilename=multipartFile.getOriginalFilename();
StringextName=originalFilename.substring(originalFilename.lastIndexOf(".")+1);
//5.2上传
StringfileId=storageClient1.upload_file1(multipartFile.getBytes(),extName,null);
returnfileId;
}catch(Exceptione){
System.out.println(e);
returnnull;
}
}

/**
*初始化fastDFS的环境
*/
privatevoidinitFdfsConfig(){
try{
ClientGlobal.initByTrackers(tracker_servers);
ClientGlobal.setG_connect_timeout(connect_timeout);
ClientGlobal.setG_network_timeout(network_timeout);
ClientGlobal.setG_charset(charset);
}catch(Exceptione){
System.out.println(e);
}
}
}

创建上传控制器：

packagecn.dzz.fastdfs.controller;

importcn.dzz.fastdfs.service.UploadService;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Controller;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.multipart.MultipartFile;

importjava.util.Map;

/**
*@authorDaiZhiZhou
*@fileBoot-With-FastDFS
*@create2020-08-138:58
*/

@RestController
@RequestMapping("upload")
publicclassUploadController{

@Autowired
privateUploadServiceuploadService;

/**
*作上传
*/
@RequestMapping("doUpload")
publicMapdoUpload(MultipartFilemf){
System.out.println(mf.getOriginalFilename());
Mapmap=uploadService.upload(mf);
returnmap;
}
}

在static目录中创建index.html用于上传测试：





Title



文件上传

运行SpringBoot进行测试：

测试成功：

查看文件位置也可以被访问到：

上传文件实现方式二：

更改依赖：



com.github.tobato
fastdfs-client
1.26.7

创建一个配置类UploadProperties

packagecn.dzz.fastdfs.config;

importlombok.Data;
importorg.springframework.boot.context.properties.ConfigurationProperties;
importorg.springframework.stereotype.Component;

importjava.util.List;

/**
*@authorDaiZhiZhou
*@fileBoot-With-FastDFS
*@create2020-08-139:10
*/

@Data
@Component
@ConfigurationProperties(prefix="upload")
publicclassUploadProperties{
privateStringbaseUrl;
privateListallowTypes;
}

更改之前的yml配置：

fdfs:
so-timeout:2500#读取时间
connect-timeout:600#连接超时时间
thumb-image:#缩略图
width:100
height:100
tracker-list:#tracker服务配置地址列表
-服务器或者虚拟机IP:22122
upload:
base-url:http://服务器或者虚拟机IP/
allow-types:
-image/jpeg
-image/png
-image/bmp
-image/gif

编写UploadProperties.java

packagecn.dzz.config;

importlombok.Data;
importorg.springframework.boot.context.properties.ConfigurationProperties;

importjava.util.List;

/**
*@authorDaiZhiZhou
*@filefdfs
*@create2020-08-139:33
*/
@ConfigurationProperties(prefix="upload")
@Data
publicclassUploadProperties{
privateStringbaseUrl;
privateListallowTypes;
}

业务层：

packagecn.dzz.service;

importcn.dzz.config.UploadProperties;
importcom.github.tobato.fastdfs.domain.fdfs.StorePath;
importcom.github.tobato.fastdfs.service.FastFileStorageClient;
importorg.apache.commons.lang3.StringUtils;
importorg.apache.commons.logging.Log;
importorg.apache.commons.logging.LogFactory;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.boot.context.properties.EnableConfigurationProperties;
importorg.springframework.stereotype.Component;
importorg.springframework.web.multipart.MultipartFile;

importjavax.imageio.ImageIO;
importjava.awt.image.BufferedImage;
importjava.io.IOException;

/**
*@authorDaiZhiZhou
*@filefdfs
*@create2020-08-139:34
*/

@Component
@EnableConfigurationProperties(UploadProperties.class)
publicclassUploadService{
privateLoglog=LogFactory.getLog(UploadService.class);

@Autowired
privateFastFileStorageClientstorageClient;

@Autowired
privateUploadPropertiesprop;

publicStringuploadImage(MultipartFilefile){
//1、校验文件类型
StringcontentType=file.getContentType();
if(!prop.getAllowTypes().contains(contentType)){
thrownewRuntimeException("文件类型不支持");
}
//2、校验文件内容
try{
BufferedImageimage=ImageIO.read(file.getInputStream());
if(image==null||image.getWidth()==0||image.getHeight()==0){
thrownewRuntimeException("上传文件有问题");
}
}catch(IOExceptione){
log.error("校验文件内容失败....{}",e);
thrownewRuntimeException("校验文件内容失败"+e.getMessage());
}

try{
//3、上传到FastDFS
//3.1、获取扩展名
Stringextension=StringUtils.substringAfterLast(file.getOriginalFilename(),".");
//3.2、上传
StorePathstorePath=storageClient.uploadFile(file.getInputStream(),file.getSize(),extension,null);
//返回路径
returnprop.getBaseUrl()+storePath.getFullPath();
}catch(IOExceptione){
log.error("【文件上传】上传文件失败！....{}",e);
thrownewRuntimeException("【文件上传】上传文件失败！"+e.getMessage());
}
}
}

控制器：

packagecn.dzz.controller;

importcn.dzz.service.UploadService;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;
importorg.springframework.web.multipart.MultipartFile;

importjava.util.HashMap;
importjava.util.Map;

/**
*@authorDaiZhiZhou
*@filefdfs
*@create2020-08-139:35
*/
@RequestMapping("upload")
@RestController
publicclassUploadController{

@Autowired
privateUploadServiceuploadService;

@RequestMapping("doUpload")
publicMapdoUpload(MultipartFilemultipartFile){
System.out.println(multipartFile.getOriginalFilename());
Mapmap=newHashMap<>();
StringfilePath=uploadService.uploadImage(multipartFile);
map.put("filePath",filePath);
returnmap;
}

}

还是一样的上传页面：





Title



文件上传

运行发现空指针异常，检查发现表单名称没对上，SpringMVC就无法转换了

再次测试：

访问：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

基于SpringBoot实现上传2种方法工程代码实例

文件上传

文件上传

热门推荐

随机推荐