最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

springboot集成fastDfs過(guò)程代碼實(shí)例

 更新時(shí)間:2019年12月23日 09:47:05   作者:青竹玉簡(jiǎn)  
這篇文章主要介紹了springboot集成fastDfs過(guò)程代碼實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

這篇文章主要介紹了springboot集成fastDfs過(guò)程代碼實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

pom.xml  引入依賴

<dependency>
  <groupId>com.github.tobato</groupId>
  <artifactId>fastdfs-client</artifactId>
  <version>1.26.1-RELEASE</version>
</dependency>

application.properties  配置

# fastDfs配置
fdfs.connect-timeout=600
fdfs.so-timeout=1500
fdfs.trackerList=192.168.1.207:22122
fdfs.thumbImage.height=150
fdfs.thumbImage.width=150
spring.jmx.enabled=false
fdfs.pool.max-total=200
storage.resHost=http://192.168.1.207/
storage.resPort=8888

DfsAutoConfig.java  自動(dòng)注入

@Configuration
@Import(FdfsClientConfig.class)
@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
public class DfsAutoConfig {
}

DfsResConfig  配置映射關(guān)系

@Data
@Component
@ConfigurationProperties("storage")
public class DfsResConfig {
 
  private String resHost;
  private String resPort;
}F
<em id="__mceDel">FastDfsClientUtil  工具類<br></em>
@Slf4j
@Component
public class FastDfsClientUtil {
 
  @Autowired
  private FastFileStorageClient storageClient;
 
  /**
   * @Author AlanMa
   * @Description MultipartFile類型的文件上傳ַ
   * @Date 2019/11/12
   * @Param [file]
   * @return com.hiynn.data.visual.file.vo.ResultData<java.lang.String>
   */
  public ResultData<String> uploadFile(MultipartFile file){
 
    try{
      StorePath path = storageClient.uploadFile(file.getInputStream(), file.getSize(),
          FilenameUtils.getExtension(file.getOriginalFilename()), null);
      return ResultDataUtil.setSuccessResult(path.getFullPath());
    }catch (Exception e){
      e.printStackTrace();
      return ResultDataUtil.setFailedResult();
    }
 
  }
 
  /**
   * @Author AlanMa
   * @Description 普通的文件上傳
   * @Date 2019/11/12
   * @Param [file]
   * @return com.hiynn.data.visual.file.vo.ResultData<java.lang.String>
   */
  public ResultData<String> uploadFile(File file){
 
    try{
      FileInputStream inputStream = new FileInputStream(file);
      StorePath path = storageClient.uploadFile(inputStream, file.length(),
          FilenameUtils.getExtension(file.getName()), null);
      return ResultDataUtil.setSuccessResult(path.getFullPath());
    }catch (Exception e){
      e.printStackTrace();
      return ResultDataUtil.setFailedResult();
    }
  }
 
  /**
   * @Author AlanMa
   * @Description 帶輸入流形式的文件上傳
   * @Date 2019/11/12
   * @Param [is, size, fileName]
   * @return com.hiynn.data.visual.file.vo.ResultData<java.lang.String>
   */
  public ResultData<String> uploadFileStream(InputStream is, long size, String fileName) {
 
    StorePath path = storageClient.uploadFile(is, size, fileName, null);
    return ResultDataUtil.setSuccessResult(path.getFullPath());
  }
 
  /**
   * @Author AlanMa
   * @Description 將一段文本文件寫(xiě)到fastdfs的服務(wù)器上
   * @Date 2019/11/12
   * @Param [content, fileExtension]
   * @return java.lang.String
   */
  public String uploadFile(String content, String fileExtension) {
    byte[] buff = content.getBytes(Charset.forName("UTF-8"));
    ByteArrayInputStream stream = new ByteArrayInputStream(buff);
    StorePath path = storageClient.uploadFile(stream, buff.length, fileExtension, null);
    return path.getFullPath();
  }
 
  /**
   * @Author AlanMa
   * @Description 刪除文件
   * @Date 2019/11/12
   * @Param [fileUrl]
   * @return com.hiynn.data.visual.file.vo.ResultData
   */
  public ResultData deleteFile(String fileUrl) {
 
    if (StringUtils.isEmpty(fileUrl)) {
      return ResultDataUtil.setFailedResult();
    }
    try {
      StorePath storePath = StorePath.praseFromUrl(fileUrl);
      storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
      return ResultDataUtil.setSuccessResult();
    } catch (FdfsUnsupportStorePathException e) {
      e.printStackTrace();
      log.warn(e.getMessage());
      return ResultDataUtil.setFailedResult();
    }
  }
//
//  /**
//   * @Author AlanMa
//   * @Description 上傳文件圖片
//   * @Date 2019/11/12
//   * @Param [is, size, fileExtName, metaData]
//   * @return java.lang.String
//   */
//  public String upfileImage(InputStream is, long size, String fileExtName, Set<MateData> metaData) {
//    StorePath path = storageClient.uploadImageAndCrtThumbImage(is, size, fileExtName, metaData);
//    return path.getFullPath();
//  }
}

測(cè)試

@Slf4j
@RestController
@RequestMapping("/dfs")
public class FileDfsController extends BaseController {
 
  @Autowired
  private FastDfsClientUtil fastDfsClientUtil;
 
  @Autowired
  private DfsResConfig dfsResConfig;
 
  @PostMapping("/single")
  public ResultData singleUpload(@RequestParam("file") MultipartFile file){
    ResultData<String> resultData = fastDfsClientUtil.uploadFile(file);
    if (Objects.equals(ResultEnum.SUCCESS.getCode(), resultData.getCode())) {
      String url = String.format("%s:%s/%s",dfsResConfig.getResHost(),dfsResConfig.getResPort(),resultData.getData());
      return ResultDataUtil.setSuccessResult(url);
    }
    return resultData;
 
  }
}

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • RocketMQ線程池創(chuàng)建實(shí)現(xiàn)原理詳解

    RocketMQ線程池創(chuàng)建實(shí)現(xiàn)原理詳解

    這篇文章主要為大家介紹了RocketMQ線程池創(chuàng)建實(shí)現(xiàn)原理詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-12-12
  • 最新評(píng)論

    静海县| 廉江市| 五大连池市| 湛江市| 资源县| 射阳县| 固原市| 阿拉善盟| 沧源| 蓝山县| 额敏县| 苍溪县| 高淳县| 喀什市| 西充县| 华池县| 东乌珠穆沁旗| 舒兰市| 灯塔市| 长垣县| 晴隆县| 锡林郭勒盟| 波密县| 嵩明县| 汉中市| 祥云县| 丹巴县| 万山特区| 班戈县| 封开县| 万全县| 黔江区| 新泰市| 抚松县| 达日县| 京山县| 象山县| 贵德县| 舒兰市| 长阳| 崇左市|