使用java操作FastDFS上传,下载,删除文件

前提条件：将源码生成为jar包,install到本地maven仓库

1.从github上down下源代码：https://github.com/happyfish100/fastdfs-client-java在myeclipse中创建maven项目,然后把解压的内容复制到maven项目中

2.你也可以直接下载我整的maven工程,解压导入myeclipse中直接使用,下载地址：http://download.csdn.net/detail/qq_34021712/9812335

执行maven install 将代码打成jar到本地maven仓库

在maven中依赖jar包

[java]view
plain copy

<!-- fastdfs上传下载图片  路径和上面的pom中对应 -->  

<dependency>  

    <groupId>org.csource.fastdfs-client-java</groupId>  

    <artifactId>fastdfs-client-java</artifactId>  

    <version>1.25</version>  

</dependency>

创建FastDFSClient类

[java]view
plain copy

import java.io.BufferedOutputStream;  

import java.io.IOException;  

import java.net.URL;  

import java.net.URLDecoder;  

import org.csource.common.MyException;  

import org.csource.common.NameValuePair;  

import org.csource.fastdfs.ClientGlobal;  

import org.csource.fastdfs.StorageClient1;  

import org.csource.fastdfs.StorageServer;  

import org.csource.fastdfs.TrackerClient;  

import org.csource.fastdfs.TrackerServer;  

public class FastDFSClient {  

    private  TrackerClient trackerClient = null;  

    private  TrackerServer trackerServer = null;  

    private  StorageServer storageServer = null;  

    private  StorageClient1 storageClient = null;  

    public FastDFSClient(String conf) throws Exception {  

        if (conf.contains("classpath:")) {  

            String path = URLDecoder.decode(getClass().getProtectionDomain().getCodeSource().getLocation().toString(),"UTF-8");   

            path=path.substring(6);  

            conf = conf.replace("classpath:",URLDecoder.decode(path,"UTF-8"));  

        }  

        ClientGlobal.init(conf);  

        trackerClient = new TrackerClient();  

        trackerServer = trackerClient.getConnection();  

        storageServer = null;  

        storageClient = new StorageClient1(trackerServer, storageServer);  

    }  

    /** 

     * 上传文件方法 

     * <p>Title: uploadFile</p> 

     * <p>Description: </p> 

     * @param fileName 文件全路径 

     * @param extName 文件扩展名，不包含（.） 

     * @param metas 文件扩展信息 

     * @return 

     * @throws Exception 

     */  

    public String uploadFile(String fileName, String extName, NameValuePair[] metas) {  

        String result=null;  

        try {  

            result = storageClient.upload_file1(fileName, extName, metas);  

        } catch (IOException e) {  

            e.printStackTrace();  

        } catch (MyException e) {  

            e.printStackTrace();  

        }  

        return result;  

    }  

    /** 

     * 上传文件,传fileName 

     * @param fileName 文件的磁盘路径名称 如：D:/image/aaa.jpg 

     * @return null为失败 

     */  

    public String uploadFile(String fileName) {  

        return uploadFile(fileName, null, null);  

    }  

    /** 

     *  

     * @param fileName 文件的磁盘路径名称 如：D:/image/aaa.jpg 

     * @param extName 文件的扩展名 如 txt jpg等 

     * @return null为失败 

     */  

    public  String uploadFile(String fileName, String extName) {  

        return uploadFile(fileName, extName, null);  

    }  

    /** 

     * 上传文件方法 

     * <p>Title: uploadFile</p> 

     * <p>Description: </p> 

     * @param fileContent 文件的内容，字节数组 

     * @param extName 文件扩展名 

     * @param metas 文件扩展信息 

     * @return 

     * @throws Exception 

     */  

    public String uploadFile(byte[] fileContent, String extName, NameValuePair[] metas) {  

        String result=null;  

        try {  

            result = storageClient.upload_file1(fileContent, extName, metas);  

        } catch (IOException e) {  

            e.printStackTrace();  

        } catch (MyException e) {  

            e.printStackTrace();  

        }  

        return result;  

    }  

    /** 

     * 上传文件 

     * @param fileContent 文件的字节数组 

     * @return null为失败 

     * @throws Exception 

     */  

    public String uploadFile(byte[] fileContent) throws Exception {  

        return uploadFile(fileContent, null, null);  

    }  

    /** 

     * 上传文件 

     * @param fileContent  文件的字节数组 

     * @param extName  文件的扩展名 如 txt  jpg png 等 

     * @return null为失败 

     */  

    public String uploadFile(byte[] fileContent, String extName) {  

        return uploadFile(fileContent, extName, null);  

    }  

    /** 

     * 文件下载到磁盘 

     * @param path 图片路径 

     * @param output 输出流 中包含要输出到磁盘的路径 

     * @return -1失败,0成功 

     */  

    public int download_file(String path,BufferedOutputStream output) {  

        //byte[] b = storageClient.download_file(group, path);  

        int result=-1;  

        try {  

            byte[] b = storageClient.download_file1(path);  

                try{  

                    if(b != null){  

                        output.write(b);  

                        result=0;  

                    }  

                }catch (Exception e){} //用户可能取消了下载  

                finally {  

                    if (output != null)  

                        try {  

                            output.close();  

                        } catch (IOException e) {  

                            e.printStackTrace();  

                        }  

            }  

        } catch (Exception e) {  

            e.printStackTrace();  

        }  

        return result;  

    }  

    /** 

     * 获取文件数组 

     * @param path 文件的路径 如group1/M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg 

     * @return 

     */  

    public byte[] download_bytes(String path) {  

        byte[] b=null;  

        try {  

            b = storageClient.download_file1(path);  

        } catch (IOException e) {  

            e.printStackTrace();  

        } catch (MyException e) {  

            e.printStackTrace();  

        }  

        return b;  

    }  

    /** 

     * 删除文件 

     * @param group 组名 如：group1 

     * @param storagePath 不带组名的路径名称 如：M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg 

     * @return -1失败,0成功 

     */  

    public Integer delete_file(String group ,String storagePath){  

        int result=-1;  

        try {  

            result = storageClient.delete_file(group, storagePath);  

        } catch (IOException e) {  

            e.printStackTrace();  

        } catch (MyException e) {  

            e.printStackTrace();  

        }  

         return  result;  

    }  

    /** 

     *  

     * @param storagePath  文件的全部路径 如：group1/M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg 

     * @return -1失败,0成功 

     * @throws IOException 

     * @throws Exception 

     */  

    public Integer delete_file(String storagePath){  

        int result=-1;  

        try {  

            result = storageClient.delete_file1(storagePath);  

        } catch (IOException e) {  

            e.printStackTrace();  

        } catch (MyException e) {  

            e.printStackTrace();  

        }  

        return  result;  

    }  

}

创建Test测试类

[java]view
plain copy

package com.taotao.controller;  

import java.util.List;  

import org.csource.fastdfs.ClientGlobal;  

import org.csource.fastdfs.StorageClient;  

import org.csource.fastdfs.StorageServer;  

import org.csource.fastdfs.TrackerClient;  

import org.csource.fastdfs.TrackerServer;  

import org.springframework.context.ApplicationContext;  

import org.springframework.context.support.ClassPathXmlApplicationContext;  

import com.github.pagehelper.PageHelper;  

import com.github.pagehelper.PageInfo;  

import com.taotao.common.util.FastDFSClient;  

import com.taotao.mapper.TbItemMapper;  

import com.taotao.pojo.TbItem;  

import com.taotao.pojo.TbItemExample;  

public class Test {  

    /*@org.junit.Test 

    public void testPageHelper(){ 

        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml"); 

        TbItemMapper tbItemMapper = applicationContext.getBean(TbItemMapper.class); 

        //执行查询，并分页 

                TbItemExample example = new TbItemExample(); 

                //分页处理 

                PageHelper.startPage(2, 10); 

                List<TbItem> list = tbItemMapper.selectByExample(example); 

                //取商品列表 

                for (TbItem tbItem : list) { 

                    System.out.println(tbItem.getTitle()); 

                } 

                //取分页信息 

                PageInfo<TbItem> pageInfo = new PageInfo<>(list); 

                long total = pageInfo.getTotal(); 

                System.out.println("共有商品："+ total); 

    } 

    @org.junit.Test 

    public void testUpload() throws Exception { 

        // 1、把FastDFS提供的jar包添加到工程中 

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

                ClientGlobal.init("D:\\MyEclipse2\\taotao-manager\\taotao-manager-web\\src\\main\\resources\\properties\\fastdfs-client.conf"); 

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

                TrackerClient trackerClient = new TrackerClient(); 

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

                TrackerServer trackerServer = trackerClient.getConnection(); 

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

                StorageServer storageServer = null; 

                // 6、获得StorageClient对象。 

                StorageClient storageClient = new StorageClient(trackerServer, storageServer); 

                // 7、直接调用StorageClient对象方法上传文件即可。 

                String[] strings = storageClient.upload_file("D:\\image\\aaa.jpg", "jpg", null); 

                for (String string : strings) { 

                    System.out.println(string); 

                } 

    }*/  

    /** 

     * 测试上传 

     * @throws Exception 

     */  

    @org.junit.Test  

    public void testFastDfsClient() throws Exception {  

        FastDFSClient client = new FastDFSClient("D:\\MyEclipse2\\taotao-manager\\taotao-manager-web\\src\\main\\resources\\properties\\fastdfs-client.conf");  

        String uploadFile = client.uploadFile("D:\\image\\aaa.jpg", "jpg");  

        System.out.println(uploadFile);  

    }  

    /** 

     * 测试删除 

     * @throws Exception 

     */  

    @org.junit.Test  

    public void testFastDfsClientDelete() throws Exception {  

        FastDFSClient client = new FastDFSClient("D:\\MyEclipse2\\taotao-manager\\taotao-manager-web\\src\\main\\resources\\properties\\fastdfs-client.conf");  

        //String uploadFile = client.uploadFile("D:\\image\\aaa.jpg", "jpg");  

        //Integer delete_file = client.delete_file("group1","M00/00/00/wKgRsVjtwg-ACOlSAAAweEAzRjw844.jpg");  

        Integer delete_file = client.delete_file("group1/M00/00/00/wKgRsVjtyWqAdpG9AAAweEAzRjw047.jpg");  

        System.out.println(delete_file);  

    }  

}

查看全文
如若内容造成侵权/违法违规/事实不符，请联系编程学习网邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！

Mybatis入门级教程
回顾：Jdbc开发步骤： ORM[对象关系映射Object Realation Mapping] 1)加载数据库驱动 2)通过DriverManager获取数据库连接 3)通过Connection获取Statement/PreparedStatement对象或其子对象 4)将SQL语句绑定到 Statement/PreparedStatement中，准备向数据库发送SQL语句 5)…...
2024/4/21 11:38:35
【前端JS】js 转换 Long 格式时间为 Date 格式时间
开发的时候碰到这么个需求，传到页面的时间值是 Long 格式，但是页面需要显示出来的格式需要是 yyyy-MM-dd 的 Date 时间，本来觉得像服务器端一样直接用 SimpleDateFormat 就可以了，但是页面提示没有 js 这个类，用 import="java.text.SimpleDateFormat" 也不行，好…...
2024/4/21 11:38:34
Linux下的小游戏集锦
最近实在是无聊得可以，有点怀念幻想游戏里面那些小游戏了，但是现在没windows了，想玩也只能在Linux上找找小游戏来玩玩了。继前段时间弄了两个Tux为主角的游戏，最近又挖掘了几个好玩的小游戏，记录下来大家分享分享。这俩个是原来的两个游戏的链接。安装Linux版超级马里奥…...
2024/4/20 16:59:14
mybatis简单入门和介绍 mybatis教程
Mybatis简介MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 J…...
2024/4/20 16:59:12
Android源码和内核下载编译流程
原文地址：点击查看概述为了深入学习Android系统源码，我们需要下载Android官方的最新源码进行阅读学习，这篇文章我们来总结一下在Ubuntu系统中Android官方源码的下载和编译流程通过本文可以了解：Ubuntu系统中Android编译环境配置下载和编译Android源码下载和编译Android内核…...
2024/4/20 16:59:10
Numeral介绍 - 格式化和操作数字的 JavaScript 库
基本介绍：Numeral.js 是一个用于格式化和操作数字的 JavaScript 库。数字可以格式化为货币，百分比，时间，甚至是小数，千位，和缩写格式，功能十分强大。支持包括中文在内的17种语言。引入numeral：浏览器中： <script src="numeral.min.js"></script>…...
2024/4/20 16:59:10
手机用户对手机游戏的偏好调查
关于“手机用户对手机游戏的偏好调查”成果报告背景：目前手机上可以运行的手机游戏可谓琳琅满目，说那是大多数游戏只能得到用户一段时间的青睐，很多游戏应用也就仅仅只有几个月的热度，虽然大部分手机手机游戏最终都难逃被淘汰的命运，但是对于程序员来说，为了最大程度上延…...
2024/4/20 16:59:09
加密算法之BLOWFISH算法(2)
二、BlowFishs CrackMe1分析由于该CrackMe主要是测试你的密码学知识，所以没有在其他方面设关卡。为了减小文件体积，缩短大家下载的时间，用upx加了壳，直接用Trw2000的"PNewSec+Makepe"很方便地就能脱掉壳。用常规的方法，很快找到下面关键比较处： :004015D9 5…...
2024/4/20 16:59:07
Mybatis 入门教程
第一章 mybatis架构 1.1 mybatis介绍 1.2 mybatis架构 1.3 mybatis开发dao的方法第二章 mybatis入门程序 2.1 需求 2.2 导入jar包 2.3 log4j.properties(共用文件) 2.4 SqlMapConfig.xml(公用文件) 2.5 根据id查询用户 2.5.1 pojo(User.java) 2.5.2 User.xml 2.5.3 编码2.6 根…...
2024/4/20 16:59:06
js时间戳格式化成日期格式
原文：http://www.sufeinet.com/thread-1500-1-1.html js需要把时间戳转为为普通格式，一般的情况下可能用不到的，下面先来看第一种吧function getLocalTime(nS) { return new Date(parseInt(nS) * 1000).toLocaleString().replace(/:\d{1,2}$/, ); } alert(get…...
2024/4/20 16:59:05
极客爱情 2.2 | 程序员是这样追女生的
前情回顾：极客爱情 2.1| 从你的编程世界路过（点击阅读原文查看）◆ 01前一阵儿“分答”和“值乎”一阵风靡，某人虽执拗于他那“胡建人”的“飘准”的普通话，却也紧跟潮流去开通了它们。假装头号粉丝的我去提了第一个问题：“你究竟有多少个女神？”某人望望提出问题后瞪着一…...
2024/4/21 11:38:33
MyBatis简明教程-手把手教你配环境-maven+idea
MyBatis中文官方文档什么是 MyBatis？ MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生类型、接口和 Java 的 POJO（Plain Ol…...
2024/4/21 11:38:32
一个群聚(鱼群)AI插件基于虚幻4(有现成打包好的试玩demo, 源码在GitHub)
Flock-AI-Fish-Unreal-PluginA fish flock AI Plugin for Unreal Engine 4一个基于虚幻4的鱼群 AI 插件 this Plugin version can Run 2000+ fishes at the same time这个插件版本可以同时运行 2000+ 条鱼儿Relevant LinksWatch the Video Preview查看视频演示 Download MyFis…...
2024/4/21 11:38:30
js如何在日期格式化，时间分钟描述月份日期等小于10情况下，加个0
转自http://www.monkeyblog.cn/2017/03/06/01-27/function num(s) {return s < 10 ? 0 + s: s; }例子function num(s) {return s < 10 ? 0 + s: s; } function GetDateStr(AddDayCount) { var dd = new Date(); dd.setDate(dd.getDate()+AddDayCount);//获取AddDayCoun…...
2024/4/27 21:31:45
phpmyadmin 下载、安装、配置
phpmyadmin 下载、安装、配置地址：https://www.phpmyadmin.net/点击右上角下载按钮下载得到phpMyAdmin-4.7.0-all-languages.zip解压到C盘根目录下，重命名为phpMyAdmin，进入该文件夹，找到config.sample.inc.php，改名为config.inc.php，用文本编辑器打开改文件。找到下列代…...
2024/4/21 11:38:29
MyBatis 菜鸟教程 1 环境配置
MyBatisMyBatis 本是apache的一个开源项目iBatis, 2010年这个项目由apache software foundation 迁移到了google code，并且改名为MyBatis 。2013年11月迁移到Github。 iBATIS一词来源于“internet”和“abatis”的组合，是一个基于Java的持久层框架。iBATIS提供的持久层框架包…...
2024/4/21 11:38:28
MyBatis教程目录
MyBatis教程目录 2017-10-18 摘自 YSOcean MyBatis教程目录：1 mybatis 详解（一）------JDBC 2 mybatis 详解（二）------入门实例（基于XML） 3 mybatis 详解（三）------入门实例（基于注解） 4 mybatis 详解（四）------properties以及别名定义 5 mybatis 详解（五）…...
2024/4/21 11:38:26
js格式化格林威治时间
格式化时间：Sat Aug 05 00:00:00 CST 2017 //定义一个函数 function fermitTime(time){var now = new Date(time);var year = now.getFullYear();var mon = now.getMonth()+1;var date= now.getDate();if(mon<10){mon = 0+mon;};if(date<10){date = 0+date;}var postDat…...
2024/4/21 11:38:25
IDEA Springboot 整合Mybatis 完整教程系列 06
06 总结以上五篇文章，就是利用IDEA环境下，springboot+mybatis编写的一个登录注册小Demo，过程很简单，整个框架也比较清晰简洁，其他复杂的功能也可以按照这个思路来写。虽然内容较少，但是自己在动手搭建环境的时候，还是有很多问题，网上找的教程也是不全的，有些细节没说清…...
2024/4/21 11:38:25
【菜鸟教程】小白接触白鹭引擎4天，成功做了一款足球小游戏
写在前面：随着越来越多的新人开始接触白鹭引擎，创作属于自己的游戏。考虑到初学者会遇到一些实际操作问题，我们近期整理推出“菜鸟”系列技术文档，以便更好的让这些开发者们快速上手，Egret大神们可以自动忽略此类内容。本文的作者是白鹭技术支持“熊猫少女”，看文的小伙伴…...
2024/4/21 11:38:24

使用java操作FastDFS上传,下载,删除文件

相关文章

最新文章