七牛的CDN部分JAVA使用介绍

2024-03-13 05:58

本文主要是介绍七牛的CDN部分JAVA使用介绍,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

原文地址:http://www.cnblogs.com/weikongziqu/p/5003003.html

本文针对于qiniu的javaSDK使用教程进行编写并测试,仅测试部分功能。

1,因为最近要用到cdn,正好之前注册过七牛,所以研究了一下。

2,使用前提:七牛账户。

3,七牛的开发者中心提供了非常详细的api文档,具体请参考Java SDK使用指南

4,下载相关包qiniu-java-sdk-7、Google Gson 、okhttp (JDK1.7 及以上) 、okio (JDK1.7 及以上)、okhttp-jdk1.6 、okio-jdk1.6(我直接从官网拷过来的链接)

5,获取Access Key 和 Secret Key

 

正式开始

一,上传

  上传主要分为两步:

  1. 业务服务器颁发 uptoken(上传授权凭证)给客户端(终端用户)
  2. 客户端凭借 uptoken 上传文件到七牛

  先介绍获取token下面的代码是获取token的一个方法,通过传入相关参数即可获取token。官网上还提供了几种简单的方法,根据需要进行选择,这里我用的是参数最全的一个。  

复制代码
 1     /**
 2      * 生成上传token
 3      *
 4      * @param bucket
 5      *            空间名
 6      * @param key
 7      *            key,可为 null 
 8      * @param expires
 9      *            有效时长,单位秒。默认3600s
10      * @param policy
11      *            上传策略的其它参数,如 new StringMap().put("endUser",
12      *            "uid").putNotEmpty("returnBody", "")。 scope通过
13      *            bucket、key间接设置,deadline 通过 expires 间接设置 (此处的设置会影响下面的文件上传时返回的参数14      * @param strict
15      *            是否去除非限定的策略字段,默认true
16      * @return 生成的上传token
17      */
18     public String uploadToken(String bucket, String key, long expires, StringMap policy, boolean strict) {
19 
20         return auth.uploadToken(bucket, key, expires, policy, strict);
21 
22     }
复制代码

  下面是上传文件

  这个是原方法

  

复制代码
/*** 上传数据** @param data     上传的数据 byte[]、File、filePath* @param key      上传数据保存的文件名* @param token    上传凭证* @param params   自定义参数,如 params.put("x:foo", "foo")* @param mime     指定文件mimetype* @param checkCrc 是否验证crc32* @return 返回参数JSON类型* @throws QiniuException*/
public Response put(XXXX data, String key, String token, StringMap params,String mime, boolean checkCrc) throws QiniuException
复制代码

 

  使用的话先实例化UploadManager

UploadManager uploadManager = new UploadManager();

  然后调用即可,下面是我封装的一个简单的方法

  

复制代码
    /***  上传图片* @param file* @param fileName*/private void upload(File file,String fileName) {try {Response res = uploadManager.put(file, fileName, token);// Map m2 = res.jsonToObject(Map.class);// Map<String, Object> m3 = res.jsonToObject(Map.class);Map<String, Object> m4 = res.jsonToObject(HashMap.class);
//             StringMap m1 = res.jsonToMap();
System.out.println(m4.get("key"));System.out.println(m4.get("hash"));System.out.println(m4.get("width"));System.out.println(m4.get("height"));System.out.println(res);System.out.println(res.bodyString());} catch (QiniuException e) {Response r = e.response;// 请求失败时简单状态信息
            System.out.println(r.toString());try {// 响应的文本信息
                System.out.println(r.bodyString());} catch (QiniuException e1) {// ignore
            }}}
复制代码

  运行后返回的参数为

复制代码
1448699528661.png    //key
FtAbKp8pY3gIoEIdsgrMdmiVTuUi  //hash
500.0                         //width
531.0                         //height
{ResponseInfo:com.qiniu.http.Response@d86cae,status:200, reqId:giUAAOpSzwWM0BoU, xlog:s.ph;s.put.tw;s.put.tr:1;s.put.tw;s.put.tr:2;s.ph;s.put.tw;s.put.tr:2;s.ph;PFDS:2;PFDS:3;PFDS:4;rs16_8.sel/not found;rs15_8.sel/not found;rdb.g/no such key;DBD/404;v4.get/Document not found;rs16_8.ins;qtbl.ins:2;mc.s;RS:2;rs.put:3;rs-upload.putFile:9;FOPAGENT;IMAGE:2;FOPAGENT:3;FOPAGENT;IMAGE:2;FOPAGENT:3;FOPG:4;FOPAGENT;UP:21, xvia:, adress:up.qiniu.com/101.71.89.200:80, duration:0.000000 s, error:null}  //res

{"key": "1448699528661.png", "hash": "FtAbKp8pY3gIoEIdsgrMdmiVTuUi", "width": 500, "height": 531}   //res.bodyString()
复制代码

  这里的返回参数全是由最前面的putPolicy定义的,我是这样子定义的

private final static StringMap policy = new StringMap().putNotEmpty("returnBody","{\"key\": $(key), \"hash\": $(etag), \"width\": $(imageInfo.width), \"height\": $(imageInfo.height)}");
//我是仅用于上传图片才这样定义的

  这里有个putPolicy详细介绍

  

二,文件操作

    根据前缀获取空间文件列表,文件名设置为空的话是全部获取

复制代码
    /*** 根据前缀获取文件列表的迭代器** @param bucket    空间名* @param prefix    文件名前缀* @param limit     每次迭代的长度限制,最大1000,推荐值 100* @param delimiter 指定目录分隔符,列出所有公共前缀(模拟列出目录效果)。缺省值为空字符串* @return FileInfo迭代器*///    BucketManager.FileListIterator it = bucketManager.createFileListIterator(bucket, prefix)public void fileList(String prefix){BucketManager.FileListIterator it = bm.createFileListIterator(bucket, prefix, 100, null);System.out.println(it.toString());while (it.hasNext()) {FileInfo[] items = it.next();System.out.println(items.length);for (int i = 0; i < items.length; i++) {System.out.println(items[i].key+"---"+items[i].hash);}}}
复制代码

  抓取资源

  这个功能非常好,而且方法很简单。

//要求url可公网正常访问,不指定 key 时以文件的 hash 值为 key
bucketManager.fetch(url, bucket);//要求url可公网正常访问
bucketManager.fetch(url, bucket, key);

三,生成私有空间的文件外链

  私有空间才需要这一步

  找到链接

   我们需要先上找到这个链接,或者去也能找到,但是比较麻烦,不过第二种可以进行校验一会我们生成的url是否正确。

  开始构造链接。

//java默认的getTime()是获取的毫秒数,我们需要将其转换成功秒,然后保存时间为5min        
String time = ""+(new Date().getTime()/1000+5*60);//e指的是过期时间。Unix时间戳        
String url = "http://xx.xx.xx.x.clouddn.com/"+fileName+"?e="+time;

  对上一步得到的url进行HMAC-SHA1签名,并对结果做URL安全的Base64编码:

  进行签名我是参考Java加密技术,进行加密

  

复制代码
class HMACSHA1 {  private static final String MAC_NAME = "HmacSHA1";    private static final String ENCODING = "UTF-8";    /**  * 使用 HMAC-SHA1 签名方法对encryptText进行签名  * @param encryptText 被签名的字符串  * @param encryptKey  密钥  * @return  * @throws Exception  */    public String HmacSHA1Encrypt(String encryptText, String encryptKey) throws Exception     {           byte[] data=encryptKey.getBytes(ENCODING);  //根据给定的字节数组构造一个密钥,第二参数指定一个密钥算法的名称  SecretKey secretKey = new SecretKeySpec(data, MAC_NAME);   //生成一个指定 Mac 算法 的 Mac 对象  Mac mac = Mac.getInstance(MAC_NAME);   //用给定密钥初始化 Mac 对象  
        mac.init(secretKey);    byte[] text = encryptText.getBytes(ENCODING);    //完成 Mac 操作   byte[] ft = mac.doFinal(text);    //这里的Base64.Default换成Url_safereturn Base64.encodeToString(ft, Base64.URL_SAFE);}  } 
复制代码

  使用

复制代码
HMACSHA1 h = new HMACSHA1();String rk = null;try {//这里的sk为七牛给你的secretKeyrk = h.HmacSHA1Encrypt(url, SK);} catch (Exception e) {// TODO Auto-generated catch block
            e.printStackTrace();}
复制代码

  将AccessKey与上一步计算得到的结果以“:”连接起来:

//这里的ak为accessKey
url = url+"&token="+AK+":"+rk;

  这样就生成了生命周期为5分钟的链接。

四,结束

  折腾了几个小时测试了部分方法,其实官网给的方法已经非常全面的,我也没有测试全面,只是简单的几个例程。

这篇关于七牛的CDN部分JAVA使用介绍的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/803844

相关文章

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED(默认)2.2 SUPPORTS2

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》:本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压:数据存储与传输的优化核心1. zip/unzip:通用压缩格式的便捷操作2.

java中新生代和老生代的关系说明

《java中新生代和老生代的关系说明》:本文主要介绍java中新生代和老生代的关系说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、内存区域划分新生代老年代二、对象生命周期与晋升流程三、新生代与老年代的协作机制1. 跨代引用处理2. 动态年龄判定3. 空间分

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》:本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器(Iterator)1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一

Java内存分配与JVM参数详解(推荐)

《Java内存分配与JVM参数详解(推荐)》本文详解JVM内存结构与参数调整,涵盖堆分代、元空间、GC选择及优化策略,帮助开发者提升性能、避免内存泄漏,本文给大家介绍Java内存分配与JVM参数详解,... 目录引言JVM内存结构JVM参数概述堆内存分配年轻代与老年代调整堆内存大小调整年轻代与老年代比例元空

深度解析Java DTO(最新推荐)

《深度解析JavaDTO(最新推荐)》DTO(DataTransferObject)是一种用于在不同层(如Controller层、Service层)之间传输数据的对象设计模式,其核心目的是封装数据,... 目录一、什么是DTO?DTO的核心特点:二、为什么需要DTO?(对比Entity)三、实际应用场景解析

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言(assert):从原理到实战引言:为什么需要断言?一、断言基础1.1 语