public
class
upLoadFile {
1
public
static
String accessKey = “h9r4Vz72dIAEL2PLSYXFEv39GmUOsw99y7wkbQQW”;
public
static
String secretKey = “BWhiWbB7D-lWkI2bP2c6wBYRbak3MzmcUeoyTaNv”;
public
static
String bucket = “image-a”;
public
static
String domainOfBucket = “pn7fhqast.bkt.clouddn.com”;
public
static
void main(String[] args)
{
getUrl(“FpMjfsJwwMDYC-IXjMIhWm9xiYt4”);
}
public
static
String uploadFile(MultipartFile file) {
Configuration cfg =
new
Configuration(Zone.zone0());
UploadManager uploadManager =
new
UploadManager(cfg);
String fileName=null;
String key = null;
try
{
Logger.getLogger("start>>>>>>>>>>").info("图片上传");
byte[] uploadBytes=file.getBytes();
ByteArrayInputStream byteInputStream=
new
ByteArrayInputStream(uploadBytes);
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
Response response = uploadManager.put(byteInputStream,key,upToken,null, null);
DefaultPutRet putRet =
new
Gson().fromJson(response.bodyString(), DefaultPutRet.
class
);
System.out.println(putRet.key);
System.out.println(putRet.hash);
fileName=putRet.hash;
Logger.getLogger("
end
>>>>>>>>>>").info("图片上传");
}
catch
(QiniuException ex) {
Response r = ex.response;
System.err.println(r.toString());
}
catch
(IOException e) {
e.printStackTrace();
}
return
fileName;
}
public
static
String uploadFile(byte[] bytes) {
Configuration cfg =
new
Configuration(Zone.zone0());
UploadManager uploadManager =
new
UploadManager(cfg);
String fileName=null;
String key = null;
try
{
Logger.getLogger("start>>>>>>>>>>").info("图片上传");
byte[] uploadBytes=bytes;
ByteArrayInputStream byteInputStream=
new
ByteArrayInputStream(uploadBytes);
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
Response response = uploadManager.put(byteInputStream,key,upToken,null, null);
DefaultPutRet putRet =
new
Gson().fromJson(response.bodyString(), DefaultPutRet.
class
);
System.out.println(putRet.key);
System.out.println(putRet.hash);
fileName=putRet.hash;
Logger.getLogger("
end
>>>>>>>>>>").info("图片上传");
}
catch
(QiniuException ex) {
Response r = ex.response;
System.err.println(r.toString());
}
catch
(IOException e) {
e.printStackTrace();
}
return
fileName;
}
public
static
String upLoadByte(byte[] data) {
Configuration cfg =
new
Configuration(Zone.zone0());
UploadManager uploadManager =
new
UploadManager(cfg);
String fileName=null;
String key = null;
try
{
byte[] uploadBytes = "hello qiniu cloud".getBytes("utf-8");
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
try
{
Response response = uploadManager.put(data, key, upToken);
DefaultPutRet putRet =
new
Gson().fromJson(response.bodyString(), DefaultPutRet.
class
);
System.out.println(putRet.key);
System.out.println(putRet.hash);
fileName=putRet.hash;
}
catch
(QiniuException ex) {
Response r = ex.response;
System.err.println(r.toString());
try
{
System.err.println(r.bodyString());
}
catch
(QiniuException ex2) {
}
}
}
catch
(UnsupportedEncodingException ex) {
}
return
fileName;
}
public
static
String getUrl(String key) {
String finalUrl=null;
String fileName = key;
String encodedFileName = null;
try
{
encodedFileName = URLEncoder.encode(fileName, "utf-8");
String publicUrl = String.format("%s/%s", domainOfBucket, encodedFileName);
Auth auth = Auth.create(accessKey, secretKey);
long expireInSeconds = 10800;
finalUrl = auth.privateDownloadUrl(publicUrl, expireInSeconds);
}
catch
(UnsupportedEncodingException e) {
e.printStackTrace();
}
System.out.println(finalUrl);
return
finalUrl;
}
public
static
String getUrl1(String key) {
String finalUrl=null;
String fileName = key;
String encodedFileName = null;
try
{
encodedFileName = URLEncoder.encode(fileName, "utf-8");
String publicUrl = String.format("%s/%s", domainOfBucket, encodedFileName);
Auth auth = Auth.create(accessKey, secretKey);
long expireInSeconds = 10800;
finalUrl = auth.privateDownloadUrl(publicUrl, expireInSeconds);
}
catch
(UnsupportedEncodingException e) {
e.printStackTrace();
}
System.out.println(finalUrl);
return
finalUrl;
}
public
static
boolean deleteOnQn(String key) throws Exception {
try
{
Auth auth = Auth.create(accessKey,secretKey);
Configuration configuration =
new
Configuration(Zone.autoZone());
BucketManager bucketManager =
new
BucketManager(auth,configuration);
bucketManager.
delete
(bucket,key);
}
catch
(QiniuException e) {
e.printStackTrace();
throw
e;
}
return
true;
}