集成七牛云储存-上传图片Demo

下面直接上方法，前段用文件流的形式，只需name的名称与方法中的file相同即可。

*准备工作：
1、注册一个七牛账号，注册链接：点击注册 ，注册成功之后最好实名认证一下，每个月的流量以及空间的容量会增加很多。
2、新建一个空间，记下空间名称（bucketName）。在账号里找到密钥：AK，SK。后面开发中会用到这些。
3、下载七牛jar文件，文章最后面有下载链接。

html代码：

<input type="file" name="imgFile" />

/**
 * 图片上传工具类
 * @author jcong
 *
 */
public class UploadingImageUtils {

private static UploadManager uploadManager = new UploadManager();

/**
 * 
 * @param imgFile 图片流
 * @param imgName 图片名称
 * @param bucketName 七牛空间名称
 * @param AK,SK 七牛密钥
 */
public static String uploadingImage(MultipartFile imgFile,String imgName){
        Auth auth = Auth.create(AK,SK);
        String token = auth.uploadToken(bucketName);

        CommonsMultipartFile cf = (CommonsMultipartFile)imgFile;
        DiskFileItem fi = (DiskFileItem) cf.getFileItem();
        InputStream  inputStream = new FileInputStream(f);
byte[] byteData = IOUtils.toByteArray(inputStream);
        Response response = uploadManager.put(byteData,imgName, token);
        response.bodyString();
    }
}

---

/**
 * 对上传的图片大小进行判断
 * @param imgFile 图片流
 */

public static boolean papers(MultipartFile imgFile){
     if(imgFile=null){
         System.out.println("上传图片大小是："+imgFile1.getSize());
         if(imgFile1.getSize()<512000){
         List<String> fileTypes = new ArrayList<String>();  
            fileTypes.add("jpg");  
            fileTypes.add("jpeg");  
            fileTypes.add("png"); 
            String fileName = imgFile1.getOriginalFilename();
            //获取上传文件类型的扩展名,先得到.的位置，再截取从.的下一个位置到文件的最后，最后得到扩展名  
             String ext = fileName.substring(fileName.lastIndexOf(".")+1,fileName.length());  
             //对扩展名进行小写转换  
             ext = ext.toLowerCase();  
            if(fileTypes.contains(ext)) { //如果扩展名属于允许上传的类型，则创建文件  
                return true;
             }else{
                return false;
             }
         }else{
             return false;
         }
     }else{
         return false;
     }

}

控制层代码：

/**
 * 上传接口
 * @param demo 实体类
 */
@RequestMapping(value="/demo",method=RequestMethod.POST)
public ModelAndView Demo(MultipartHttpServletRequest req,Demo demo){
        ModelAndView mav=new ModelAndView();
//首先判断图片是否符合上传的要求（调用上面2-方法）
if(UploadImageVerify.papers(req.getFile("imgFile"))){
            System.out.println("成功！");  

//调用图片上传工具类
            String path=UploadingImageUtils.uploadingImage(demo.imgId(),req.getFile("imgFile"));
//打印上传的图片路径
            System.out.println("图片路径是："+path);
            demo.setImg(path);
        }
//将得到的图片路径写入数据库中
        jcDao.Demo(demo);
        mav.setViewName("forward:/WEB-INF/salesman/jcong.jsp");
return mav;
    }

以上即是上传图片全部代码。

---

在开发过程中，找到一个写的比较完整的类，上面没怎么看懂的朋友可以再参考一下下面的代码内容，转自：IT答案网

package com.yida.framework.base.util.qiniu;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import org.apache.commons.io.IOUtils;

import com.qiniu.common.QiniuException;
import com.qiniu.http.Response;
import com.qiniu.storage.BucketManager;
import com.qiniu.storage.UploadManager;
import com.qiniu.storage.model.DefaultPutRet;
import com.qiniu.storage.model.FileInfo;
import com.qiniu.storage.model.FileListing;
import com.qiniu.util.Auth;

/**
 * @ClassName: QiniuUtils
 * @Description: 七牛操作工具类
 * @author Lanxiaowei([e-mail])
 * @date 2015年12月8日 上午10:56:32
 * 
 */
public class QiniuUtils {
private static final String ACCESS_KEY = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
private static final String SECRET_KEY = "*******************************";
/**默认上传空间*/
private static final String BUCKET_NAME = "XXXXXXXXXXXXXXX";
/**空间默认域名*/
private static final String BUCKET_HOST_NAME = "http://xxxxxxxxxxxxxxxx.clouddn.com";

private static UploadManager uploadManager = new UploadManager();

private static int LIMIT_SIZE = 1000;
/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: listBucket
 * @Description: 返回七牛帐号的所有空间
 * @param @return
 * @param @throws QiniuException
 * @return String[]
 * @throws
 */
public static String[] listBucket() throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
return bucketManager.buckets();
}

/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: listFileOfBucket
 * @Description: 获取指定空间下的文件列表
 * @param bucketName 空间名称
 * @param prefix 文件名前缀
 * @param limit 每次迭代的长度限制，最大1000，推荐值 100[即一个批次从七牛拉多少条]
 * @param @return
 * @return List<FileInfo>
 * @throws
 */
public static List<FileInfo> listFileOfBucket(String bucketName,String prefix,int limit) {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
BucketManager.FileListIterator it = bucketManager.createFileListIterator(bucketName, prefix, limit, null);
List<FileInfo> list = new ArrayList<FileInfo>();
while (it.hasNext()) {
    FileInfo[] items = it.next();
if (null != items && items.length > 0) {
        list.addAll(Arrays.asList(items));
    }
}
return list;
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: uploadFile
 * @Description: 七牛图片上传
 * @param @param inputStream 待上传文件输入流
 * @param @param bucketName 空间名称
 * @param @param key 空间内文件的key
 * @param @param mimeType 文件的MIME类型，可选参数，不传入会自动判断
 * @param @return
 * @param @throws IOException
 * @return String
 * @throws
 */
public static String uploadFile(InputStream inputStream,String bucketName,String key,String mimeType) throws IOException {  
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
    String token = auth.uploadToken(bucketName);
byte[] byteData = IOUtils.toByteArray(inputStream);
    Response response = uploadManager.put(byteData, key, token, null, mimeType, false);
    inputStream.close();
return response.bodyString();
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: uploadFile
 * @Description: 七牛图片上传
 * @param @param inputStream 待上传文件输入流
 * @param @param bucketName 空间名称
 * @param @param key 空间内文件的key
 * @param @return
 * @param @throws IOException
 * @return String
 * @throws
 */
public static String uploadFile(InputStream inputStream,String bucketName,String key) throws IOException {  
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
    String token = auth.uploadToken(bucketName);
byte[] byteData = IOUtils.toByteArray(inputStream);
    Response response = uploadManager.put(byteData, key, token, null, null, false);
    inputStream.close();
return response.bodyString();
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: uploadFile
 * @Description: 七牛图片上传
 * @param filePath 待上传文件的硬盘路径
 * @param fileName 待上传文件的文件名
 * @param bucketName 空间名称
 * @param key 空间内文件的key
 * @param @return
 * @param @throws IOException
 * @return String
 * @throws
 */
public static String uploadFile(String filePath,String fileName,String bucketName,String key) throws IOException {  
    Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
    String token = auth.uploadToken(bucketName);
    InputStream is = new FileInputStream(new File(filePath + fileName));
byte[] byteData = IOUtils.toByteArray(is);
    Response response = uploadManager.put(byteData, (key == null || "".equals(key))? fileName : key, token);
    is.close();
return response.bodyString();
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: uploadFile
 * @Description: 七牛图片上传[若没有指定文件的key,则默认将fileName参数作为文件的key]
 * @param filePath 待上传文件的硬盘路径
 * @param fileName 待上传文件的文件名
 * @param bucketName 空间名称
 * @param @return
 * @param @throws IOException
 * @return String
 * @throws
 */
public static String uploadFile(String filePath,String fileName,String bucketName) throws IOException {  
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
    String token = auth.uploadToken(bucketName);
    InputStream is = new FileInputStream(new File(filePath + fileName));
byte[] byteData = IOUtils.toByteArray(is);
    Response response = uploadManager.put(byteData, fileName, token);
    is.close();
return response.bodyString();
}


----------


/**
 * @throws QiniuException 
 * @Author: Lanxiaowei([e-mail])
 * @Title: fetchToBucket
 * @Description: 提取网络资源并上传到七牛空间里
 * @param url 网络上一个资源文件的URL
 * @param bucketName 空间名称
 * @param key 空间内文件的key[唯一的]
 * @param @return
 * @return String
 * @throws
 */
public static String fetchToBucket(String url,String bucketName,String key) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
DefaultPutRet putret = bucketManager.fetch(url, bucketName, key);
return putret.key;
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: fetchToBucket
 * @Description: 提取网络资源并上传到七牛空间里,不指定key，则默认使用url作为文件的key
 * @param url
 * @param bucketName
 * @param @return
 * @param @throws QiniuException
 * @return String
 * @throws
 */
public static String fetchToBucket(String url,String bucketName) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
DefaultPutRet putret = bucketManager.fetch(url, bucketName);
return putret.key;
}


----------


/**
 * @throws QiniuException 
 * @Author: Lanxiaowei([e-mail])
 * @Title: copyFile
 * @Description: 七牛空间内文件复制
 * @param bucket 源空间名称
 * @param key 源空间里文件的key(唯一的)
 * @param targetBucket 目标空间
 * @param targetKey 目标空间里文件的key(唯一的)
 * @return void
 * @throws
 */
public static void copyFile(String bucket, String key, String targetBucket, String targetKey) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
bucketManager.copy(bucket, key, targetBucket, targetKey);
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: moveFile
 * @Description: 七牛空间内文件剪切
 * @param bucket 源空间名称
 * @param key 源空间里文件的key(唯一的)
 * @param targetBucket 目标空间
 * @param targetKey 目标空间里文件的key(唯一的)
 * @param @throws QiniuException
 * @return void
 * @throws
 */
public static void moveFile(String bucket, String key, String targetBucket, String targetKey) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
bucketManager.move(bucket, key, targetBucket, targetKey);
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: renameFile
 * @Description: 七牛空间内文件重命名
 * @param bucket
 * @param key
 * @param targetKey
 * @param @throws QiniuException
 * @return void
 * @throws
 */
public static void renameFile(String bucket, String key, String targetKey) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
bucketManager.rename(bucket, key, targetKey);
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: deleteFile
 * @Description: 七牛空间内文件删除
 * @param bucket 空间名称
 * @param key 空间内文件的key[唯一的]
 * @param @throws QiniuException
 * @return void
 * @throws
 */
public static void deleteFile(String bucket, String key) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
bucketManager.delete(bucket, key);
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: findFiles
 * @Description: 返回指定空间下的所有文件信息
 * @param @param bucketName 空间名称
 * @param @param prefix 文件key的前缀
 * @param @param limit 批量提取的最大数目
 * @param @return
 * @param @throws QiniuException
 * @return FileInfo[]
 * @throws
 */
public static FileInfo[] findFiles(String bucketName,String prefix,int limit) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
FileListing listing = bucketManager.listFiles(bucketName, prefix, null, limit, null);
if(listing == null || listing.items == null || listing.items.length <= 0) {
return null;
}
return listing.items;
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: findFiles
 * @Description: 返回指定空间下的所有文件信息
 * @param @param bucketName 空间名称
 * @param @param prefix 文件key的前缀
 * @param @return
 * @param @throws QiniuException
 * @return FileInfo[]
 * @throws
 */
public static FileInfo[] findFiles(String bucketName,String prefix) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
FileListing listing = bucketManager.listFiles(bucketName, prefix, null, LIMIT_SIZE, null);
if(listing == null || listing.items == null || listing.items.length <= 0) {
return null;
}
return listing.items;
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: findFiles
 * @Description: 返回指定空间下的所有文件信息
 * @param @param bucketName
 * @param @param key
 * @param @return
 * @param @throws QiniuException
 * @return FileInfo[]
 * @throws
 */
public static FileInfo[] findFiles(String bucketName) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
FileListing listing = bucketManager.listFiles(bucketName, null, null, LIMIT_SIZE, null);
if(listing == null || listing.items == null || listing.items.length <= 0) {
return null;
}
return listing.items;
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: findOneFile
 * @Description: 返回指定空间下的某个文件
 * @param @param bucketName
 * @param @param key
 * @param @param limit
 * @param @return
 * @param @throws QiniuException
 * @return FileInfo
 * @throws
 */
public static FileInfo findOneFile(String bucketName,String key,int limit) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
FileListing listing = bucketManager.listFiles(bucketName, key, null, limit, null);
if(listing == null || listing.items == null || listing.items.length <= 0) {
return null;
}
return (listing.items)[0];
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: findOneFile
 * @Description: 返回指定空间下的某个文件(重载)
 * @param @param bucketName
 * @param @param key
 * @param @return
 * @param @throws QiniuException
 * @return FileInfo
 * @throws
 */
public static FileInfo findOneFile(String bucketName,String key) throws QiniuException {
Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
BucketManager bucketManager = new BucketManager(auth);
FileListing listing = bucketManager.listFiles(bucketName, key, null, LIMIT_SIZE, null);
if(listing == null || listing.items == null || listing.items.length <= 0) {
return null;
}
return (listing.items)[0];
}


----------


/**
 * @Author: Lanxiaowei([e-mail])
 * @Title: getFileAccessUrl
 * @Description: 返回七牛空间内指定文件的访问URL
 * @param @param key
 * @param @return
 * @param @throws QiniuException
 * @return String
 * @throws
 */
public static String getFileAccessUrl(String key) throws QiniuException {
return BUCKET_HOST_NAME + "/" + key;
}

public static void main(String[] args) throws IOException {
//uploadFile("C:/test.jpg");

/*String[] buckets = listBucket();
for(String bucket : buckets) {
System.out.println(bucket);
}*/

/*List<FileInfo> list = listFileOfBucket(BUCKET_NAME, null, 1000);
for(FileInfo fileInfo : list) {
System.out.println("key：" + fileInfo.key);
System.out.println("hash：" + fileInfo.hash);
System.out.println("................");
}*/

//copyFile(BUCKET_NAME, "images-test", BUCKET_NAME, "images-test-1111");

//renameFile(BUCKET_NAME, "images-test-1111", "images-test-2222.jpg");

//deleteFile(BUCKET_NAME, "images-test-2222.jpg");

//fetchToBucket("http://www.nanrenwo.net/uploads/allimg/121026/14-1210261JJD03.jpg", BUCKET_NAME,"1111111111111111.jpg");

FileInfo[] fileInfos = findFiles(BUCKET_NAME, "10", LIMIT_SIZE);
for(FileInfo fileInfo : fileInfos) {
System.out.println(fileInfo.key);
System.out.println(fileInfo.hash);
System.out.println("..............");
}
}
}

最后，友情提醒：如果开发过程中遇到报错实在无法理解的地方。可以尝试一下更换架包文件，本人在开发过程中，用的是七牛官网下载的架包，可能是与本地的某java架包起冲突，导致上传成功却一直报错，头疼，最后找了一下版本低一点的七牛架包，问题解决。
用到的七牛架包文件：点击下载
网盘密码：ng83