FastDFS使用

骑猪看日落 2021-10-06 02:44 391阅读 0赞

### FastDFS使用 ###

*  引入依赖
 *  项目使用

# 引入依赖 #

<dependency>
 		<groupId>commons-fileupload</groupId>
 		<artifactId>commons-fileupload</artifactId>
 	</dependency>
 	<dependency>
 		<groupId>fastdfs_client</groupId>
 		<artifactId>fastdfs_client</artifactId>
 		<version>1.25</version>
 	</dependency>

# 项目使用 #

（1）前提：搭建FastDFS服务器  
（2）添加配置  
conf/fdfs\_client.conf

connect_timeout = 2
    network_timeout = 30
    charset = UTF-8
    http.tracker_http_port = 8080
    http.anti_steal_token = no
    http.secret_key = FastDFS1234567890
    #多个跟踪器需配置多个（FastDFS集群）
    tracker_server = 192.168.164.116:22122
    tracker_server = 192.168.164.117:22122

（3）使用方式一  
使用原生工具类FastDFSClient  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE1NzY0OTQz_size_16_color_FFFFFF_t_70]  
（4）使用方式二

/**
 * FastDFS分布式文件系统操作客户端
 *
 * @author vander
 * @author 2018/2/27
 */
 public class FastDFSUtil {
 
 private static final String CONF_FILENAME = Thread.currentThread().getContextClassLoader().getResource("").getPath() + "conf/fdfs_client.conf";
 
 private static StorageClient1 storageClient = null;
 
 private static Logger logger = Logger.getLogger(FastDFSClient.class);
 
 /**
 * 只加载一次.
 */
 static {
 try {
 logger.info("=== CONF_FILENAME:" + CONF_FILENAME);
 ClientGlobal.init(CONF_FILENAME);
 TrackerClient trackerClient = new TrackerClient(ClientGlobal.g_tracker_group);
 TrackerServer trackerServer = trackerClient.getConnection();
 if (trackerServer == null) {
 logger.error("getConnection return null");
 }
 StorageServer storageServer = trackerClient.getStoreStorage(trackerServer);
 if (storageServer == null) {
 logger.error("getStoreStorage return null");
 }
 storageClient = new StorageClient1(trackerServer, storageServer);
 } catch (Exception e) {
 logger.error(e);
 }
 }
 
 /**
 * 上传文件方法
 * Title: uploadFile
 * Description: 
 * @param fileContent 文件的内容，字节数组
 * @param extName 文件扩展名
 * @param metas 文件扩展信息
 * @return
 * @throws Exception
 */
 public static String uploadFile(byte[] fileContent, String extName, NameValuePair[] metas) throws Exception {
 
 String result = storageClient.upload_file1(fileContent, extName, metas);
 return result;
 }
 
 public static String uploadFile(byte[] fileContent) throws Exception {
 return uploadFile(fileContent, null, null);
 }
 
 public static String uploadFile(byte[] fileContent, String extName) throws Exception {
 return uploadFile(fileContent, extName, null);
 }
 
 /**
 * 上传文件方法
 * Title: uploadFile
 * Description: 
 * @param fileName 文件全路径
 * @param extName 文件扩展名，不包含（.）
 * @param metas 文件扩展信息
 * @return
 * @throws Exception
 */
 public static String uploadFile(String fileName, String extName, NameValuePair[] metas) throws Exception {
 String result = storageClient.upload_file1(fileName, extName, metas);
 return result;
 }
 
 public static String uploadFile(String fileName) throws Exception {
 return uploadFile(fileName, null, null);
 }
 
 public static String uploadFile(String fileName, String extName) throws Exception {
 return uploadFile(fileName, extName, null);
 }
 
 /**
 *
 * @param file
 * 文件
 * @param fileName
 * 文件名
 * @return 返回Null则为失败
 */
 public static String uploadFile(File file, String fileName) {
 FileInputStream fis = null;
 try {
 NameValuePair[] meta_list = null; // new NameValuePair[0];
 fis = new FileInputStream(file);
 byte[] file_buff = null;
 if (fis != null) {
 int len = fis.available();
 file_buff = new byte[len];
 fis.read(file_buff);
 }
 
 String fileid = storageClient.upload_file1(file_buff, getFileExt(fileName), meta_list);
 return fileid;
 } catch (Exception ex) {
 logger.error(ex);
 return null;
 }finally{
 if (fis != null){
 try {
 fis.close();
 } catch (IOException e) {
 logger.error(e);
 }
 }
 }
 }
 
 /**
 * 根据组名和远程文件名来删除一个文件
 *
 * @param groupName
 * 例如 "group1" 如果不指定该值，默认为group1
 * @param fileName
 * 例如"M00/00/00/wKgxgk5HbLvfP86RAAAAChd9X1Y736.jpg"
 * @return 0为成功，非0为失败，具体为错误代码
 */
 public static int deleteFile(String groupName, String fileName) {
 try {
 int result = storageClient.delete_file(groupName == null ? "group1" : groupName, fileName);
 return result;
 } catch (Exception ex) {
 logger.error(ex);
 return 0;
 }
 }
 
 /**
 * 根据fileId来删除一个文件（我们现在用的就是这样的方式，上传文件时直接将fileId保存在了数据库中）
 *
 * @param fileId
 * file_id源码中的解释file_id the file id(including group name and filename);例如 group1/M00/00/00/ooYBAFM6MpmAHM91AAAEgdpiRC0012.xml
 * @return 0为成功，非0为失败，具体为错误代码
 */
 public static int deleteFile(String fileId) {
 try {
 int result = storageClient.delete_file1(fileId);
 return result;
 } catch (Exception ex) {
 logger.error(ex);
 return 0;
 }
 }
 
 /**
 * 修改一个已经存在的文件
 *
 * @param oldFileId
 * 原来旧文件的fileId, file_id源码中的解释file_id the file id(including group name and filename);例如 group1/M00/00/00/ooYBAFM6MpmAHM91AAAEgdpiRC0012.xml
 * @param file
 * 新文件
 * @param filePath
 * 新文件路径
 * @return 返回空则为失败
 */
 public static String modifyFile(String oldFileId, File file, String filePath) {
 String fileid = null;
 try {
 // 先上传
 fileid = uploadFile(file, filePath);
 if (fileid == null) {
 return null;
 }
 // 再删除
 int delResult = deleteFile(oldFileId);
 if (delResult != 0) {
 return null;
 }
 } catch (Exception ex) {
 logger.error(ex);
 return null;
 }
 return fileid;
 }
 
 /**
 * 文件下载
 *
 * @param fileId
 * @return 返回一个流
 */
 public static InputStream downloadFile(String fileId) {
 try {
 byte[] bytes = storageClient.download_file1(fileId);
 InputStream inputStream = new ByteArrayInputStream(bytes);
 return inputStream;
 } catch (Exception ex) {
 logger.error(ex);
 return null;
 }
 }
 
 /**
 * 获取文件后缀名（不带点）.
 *
 * @return 如："jpg" or "".
 */
 private static String getFileExt(String fileName) {
 if (StringUtils.isBlank(fileName) || !fileName.contains(".")) {
 return "";
 } else {
 return fileName.substring(fileName.lastIndexOf(".") + 1); // 不带最后的点
 }
 }
 }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE1NzY0OTQz_size_16_color_FFFFFF_t_70]: /images/20211006/63f768ed02344f878b35bd7f87e4e4ed.png