Class OSSImageupload

src/main/java/cn/hellohao/service/impl/OSSImageupload.java:22–97

import java.util.Map;

@Service
public class OSSImageupload {
    private static Logger logger = LoggerFactory.getLogger(OSSImageupload.class);
    static OSS ossClient;
    static Keys key;

    public ReturnImage ImageuploadOSS(
            Map<Map<String, String>, File> fileMap, String username, Integer keyID) {
        ReturnImage returnImage = new ReturnImage();
        File file = null;
        FileInputStream stream = null;
        ObjectMetadata meta = new ObjectMetadata();
        meta.setHeader("Content-Disposition", "inline");
        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);
                Msg fileMiME = TypeDict.FileMiME(stream);
                meta.setHeader("content-type", fileMiME.getData().toString());
                PutObjectRequest putObjectRequest =
                        new PutObjectRequest(
                                key.getBucketname(),
                                username + "/" + ShortUIDName + "." + prefix,
                                stream,
                                meta);
                ossClient.putObject(putObjectRequest);
                try {if(stream!=null){stream.close();}} catch (Exception e) { }
            }
            returnImage.setCode("200");
        } catch (Exception e) {
            try {if(stream!=null){stream.close();}} catch (Exception ex) { }
            logger.error("OSS上传发生异常：",e);
            returnImage.setCode("500");
        }
        return returnImage;
    }

    public static Integer Initialize(Keys k) {
        int ret = -1;
        ObjectListing objectListing = null;
        if (StringUtils.isBlank(k.getAccessKey())
                || StringUtils.isBlank(k.getAccessSecret())
                || StringUtils.isBlank(k.getEndpoint())
                || StringUtils.isBlank(k.getBucketname())
                || StringUtils.isBlank(k.getRequestAddress())) {
            return -1;
        }
        OSS ossObj =
                new OSSClientBuilder()
                        .build(k.getEndpoint(), k.getAccessKey(), k.getAccessSecret());
        try {
            objectListing = ossObj.listObjects(k.getBucketname());
            ret = 1;
            ossClient = ossObj;
            key = k;
        } catch (Exception e) {