使用docker安装fastDFS

docker run -d --network=host --name tracker -v /var/fdfs/tracker:/var/fdfs delron/fastdfs tracker

docker run -d --network=host --name storage -e TRACKER_SERVER=你服务器自己的ip:22122 -v /var/fdfs/storage:/var/fdfs -e GROUP_NAME=group1 delron/fastdfs storage

docker exec -it tracker bash

vi /etc/fdfs/client.conf

 1         <!-- FastDFS依赖 -->
 2         <dependency>
 3             <groupId>com.github.tobato</groupId>
 4             <artifactId>fastdfs-client</artifactId>
 5             <version>1.26.5</version>
 6         </dependency>
 7         <!-- Swagger2 核心依赖 -->
 8         <dependency>
 9             <groupId>io.springfox</groupId>
10             <artifactId>springfox-swagger2</artifactId>
11             <version>2.6.1</version>
12         </dependency>
13         <dependency>
14             <groupId>io.springfox</groupId>
15             <artifactId>springfox-swagger-ui</artifactId>
16             <version>2.6.1</version>
17         </dependency>

 1 spring:
 2   servlet:
 3     multipart:
 4       max-file-size: 100MB # 最大支持文件大小
 5       max-request-size: 100MB # 最大支持请求大小
 6 # 分布式文件系统FDFS配置
 7 fdfs:
 8   # 链接超时
 9   connect-timeout: 600
10   # 读取时间
11   so-timeout: 600
12   # 生成缩略图参数
13   thumb-image:
14     width: 150
15     height: 150
16   tracker-list: 你自己的ip:22122

 1 @Configuration
 2 public class SwaggerConfig {
 3     @Bean
 4     public Docket createRestApi() {
 5         return new Docket(DocumentationType.SWAGGER_2)
 6                 .apiInfo(apiInfo())
 7                 .select()
 8                 .apis(RequestHandlerSelectors.basePackage("top.mail.email.controller"))
 9                 .paths(PathSelectors.any())
10                 .build();
11     }
12     private ApiInfo apiInfo() {
13         return new ApiInfoBuilder()
14                 .title("SpringBoot利用Swagger构建API文档")
15                 .description("使用RestFul风格, 创建人：知了一笑")
16                 .termsOfServiceUrl("https://github.com/cicadasmile")
17                 .version("version 1.0")
18                 .build();
19     }
20 }

1 @Configuration
2 @Import(FdfsClientConfig.class)
3 // Jmx重复注册bean的问题
4 @EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
5 public class DfsConfig {
6 }

 1 @Component
 2 public class FileDfsUtil {
 3     private static final Logger LOGGER = LoggerFactory.getLogger(FileDfsUtil.class);
 4     @Resource
 5     private FastFileStorageClient storageClient ;
 6     /**
 7      * 上传文件
 8      */
 9     public String upload(MultipartFile file) throws Exception{
10         StorePath storePath = storageClient.uploadFile(file.getInputStream(),file.getSize(), FilenameUtils.getExtension(file.getOriginalFilename()),null);
11         return storePath.getFullPath() ;
12     }
13     /**
14      * 删除文件
15      */
16     public void deleteFile(String fileUrl) {
17         if (StringUtils.isEmpty(fileUrl)) {
18             LOGGER.info("fileUrl == >>文件路径为空...");
19             return;
20         }
21         try {
22             StorePath storePath = StorePath.parseFromUrl(fileUrl);
23             storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
24         } catch (Exception e) {
25             LOGGER.info(e.getMessage());
26         }
27     }
28 }

 1 @RestController
 2 public class FileController {
 3     @Resource
 4     private FileDfsUtil fileDfsUtil ;
 5     /**
 6      * 文件上传
 7      */
 8     @ApiOperation(value="上传文件", notes="测试FastDFS文件上传")
 9     @RequestMapping(value = "/uploadFile",headers="content-type=multipart/form-data", method = RequestMethod.POST)
10     public ResponseEntity<String> uploadFile (@RequestParam("file") MultipartFile file){
11         String result ;
12         try{
13             String path = fileDfsUtil.upload(file) ;
14             if (!StringUtils.isEmpty(path)){
15                 result = path ;
16             } else {
17                 result = "上传失败" ;
18             }
19         } catch (Exception e){
20             e.printStackTrace() ;
21             result = "服务异常" ;
22         }
23         return ResponseEntity.ok(result);
24     }
25     /**
26      * 文件删除
27      */
28     @RequestMapping(value = "/deleteByPath", method = RequestMethod.GET)
29     public ResponseEntity<String> deleteByPath (){
30         String filePathName = "group1/M00/00/00/wKhIgl0n4AKABxQEABhlMYw_3Lo825.png" ;
31         fileDfsUtil.deleteFile(filePathName);
32         return ResponseEntity.ok("SUCCESS") ;
33     }
34 }

1 @SpringBootApplication
2 @EnableSwagger2
3 public class EmailApplication {
4 
5     public static void main(String[] args) {
6         SpringApplication.run(EmailApplication.class, args);
7     }
8 
9 }