zoukankan      html  css  js  c++  java
  • fastdfs-client-java工具类封装

    FastDFS是通过StorageClient来执行上传操作的

    通过看源码我们知道,FastDFS有两个StorageClient工具类。

    StorageClient的上传方法upload_file(...)返回的是字符串数组String[],

    如[group1,M00/00/00/wKgAb1dBK2iANrayAA1rIuRd3Es112.jpg]

    StorageClient1的上传方法upload_file(...)返回的是字符串数组String,

    如group1/M00/00/00/wKgAb1dBK2iANrayAA1rIuRd3Es112.jpg,也就是已经帮我们拼接好了

    所以使用StorageClient1的上传方法更方便,不用我们自己拼接了。

    FastDFSClient
    复制代码
    public class FastDFSClient {
        private TrackerClient trackerClient = null;
        private TrackerServer trackerServer = null;
        private StorageServer storageServer = null;
        //使用StorageClient1进行上传
        private StorageClient1 storageClient1 = null;

        public FastDFSClient(String conf) throws Exception {
            //获取classpath路径下配置文件"fdfs_client.conf"的路径
            //conf直接写相对于classpath的位置,不需要写classpath:
            String configPath = this.getClass().getClassLoader().getResource(conf).getFile();
            System.out.println(configPath);
            ClientGlobal.init(configPath);

            trackerClient = new TrackerClient();
            trackerServer = trackerClient.getConnection();
            storageServer = trackerClient.getStoreStorage(trackerServer);
            storageClient1 = new StorageClient1(trackerServer, storageServer);
        }

        public String uploadFile(byte[] file_buff, String file_ext_name) throws Exception {

            String result = storageClient1.upload_file1(file_buff, file_ext_name, null);

            return result;
        }

        public String uploadFile(String local_filename, String file_ext_name) throws Exception {

            String result = storageClient1.upload_file1(local_filename, file_ext_name, null);

            return result;
        }
    }

    测试

     
    public class FastDFSTest {
        public static void main(String[] args) throws Exception {
            //不要带classpath
            FastDFSClient client = new FastDFSClient("properties/fdfs_client.conf");
            String result = client.uploadFile("C:\Users\Public\Pictures\Sample Pictures\Chrysanthemum.jpg", "jpg");
            System.out.println(result);
        }
    }


                                                                                            

    在项目中,图片上传的实现

    Service层

    复制代码
    @Service
    public class PictureServiceImpl implements PictureService {
    
        //将需要拼接的ip地址写在配置文件中,交给spring管理
        @Value("${IAMGE_SERVER_BASE_UEL}")
        private String IAMGE_SERVER_BASE_UEL;
    
        @Override
        public PictureResult uploadPic(MultipartFile picFile) {
    
            PictureResult result = new PictureResult();
    
            //判断图片是否为空
            if (picFile.isEmpty()) {
                result.setError(1);
                result.setMessage("图片为空");
                return result;
            }
            //上传到图片服务器
            try {
                //获取图片扩展名
                String originalFilename = picFile.getOriginalFilename();
                //取扩展名,不要"."
                String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
                FastDFSClient client = new FastDFSClient("properties/fdfs_client.conf");
                String url = client.uploadFile(picFile.getBytes(), extName);
    
                //拼接图片服务器的ip的地址(写配置文件中)
                url = IAMGE_SERVER_BASE_UEL + url;
    
                //把url响应给客户端
                result.setError(0);
                result.setUrl(url);
    
            } catch (Exception e) {
                e.printStackTrace();
                result.setError(1);
                result.setMessage("图片上传失败");
            }
            return result;
        }
    }
    复制代码

    表现层

    复制代码
    @Controller
    public class PictureController {
    
        @Autowired
        PictureService pictureService;
    
        @RequestMapping("/pic/upload")
        @ResponseBody
        public PictureResult uploadFile(MultipartFile uploadFile){
            PictureResult result = pictureService.uploadPic(uploadFile);
            return result;
        }
    }
    复制代码

    经测试发现,chrome可以正常上传,但是firefox不能,说明兼容性有问题

    这就要求我们将返回的数据转换成一个字符串文本,浏览器对字符串的兼容性最好、

    封装一个工具类

    JsonUtils
    复制代码
    import java.util.List;
    
    import com.fasterxml.jackson.core.JsonProcessingException;
    import com.fasterxml.jackson.databind.JavaType;
    import com.fasterxml.jackson.databind.ObjectMapper;
    
    public class JsonUtils {
    
        // 定义jackson对象
        private static final ObjectMapper MAPPER = new ObjectMapper();
    
        /**
         * 将对象转换成json字符串。
         */
        public static String objectToJson(Object data) {
            try {
                String string = MAPPER.writeValueAsString(data);
                return string;
            } catch (JsonProcessingException e) {
                e.printStackTrace();
            }
            return null;
        }
    
        /**
         * 将json结果集转化为对象
         */
        public static <T> T jsonToPojo(String jsonData, Class<T> beanType) {
            try {
                T t = MAPPER.readValue(jsonData, beanType);
                return t;
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
    
        /**
         * 将json数据转换成pojo对象list
         */
        public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) {
            JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType);
            try {
                List<T> list = MAPPER.readValue(jsonData, javaType);
                return list;
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            return null;
        }
    
    }
    复制代码

    修改后的controller

    复制代码
    @Controller
    public class PictureController {
    
        @Autowired
        PictureService pictureService;
    
        @RequestMapping("/pic/upload")
        @ResponseBody
        public String uploadFile(MultipartFile uploadFile){
            PictureResult result = pictureService.uploadPic(uploadFile);
            //需要把java对象转换成json数据
            String json = JsonUtils.objectToJson(result);
            return json;
        }
    }
    复制代码

      
  • 相关阅读:
    作业5

    Linux系统管理4
    作业
    递归训练1:在两个长度相等的排序数组中找到上中位数
    LeetCode:面试题 08.05. 递归乘法
    LeetCode:面试题 08.06. 汉诺塔问题
    LeetCode:22. 括号生成
    如何仅用递归函数和栈操作逆序一个栈
    LeetCode:面试题 03.02. 栈的最小值
  • 原文地址:https://www.cnblogs.com/jx17/p/6233984.html
Copyright © 2011-2022 走看看