前言 要了解FastDFS的工作流程

1、首先加入jar包

      <dependency>
      <groupId>net.oschina.zcx7878</groupId>
      <artifactId>fastdfs-client-java</artifactId>
      <version>1.27.0.0</version>
      </dependency>
  
 

2、配置FastDFS基本信息：

     在项目的resource目录下面新建fdfs_client.conf配置文件，配置信息如下：

      connect_timeout = 60
      network_timeout = 60
      charset = UTF-8
      http.tracker_http_port = 8080
      tracker_server = 192.168.200.128:22122
  
 

3、封装文件的信息（FastDFSFile.java）

      public class FastDFSFile {
      //文件名字
      private String name;
      //文件内容
      private byte[] content;
      //文件扩展名
      private String ext;
      //文件MD5摘要值
      private String md5;
      //文件创建作者
      private String author;
      public FastDFSFile(String name, byte[] content, String ext, String height,
       String width, String author) {
      super();
      this.name = name;
      this.content = content;
      this.ext = ext;
      this.author = author;
       }
      public FastDFSFile(String name, byte[] content, String ext) {
      super();
      this.name = name;
      this.content = content;
      this.ext = ext;
       }
      public String getName() {
      return name;
       }
      public void setName(String name) {
      this.name = name;
       }
      public byte[] getContent() {
      return content;
       }
      public void setContent(byte[] content) {
      this.content = content;
       }
      public String getExt() {
      return ext;
       }
      public void setExt(String ext) {
      this.ext = ext;
       }
      public String getMd5() {
      return md5;
       }
      public void setMd5(String md5) {
      this.md5 = md5;
       }
      public String getAuthor() {
      return author;
       }
      public void setAuthor(String author) {
      this.author = author;
       }
      }
  
 

4、编写文件操作的工具类（上传、下载和删除等等操作）

      import org.csource.common.NameValuePair;
      import org.csource.fastdfs.*;
      import org.slf4j.LoggerFactory;
      import org.springframework.core.io.ClassPathResource;
      import java.io.ByteArrayInputStream;
      import java.io.IOException;
      import java.io.InputStream;
      public class FastDFSClient {
      private static org.slf4j.Logger logger = LoggerFactory.getLogger(FastDFSClient.class);
       /***
       * 初始化加载FastDFS的TrackerServer配置
       */
      static {
      try {
       String filePath = new ClassPathResource("fdfs_client.conf").getFile().getAbsolutePath();
       ClientGlobal.init(filePath);
       } catch (Exception e) {
       logger.error("FastDFS Client Init Fail!",e);
       }
       }
      /***
       * 文件上传
       * @param file
       * @return 1.文件的组名 2.文件的路径信息
       */
      public static String[] upload(FastDFSFile file) {
      //获取文件的作者
       NameValuePair[] meta_list = new NameValuePair[1];
       meta_list[0] = new NameValuePair("author", file.getAuthor());
      //接收返回数据
       String[] uploadResults = null;
       StorageClient storageClient=null;
      try {
      //创建StorageClient客户端对象
       storageClient = getTrackerClient();
      /***
       * 文件上传
       * 1)文件字节数组
       * 2)文件扩展名
       * 3)文件作者
       */
       uploadResults = storageClient.upload_file(file.getContent(), file.getExt(), meta_list);
       } catch (Exception e) {
       logger.error("Exception when uploadind the file:" + file.getName(), e);
       }
      if (uploadResults == null && storageClient!=null) {
       logger.error("upload file fail, error code:" + storageClient.getErrorCode());
       }
      //获取组名
       String groupName = uploadResults[0];
      //获取文件存储路径
       String remoteFileName = uploadResults[1];
      return uploadResults;
       }
      /***
       * 获取文件信息
       * @param groupName:组名
       * @param remoteFileName：文件存储完整名
       * @return
       */
      public static FileInfo getFile(String groupName, String remoteFileName) {
      try {
       StorageClient storageClient = getTrackerClient();
      return storageClient.get_file_info(groupName, remoteFileName);
       } catch (Exception e) {
       logger.error("Exception: Get File from Fast DFS failed", e);
       }
      return null;
       }
      /***
       * 文件下载
       * @param groupName
       * @param remoteFileName
       * @return
       */
      public static InputStream downFile(String groupName, String remoteFileName) {
      try {
      //创建StorageClient
       StorageClient storageClient = getTrackerClient();
      //下载文件
      byte[] fileByte = storageClient.download_file(groupName, remoteFileName);
       InputStream ins = new ByteArrayInputStream(fileByte);
      return ins;
       } catch (Exception e) {
       logger.error("Exception: Get File from Fast DFS failed", e);
       }
      return null;
       }
      /***
       * 文件删除
       * @param groupName
       * @param remoteFileName
       * @throws Exception
       */
      public static void deleteFile(String groupName, String remoteFileName)
      throws Exception {
      //创建StorageClient
       StorageClient storageClient = getTrackerClient();
      //删除文件
      int i = storageClient.delete_file(groupName, remoteFileName);
       }
      /***
       * 获取Storage组
       * @param groupName
       * @return
       * @throws IOException
       */
      public static StorageServer[] getStoreStorages(String groupName)
      throws IOException {
      //创建TrackerClient
       TrackerClient trackerClient = new TrackerClient();
      //获取TrackerServer
       TrackerServer trackerServer = trackerClient.getConnection();
      //获取Storage组
      return trackerClient.getStoreStorages(trackerServer, groupName);
       }
      /***
       * 获取Storage信息,IP和端口
       * @param groupName
       * @param remoteFileName
       * @return
       * @throws IOException
       */
      public static ServerInfo[] getFetchStorages(String groupName,
       String remoteFileName) throws IOException {
       TrackerClient trackerClient = new TrackerClient();
       TrackerServer trackerServer = trackerClient.getConnection();
      return trackerClient.getFetchStorages(trackerServer, groupName, remoteFileName);
       }
      /***
       * 获取Tracker服务地址
       * @return
       * @throws IOException
       */
      public static String getTrackerUrl() throws IOException {
      return "http://"+getTrackerServer().getInetSocketAddress().getHostString()+":"+ClientGlobal.getG_tracker_http_port()+"/";
       }
      /***
       * 获取Storage客户端
       * @return
       * @throws IOException
       */
      private static StorageClient getTrackerClient() throws IOException {
       TrackerServer trackerServer = getTrackerServer();
       StorageClient storageClient = new StorageClient(trackerServer, null);
      return  storageClient;
       }
      /***
       * 获取Tracker
       * @return
       * @throws IOException
       */
      private static TrackerServer getTrackerServer() throws IOException {
       TrackerClient trackerClient = new TrackerClient();
       TrackerServer trackerServer = trackerClient.getConnection();
      return  trackerServer;
       }
      }
  
 

文章来源: blog.csdn.net，作者：LookForDream_，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/LookForDream_/article/details/104521309