Java 实现七牛云回调

女爷i 2022-06-17 12:48 212阅读 0赞

有这样一个需求：android将文件上传到七牛云，并将文件在七牛云存储的信息返回业务服务器处理。七牛云的sdk上有一个模型解决这种需求，这是原理图：

![这里写图片描述][SouthEast]

然而不幸的是，关于回调上传的demo一直找不到，经过一天的折腾，整理了一个demo。大体流程是这样子的：  
1、android向业务服务器请求上传凭证，服务端代码如下

public class QiniuUtil {  
    
        //设置需要操作的账号的AK和SK
        public static final String ACCESS_KEY = "...";   
        public static final String SECRET_KEY = "...";  
        //要上传的空间 
        public static final String BUCKET = "..."; //对应要上传到七牛上 你的那个路径（自己建文件夹 注意设置公开） 
    
    }

@RequestMapping("getToken")
        public @ResponseBody GetTokenResponse getToken() {
            Auth auth = Auth.create(QiniuUtil.ACCESS_KEY, QiniuUtil.SECRET_KEY);
            StringMap putPolicy = new StringMap();
            //设置回调地址
            putPolicy.put("callbackUrl", ".../callback");
            //设置回调参数,android最终从七牛云得到的数据的格式就是这里设置的回调参数
            putPolicy.put("callbackBody", "{\"mimeType\":\"$(mimeType)\",\"key\":\"$(key)\",\"hash\":\"$(etag)\",\"bucket\":\"$(bucket)\",\"fsize\":$(fsize)}");
            //设置回调返回类型
            putPolicy.put("callbackBodyType", "application/json");
            //设置超时
            long expireSeconds = 3600;
            //生成具有服务端授权的凭证
            String upToken = auth.uploadToken(QiniuUtil.BUCKET, null, expireSeconds, putPolicy);
            //getTokenResponse 类是我自己封装的返回类型，根据实际需求而定。总之把upToken 返回去就行
            GetTokenResponse getTokenResponse = new GetTokenResponse();
            getTokenResponse.setResult(0);
            getTokenResponse.setToken(upToken);
            getTokenResponse.setMsg("success");
            return getTokenResponse;
        }

2.当android向七牛云上传文件后，七牛云将回调参数以byte\[\]形式返回给上面定义的callbackUrl，所以服务端有个处理回调方法。

@RequestMapping("callback")
        public @ResponseBody Upload callback(HttpServletRequest request) {
            /* * 这两个参数就是在定义PutPolicy参数时指定的内容 */
            //回调地址
            String callbackUrl = ".../callback";
            //定义回调内容的组织格式
            //String callbackBodyType = "application/x-www-form-urlencoded";
            String callbackBodyType = "application/json";
            /** * 这两个参数根据实际所使用的HTTP框架进行获取 */
            //通过获取请求的HTTP头部Authorization字段获得
            String callbackAuthHeader = request.getHeader("Authorization");
            //通过读取回调POST请求体获得，不要设置为null
            byte[] callbackBody = new byte[1024];
            try {
                //这里是最重要的，接收byte[]
                request.getInputStream().read(callbackBody);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            //将byte[]转化为字符串
            String callbackBodyStr = new String(callbackBody);
            Auth auth = Auth.create(QiniuUtil.ACCESS_KEY, QiniuUtil.SECRET_KEY);
            //检查是否为七牛合法的回调请求
            boolean validCallback = auth.isValidCallback(callbackAuthHeader, callbackUrl, callbackBody, callbackBodyType);
            if (validCallback) {
                //继续处理其他业务逻辑
            } else {
                //这是哪里的请求，被劫持，篡改了吧？
            }
            //将字符串转化为json对象
            JSONObject obj = JSONObject.fromObject(callbackBodyStr);
            //下面也是根据自己的需要封装的类
            Upload upload = new Upload();
            upload.setFilekey(obj.get("key")+"");
            upload.setFilehash(obj.get("hash")+"");
            upload.setFilesize(obj.get("fsize")+"");
            upload.setBucket(obj.get("bucket")+"");
            upload.setMimetype(obj.get("mimeType")+"");
            upload.setUrl(callbackBodyStr);
            return upload;
        }

3.注意事项  
(1)callbackUrl 的地址就是服务端处理callback方法的访问路径  
(2)七牛云返回的是byte\[\]，用request.getInputStream().read(callbackBody);

[SouthEast]: /images/20220617/2ac28330269b44a1b742151150bc2ca2.png