Springboot 封装Fastdfs 功能模块

喜欢ヅ旅行 2024-02-19 19:14 61阅读 0赞

整体项目结构：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70][]

第一步：BuleSky 的pom.xml 文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<groupId>com.zzg</groupId>
    	<artifactId>BuleSky</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>pom</packaging>
    
    	
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.0.RELEASE</version>
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<version>1.18.0</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>commons-net</groupId>
    			<artifactId>commons-net</artifactId>
    			<version>3.6</version>
    		</dependency>
    		 <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>3.8.1</version>
            </dependency>
    	</dependencies>
    	<modules>
    		<module>common-ssh</module>
    		<module>common-ftp</module>
    		<module>common-fastdfs</module>
    		<module>common-monitor-windows</module>
    		<module>common-monitor_linux</module>
    		<module>common-elasticsearch</module>
    	</modules>
    </project>

common-fastdfs 项目结构图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70 1][]

common-fastdfs的pom.xml文件：

Application.java 代码：

package com.zzg.common;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.annotation.Import;
    
    import com.github.tobato.fastdfs.FdfsClientConfig;
    
    @SpringBootApplication
    @Import(FdfsClientConfig.class)
    public class Application {
    
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(Application.class, args);
    	}
    }

FastDFSClient.java

package com.zzg.common.util;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import org.apache.commons.io.FileUtils;
    import org.apache.commons.io.FilenameUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import com.github.tobato.fastdfs.domain.fdfs.StorePath;
    import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray;
    import com.github.tobato.fastdfs.service.FastFileStorageClient;
    
    @Component
    public class FastDFSClient {
    	 	@Autowired
    	    private FastFileStorageClient storageClient;
    	   
    	  
    	    // 文件上传
    	    public String uploadFile(String path) throws FileNotFoundException{
    	    	File file = new File(path);
    	    	InputStream input = new FileInputStream(file);
    	    	long size = FileUtils.sizeOf(file);
    	    	String name = file.getName();
    	    	String fileName = name.substring(name.lastIndexOf("/")+1);  
    	    	StorePath storePath = storageClient.uploadFile(input,size, FilenameUtils.getExtension(fileName),null);
    	    	return storePath.getFullPath();
    	    }
    	    
    	    // 文件删除
    	    public boolean deleteFile(String path) {
    	    	try{
    	    		StorePath storePath = StorePath.parseFromUrl(path);
    	    		storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
    	    		return true;	    		
    	    	} catch(Exception e) {
    	    		return false;
    	    	}
    	    }
    	    
    	    // 文件下载
    	    public boolean downloadFile(String path,String downloadFilePath) throws IOException{
    	    	File file = new File(downloadFilePath);
    	    	FileOutputStream outputStream = null;
    	    	// fastdfs 文件读取
    	    	String filepath = path.substring(path.lastIndexOf("group1/")+7);
    	    	DownloadByteArray callback = new DownloadByteArray();
                byte[] content = storageClient.downloadFile("group1", filepath,callback);
                // 数据写入指定文件夹中
                outputStream = new FileOutputStream(file);
                outputStream.write(content);
    	    	return true;
    	    }
    
    }

application.properties(配置文件)

fdfs.soTimeout=1500
    fdfs.connectTimeout=600
    fdfs.trackerList[0]=192.168.60.178:22122

fastdfs 功能测试：

FastdfsTest.java

package com.zzg.common.fds;
    
    import java.io.FileNotFoundException;
    import java.io.IOException;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    import org.springframework.util.StringUtils;
    
    import com.github.tobato.fastdfs.domain.fdfs.StorePath;
    import com.zzg.common.util.FastDFSClient;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class FastdfsTest {
    	@Autowired
    	private FastDFSClient client;
    
    	@Test
    	public void uploadFile() throws FileNotFoundException {
    		String filepath = "C:/Users/zzg/Desktop/spring-security.png";
    		String result = client.uploadFile(filepath);
    		if (!StringUtils.isEmpty(result)) {
    			System.out.println("资源路径:" + result);
    			System.out.println("文件上传成功");
    		} else {
    			System.out.println("文件上传失败");
    		}
    	}
    
    	@Test
    	public void deleteFile() {
    		String fileUrl = "group1/M00/00/00/wKg8pVyB9E6AQlcJAAMjXuQzK2A959.png";
    		if (StringUtils.isEmpty(fileUrl)) {
    			return;
    		}
    		boolean flag = client.deleteFile(fileUrl);
    		if(flag){
    			System.out.println("文件删除成功");
    		} else {
    			System.out.println("文件删除失败");
    		}
    	}
    	
    	@Test
    	public void downloadFile() throws IOException{
    		String path = "group1/M00/00/00/wKg8pVyCDsaABTVdAAMjXuQzK2A647.png";
    		String downloadFilePath ="C:/Users/zzg/Desktop/test.png";
    		boolean flag = client.downloadFile(path, downloadFilePath);
    		if(flag){
    			System.out.println("文件下载成功");
    		} else {
    			System.out.println("文件下载失败");
    		}
    	}
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/dd775f93083e4fac8e7dbc239f34d2df.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/ab276c4a0af44110adaca494ea622200.png