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

it2026-04-03 9

下面直接上方法，前段用文件流的形式，只需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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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(736031305@qq.com) * @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

转载于:https://www.cnblogs.com/jcong/p/5252642.html

相关资源：七牛云上传图片demo

最新回复(0)