Java使用阿里云OSS和短信

本文涉及的产品
对象存储 OSS,20GB 3个月
对象存储 OSS,内容安全 1000次 1年
对象存储 OSS,恶意文件检测 1000次 1年
简介: Java版OSS和短信工具

阿里云OSS和短信工具

导入依赖


<dependency>
    <groupId>cn.gjing</groupId>
    <artifactId>tools-aliyun</artifactId>
    <version>1.0.7</version>
</dependency>

一、OSS

1、配置

以下配置除了后四个配置不必填,其他都必填

tools:
  aliyun:
    # 用户key,在阿里云获取,此处为全局配置,短信和oss未单独设置则会默认调用此处配置
    access-key: xxxxxxx
    # 用户秘钥,在阿里云获取,此处为全局配置,短信和OSS都会默认调用此处的key
    access-key-secret: xxxxxxx
    oss:
      # 用户key,在阿里云获取,此处优先级高于全局配置
      access-key: xxxxxxx
      # 用户秘钥,此处优先级高于全局配置
      access-key-secret: xxxxxxx
      # 节点, 前往阿里云查看
      end-point: xxxxxxxx
      # 存储空间,不存在会创建
      bucket: xxxxxxx
      # 最大连接数,默认1024
      max-connections: 1024
      # 最大空闲时间(毫秒),默认60000
      idle-time: 60000
      # socket超时时间(毫秒),默认50000
      socket-timeout: 50000
      # 连接超时时间(毫秒),默认50000
      connection-timeout: 50000

2、文件上传

  • 简单上传

适用于上传小文件,成功后会返回文件名,前端只需要将文件名与bucket域名拼接即可,bucket域名可在oss控制台,点击bucket列表,找到你使用的bucket点进去后点击概览,就可以在右边界面看到了,或者自己拼接:https://<bucket>.<endPoint>

import cn.gjing.tools.aliyun.oss.SimpleOssUpload;
/**
 * @author Gjing
 **/
@RestController
public class TestController {
    @Resource
    private SimpleOssUpload simpleOssUpload;

    @PostMapping("/file")
    public String upload(MultipartFile file) {
        // 直接上传,其他参数使用默认方式
        return this.simpleOssUpload.upload(file);
    }

    @PostMapping("/file2")
    public String upload(MultipartFile file) {
        // 手动设置文件名,默认为源文件的文件名,也可以指定包含文件后缀在内的完整路径
        return this.simpleOssUpload.upload(file, "目录1/123.jpg");
    }

    @PostMapping("/file3")
    public String upload(MultipartFile file) {
        // 可以手动设置bucket,否则读取yml文件中配置的bucket, bucket如果在阿里云oss不存在,会自动创建
        return this.simpleOssUpload.upload(file, "文件名", "bucket");
    }

    @DeleteMapping("/test1")
    public void deleteFile(String fileName) {
        // 删除指定oss文件,文件名为上传文件后返回的
        this.simpleOssUpload.deleteFile(fileName);
    }

    @DeleteMapping("/test2")
    public String deleteFiles(String[] fileNames) {
        // 批量删除, 会在执行完成后会返回删除成功的文件名列表,批量删除最多同时删除``1000``个
        return this.simpleOssUpload.deleteFiles(Arrays.asList(fileNames)).toString();
    }
}
  • 分片上传
    适用于大文件上传,通过分片,加快上传的速度,上传成功后返回一个FileMeta,里面包含fileNameuploadIdbucket默认分片切割大小为1M
import cn.gjing.tools.aliyun.oss.FileMeta;
import cn.gjing.tools.aliyun.oss.MultipartOssUpload;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.multipart.MultipartFile;

/**
 * @author Gjing
 **/
@RestController
public class TestController {
    @Resource
    private MultipartOssUpload multipartOssUpload;

    @PostMapping("/file")
    public String upload(MultipartFile file) {
        // 直接上传,其他的参数使用默认
        return this.multipartOssUpload.upload(file).getFileName();
    }

    @PostMapping("/file2")
    public String upload(MultipartFile file) {
        // 手动设置文件名,默认获取源文件的文件名, 也可以指定包含文件后缀在内的完整路径
        return this.multipartOssUpload.upload(file, "目录1/123.jpg").getFileName();
    }

    @PostMapping("/file3")
    public String upload(MultipartFile file) {
        // 可以手动设置bucket,否则读取yml文件中配置的bucket,bucket如果在阿里云oss不存在,会创建
        return this.multipartOssUpload.upload(file, "文件名", "bucket").getFileName();
    }
}

4、判断文件是否存在

/**
 * @author Gjing
 **/
@RestController
public class TestController {
    @Resource
    private OssDownload ossDownload;

    @PostMapping("/test")
    public boolean test(String fileName) {
        return this.ossDownload.isExist(fileName);
    }
}

5、文件下载

/**
 * @author Gjing
 **/
@RestController
public class TestController {
    @Resource
    private OssDownload ossDownload;

    @GetMapping("/test")
    public void downLocal(String fileName, HttpServletResponse response) {
        // 1、下载到本地指定目录
        this.ossDownload.downByLocal("/Users/colin/Desktop/1/", fileName);
        // 2、通过流下载
        this.ossDownload.downByStream(fileName, response);
    }
}

二、短信

1、配置

以下配置除了region其他都必填

tools:
  aliyun:
    # 用户key,在阿里云获取
    access-key: xxxxxxx
    # 用户秘钥,在阿里云获取
    access-key-secret: xxxxxx
    sms:
      # 用户key,在阿里云获取,此处优先级高于全局配置
      access-key: xxxxxxx
      # 用户秘钥,此处优先级高于全局配置
      access-key-secret: xxxxxxx
      # 短信模板ID,必须是已添加并审核通过的
      template-code: xxxxxxx
      # 短信签名名称,必须是已添加并审核通过的
      sign-name: xxxxxx
      # 区域,默认default
      region: default

2、发送短信

短信模板变量对应的实际值

/**
 * @author Gjing
 **/
@RestController
public class SmsController {
    @Resource
    private SmsHelper smsHelper;

    @PostMapping("/sms")
    public String send(String phones) {
        Map<String, Integer> param = new HashMap<>();
        param.put("code", 12345);
        return this.smsHelper.send(phones, param);
    }
}

send()方法参数如下

参数 描述
phones 11位手机号,多个用英文逗号隔开,上限为1000
templateCode 短信模板code,必须是已存在且审核通过
signName 短信签名名称,必须是已存在且审核通过
param 短信模板变量对应的实际值

3、查询指定号码发送记录


/**
 * @author Gjing
 **/
@RestController
public class SmsController {
    @Resource
    private SmsHelper smsHelper;

    @GetMapping("/sms_record")
    public String findSmsRecord(String phone) {
        return this.smsHelper.findSendDetail(phone, "2020-02-01", 1, 5);
    }
}

findSendDetail()方法参数如下

参数 描述
phone 11位手机号
sendDate 发送日期,格式:yyyy-MM-dd
page 页数
row 每页条数,最大50

源代码地址:tools-aliyun

相关实践学习
借助OSS搭建在线教育视频课程分享网站
本教程介绍如何基于云服务器ECS和对象存储OSS,搭建一个在线教育视频课程分享网站。
目录
相关文章
|
5月前
|
机器学习/深度学习 人工智能 专有云
人工智能平台PAI使用问题之怎么将DLC的数据写入到另一个阿里云主账号的OSS中
阿里云人工智能平台PAI是一个功能强大、易于使用的AI开发平台,旨在降低AI开发门槛,加速创新,助力企业和开发者高效构建、部署和管理人工智能应用。其中包含了一系列相互协同的产品与服务,共同构成一个完整的人工智能开发与应用生态系统。以下是对PAI产品使用合集的概述,涵盖数据处理、模型开发、训练加速、模型部署及管理等多个环节。
|
28天前
|
分布式计算 Java 开发工具
阿里云MaxCompute-XGBoost on Spark 极限梯度提升算法的分布式训练与模型持久化oss的实现与代码浅析
本文介绍了XGBoost在MaxCompute+OSS架构下模型持久化遇到的问题及其解决方案。首先简要介绍了XGBoost的特点和应用场景,随后详细描述了客户在将XGBoost on Spark任务从HDFS迁移到OSS时遇到的异常情况。通过分析异常堆栈和源代码,发现使用的`nativeBooster.saveModel`方法不支持OSS路径,而使用`write.overwrite().save`方法则能成功保存模型。最后提供了完整的Scala代码示例、Maven配置和提交命令,帮助用户顺利迁移模型存储路径。
|
2月前
|
算法 Java Linux
java制作海报四:java BufferedImage 转 InputStream 上传至OSS。png 图片合成到模板(另一个图片)上时,透明部分变成了黑色
这篇文章主要介绍了如何将Java中的BufferedImage对象转换为InputStream以上传至OSS,并解决了png图片合成时透明部分变黑的问题。
69 1
|
2月前
|
运维 监控 搜索推荐
阿里大鱼进行发短信业务---使用详细步骤-Java操作
这篇文章详细介绍了如何在Java中使用阿里大鱼服务来发送短信,包括开通短信服务、签名和模板管理,以及具体的Java开发步骤和代码示例。
87 0
阿里大鱼进行发短信业务---使用详细步骤-Java操作
|
3月前
|
存储 SQL 分布式计算
Java连接阿里云MaxCompute例
要使用Java连接阿里云MaxCompute数据库,首先需在项目中添加MaxCompute JDBC驱动依赖,推荐通过Maven管理。避免在代码中直接写入AccessKey,应使用环境变量或配置文件安全存储。示例代码展示了如何注册驱动、建立连接及执行SQL查询。建议使用RAM用户提升安全性,并根据需要配置时区和公网访问权限。具体步骤和注意事项请参考阿里云官方文档。
|
4月前
|
Java 开发工具
通过Java SDK调用阿里云模型服务
在阿里云平台上,可以通过创建应用并使用模型服务完成特定任务,如生成文章内容。本示例展示了一段简化的Java代码,演示了如何调用阿里云模型服务生成关于“春秋战国经济与文化”的简短文章。示例代码通过设置系统角色为历史学家,并提出文章生成需求,最终处理并输出生成的文章内容。在实际部署前,请确保正确配置环境变量中的密钥和ID,并根据需要调整SDK导入语句及类名。更多详情和示例,请参考相关链接。
|
4月前
|
存储 机器学习/深度学习 弹性计算
阿里云EMR数据湖文件系统问题之OSS-HDFS全托管服务的问题如何解决
阿里云EMR数据湖文件系统问题之OSS-HDFS全托管服务的问题如何解决
|
4月前
|
机器学习/深度学习 存储 缓存
Java本地高性能缓存实践问题之阿里云机器学习团队开源社区的问题如何解决
Java本地高性能缓存实践问题之阿里云机器学习团队开源社区的问题如何解决
|
5月前
|
消息中间件 分布式计算 DataWorks
DataWorks产品使用合集之如何使用Python和阿里云SDK读取OSS中的文件
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
5月前
|
存储 运维 安全
阿里云OSS的优势
【7月更文挑战第19天】阿里云OSS的优势
203 2