Class COSImageupload

src/main/java/cn/hellohao/service/impl/COSImageupload.java:26–109

import java.util.Map;

@Service
public class COSImageupload {
    private static Logger logger = LoggerFactory.getLogger(COSImageupload.class);
    static COSClient cosClient;
    static Keys key;

    public ReturnImage ImageuploadCOS(
            Map<Map<String, String>, File> fileMap, String username, Integer keyID) {
        ReturnImage returnImage = new ReturnImage();
        File file = null;
        FileInputStream stream = null;
        try {
            for (Map.Entry<Map<String, String>, File> entry : fileMap.entrySet()) {
                String prefix = entry.getKey().get("prefix");
                String ShortUIDName = entry.getKey().get("name");
                file = entry.getValue();
                stream = new FileInputStream(file);
                try {
                    String bucketName = key.getBucketname();
                    String userkey = username + "/" + ShortUIDName + "." + prefix;
                    PutObjectRequest putObjectRequest =
                            new PutObjectRequest(bucketName, userkey, stream,null);
                    PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
                } catch (CosServiceException serverException) {
                    returnImage.setCode("400");
                    serverException.printStackTrace();
                } catch (CosClientException clientException) {
                    returnImage.setCode("400");
                    clientException.printStackTrace();
                }
                try {if(stream!=null){stream.close();}} catch (Exception ex) { }
            }
            returnImage.setCode("200");
        } catch (Exception e) {
            try {if(stream!=null){stream.close();}} catch (Exception ex) { }
            logger.error("COS协议上传时发生异常：",e);
            returnImage.setCode("500");
        }
        return returnImage;
    }

    public static Integer Initialize(Keys k) {
        int ret = -1;
        if (StringUtils.isBlank(k.getAccessKey())
                || StringUtils.isBlank(k.getAccessSecret())
                || StringUtils.isBlank(k.getEndpoint())
                || StringUtils.isBlank(k.getBucketname())
                || StringUtils.isBlank(k.getRequestAddress())) {
            return -1;
        }
        String secretId = k.getAccessKey();
        String secretKey = k.getAccessSecret();
        COSCredentials cred = new BasicCOSCredentials(secretId, secretKey);
        Region region = new Region(k.getEndpoint());
        ClientConfig clientConfig = new ClientConfig(region);
        COSClient cos = new COSClient(cred, clientConfig);
        ListObjectsRequest listObjectsRequest = new ListObjectsRequest();
        listObjectsRequest.setBucketName(k.getBucketname());