Springboot集成fastDFS配置过程解析

Springboot集成fastDFS配置过程解析

配置文件

配置fdfs_client.conf配置文件

# 连接超时时间，针对socket套接字函数connect，默认为30秒

connect_timeout=30000

# 网络通讯超时时间，默认是60秒

network_timeout=60000

tracker_server = 47.98.159.15:22122

导入依赖

&lthttp://;groupId>org.csource

fastdfs-client-java

1.27-SNAPSHOT

配置客户端

package panda.data.Utils;

import org.csource.common.MyException;

import org.csource.fastdfs.*;

import org.slf4j.LoggerFactory;

import org.springframework.core.io.ClassPathResource;

import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;

import java.util.stream.Stream;

/**

* @Auther: 罗罗

* @Description:

*/

public class FastDFSClient {

private static org.slf4j.Logger logger = LoggerFactory.getLogger(FastDFSClient.class);

public static String uploadImage(MultipartFile multipartFile) throws IOException, MyException {

// 1、初始化全局配置。加载一个配置文件。

String filePath = new ClassPathResource("fdfs_client.conf").getFile().getAbsolutePath();

ClientGlobal.init(filePath);

// 2、创建一个TrackerClient对象。

TrackerClient trackerClient = new TrackerClient();

// 3、创建一个TrackerServer对象。

TrackerServer trackerServer = trackerClient.getConnection();

// 4、声明一个StorageServer对象，null。

StorageServer storageServer = null;

// 5、获得StorageClient对象。

StorageClient storageClient = new StorageClient(trackerServer, storageServer);

byte[] bytes = multipartFile.getBytes();// 获得上传的二进制对象

String[] strings = storageClient.upload_file(bytes, "jpg", null);

Stream.of(strings).forEach(System.out::println);

String imagurl = "http://47.98.159.35/"+strings[0]+"/"+strings[1];

//返回值0代表删除成功

//int result = storageClient.delete_file("group1", "M00/00/00/wKgAaFyM3fSANCgXAABMnNm0e54098.jpg");

//System.out.println("result="+result);

return imagurl;

}

}

package panda.data.controller;

import org.csource.common.MyException;

import org.springframework.beans.factory.annotation.Autowired;

import org.sprinciqNSjxKgframework.stereotype.Controller;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.ResponseBody;

import org.springframework.web.multipart.MultipartFile;

import panda.data.ResultData.ImgAttr;

import panda.data.ResultData.ResultData;

import panda.data.Utils.FastDFSClient;

import java.io.IOException;

import java.util.ArrayList;

@Controller

public class ImgControciqNSjxKller {

@Autowired

private ResultData resultData;

//必须是post方式

@PostMapping("/fileUpload")

@ResponseBody

public ResultData fileUpload(@RequestParam("file") MultipartFile multipartFile) throws IOException, MyException {

String url = FastDFSClient.uploadImage(multipartFile);

if (url.contains("group")){

resultData.setCode(0);

ImgAttr imgAttr = new ImgAttr(url);

ArrayList

list.add(imgAttr);

resultData.setData(list);

}else {

resultData.setCode(0);

resultData.setData(null);

}

return resultData;

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。