SpringCloud集成–容联云通讯–Redis

发送短信微服务

项目结构

配置文件

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>leyou</artifactId><groupId>com.leyou.parent</groupId><version>1.0.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><groupId>com.leyou.service</groupId><artifactId>ly-sms</artifactId><dependencies><!-- 容联云通讯, 发送短信的依赖 自带的是gson2.8.5但是会报错--><dependency><groupId>com.cloopen</groupId><artifactId>java-sms-sdk</artifactId><version>1.0.1</version></dependency><!-- 必须添加2.8.6, 要不然发送短信就会报错 --><dependency><groupId>com.google.code.gson</groupId><artifactId>gson</artifactId><version>2.8.6</version></dependency><!-- spring操作rabbitmq依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><!-- 测试依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId></dependency><!-- spring操作redis依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency></dependencies></project>

application.yml

server:port: 8086spring:application:name: sms-servicerabbitmq:host: 192.168.79.128  # 安装rabbitmq的ipusername: leyou # rabbitmq的账号password: 123456 # rabbitmq的密码virtual-host: /leyou # 虚拟主机redis:host: 192.168.79.128 # 端口默认6379, 所以这里没配置ly:sms:# 主账号,登陆云通讯网站后,可在控制台首页看到开发者主账号ACCOUNT SID和主账号令牌AUTH TOKENaccountSId: ***********************accountToken: ***********************# 请使用管理控制台中已创建应用的APPIDappId: ***********************# 短信模板templateId: 1

启动类

LySmsApplication

package com.leyou.sms;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** @program: leyou* @description:* @author: Mr.Xiao* @create: 2020-07-01 11:12**/
@SpringBootApplication
public class LySmsApplication {public static void main(String[] args) {SpringApplication.run(LySmsApplication.class);}}

config

SmsProperties

package com.leyou.sms.config;import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;/*** @program: leyou* @description: java配置类* @author: Mr.Xiao* @create: 2020-07-01 11:24**/
@ConfigurationProperties(prefix = "ly.sms")
@Data
public class SmsProperties {private String accountSId;private String accountToken;private String appId;private String templateId;}

mq

SmsListener

package com.leyou.sms.mq;import com.leyou.sms.config.SmsProperties;
import com.leyou.sms.utils.SmsUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;import java.util.Map;/*** @program: leyou* @description: 消息接收处理* @author: Mr.Xiao* @create: 2020-06-29 18:21**/
@Component
@EnableConfigurationProperties(SmsProperties.class)
public class SmsListener {@Autowiredprivate SmsUtils smsUtils;@Autowiredprivate SmsProperties prop;@RabbitListener(bindings = @QueueBinding(/*** name = "sms.verify.code.queue" 队列名称* durable = "true" 持久化**/value = @Queue(name = "sms.verify.code.queue", durable = "true"),/*** name = "ly.sms.exchange" 交换机名称* type = ExchangeTypes.TOPIC 交换机类型**/exchange = @Exchange(name = "ly.sms.exchange", type = ExchangeTypes.TOPIC),/*** key = "sms.verify.code"  routing key**/key = "sms.verify.code"))public void listenerSendSms(Map<String, String> msg) {if (CollectionUtils.isEmpty(msg)) {return;}String to = msg.get("phone");if (StringUtils.isBlank(to)) {return;}String[] datas = msg.get("datas").split(",");// 发送短信验证码smsUtils.sendSms(to, prop.getTemplateId(), datas);}}

utils

SmsUtils

package com.leyou.sms.utils;import com.cloopen.rest.sdk.BodyType;
import com.cloopen.rest.sdk.CCPRestSmsSDK;
import com.leyou.sms.config.SmsProperties;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;import java.util.HashMap;
import java.util.Set;
import java.util.concurrent.TimeUnit;/*** @program: leyou* @description: 发送短息* @author: Mr.Xiao* @create: 2020-07-01 11:27**/
@Slf4j
@Component
@EnableConfigurationProperties(SmsProperties.class)
public class SmsUtils {@Autowiredprivate SmsProperties prop; // java配置类, 把发送短信需要的配置, 都配置在配置文件了@Autowiredprivate StringRedisTemplate redisTemplate; // 注入redisTemplate// 生产环境请求地址：app.cloopen.comprivate static final String serverIp = "app.cloopen.com";// 请求端口private static final String serverPort = "8883";// 存入redis的前缀private static final String KEY_PREFIX = "sms:phone:";// 存活时间 1分钟private static final long SMS_MIN_INTERVAL_IN_MILLIS = 60000;public void sendSms(String to, String templateId, String[] datas) {String redisKey = KEY_PREFIX + to;// TODO 按照手机号限流// 先从redis中取出该值String redisValue = redisTemplate.opsForValue().get(redisKey);if (StringUtils.isNotBlank(redisValue)) {// redis中有值long lastTime = Long.valueOf(redisValue);if (System.currentTimeMillis() - lastTime < SMS_MIN_INTERVAL_IN_MILLIS) {log.info("[短信服务], 发送频率过高, 被拦截, 请稍后再试, 手机号码: {}", to);return;}}CCPRestSmsSDK sdk = new CCPRestSmsSDK();sdk.init(serverIp, serverPort);sdk.setAccount(prop.getAccountSId(), prop.getAccountToken());sdk.setAppId(prop.getAppId());sdk.setBodyType(BodyType.Type_JSON);/*** to: 发送短信至手机号** templateId: 短信模板** datas: 这里模拟一下验证码123456，10分钟内到期 {"123456", "10"}*/HashMap<String, Object> result = sdk.sendTemplateSMS(to,templateId,datas);if("000000".equals(result.get("statusCode"))){//正常返回输出data包体信息（map）HashMap<String,Object> data = (HashMap<String, Object>) result.get("data");Set<String> keySet = data.keySet();for(String key:keySet){Object object = data.get(key);System.out.println(key +" = "+object);}// 发送短信成功后, 写入redis, 指定生存时间1分钟redisTemplate.opsForValue().set(redisKey, String.valueOf(System.currentTimeMillis()), 1, TimeUnit.MINUTES);log.info("[短信服务], 发送短信验证码, 手机号: {}", to);}else{log.error("[短信服务] 发送短信失败 ", result.get("statusMsg"));//异常返回输出错误码和错误信息System.out.println("错误码=" + result.get("statusCode") +" 错误信息= "+result.get("statusMsg"));}}}

测试

test

package com.leyou.test;import com.leyou.sms.LySmsApplication;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;import java.util.HashMap;/*** @program: leyou* @description:* @author: Mr.Xiao* @create: 2020-07-01 14:03**/
@RunWith(SpringRunner.class)
@SpringBootTest(classes = LySmsApplication.class)
public class test {@Autowiredprivate AmqpTemplate amqpTemplate;@Testpublic void sendSms() {HashMap<String, String> map = new HashMap<>();map.put("phone", "*********");map.put("datas", "123456,1");this.amqpTemplate.convertAndSend("ly.sms.exchange", "sms.verify.code", map);}}

SpringCloud集成发送短信--容联云通讯--Redis相关推荐

Django验证码*短信验证码之2-容联云通讯短信平台(联云通讯短信平台介绍、容联云通讯Python SDK、封装发送短信单例类)
容联云通讯短信平台介绍容联云通讯网址:https://www.yuntongxun.com/ 容联云管理控制台容联云创建应用容联云通讯Python SDK https://doc.yuntong ...
python控制手机发短信_python-在python3中使用容联云通讯发送短信验证码
2020-08-15更新今天进容联云官网发现其已经更新了最新版的Python SDK,可以直接 pip install ronglian_sms_sdk 即可安装使用,具体新的使用方法可以查看官网案 ...
java通过容联云通讯实现发送短信验证码
1.在容联云通讯上根据 -接入流程完成以下的步骤创建应用申请短信签名配置测试号码等等最终可以拿到SID和TOKEN.之后把官网上的Demo下载下来,把里面的jar包加到你的项目里面 Cont ...
laravel+容联.云通讯实现手机短信验证用户注册
Laravel框架简介: Laravel是一套简洁.优雅的PHP Web开发框架(PHP Web Framework).它可以让你从面条一样杂乱的代码中解脱出来:它可以帮你构建一个完美的网络APP,而 ...
容联云通讯短信平台JS调用
容联云通讯官网 1.注册注册成功之后,会赠送8元进行测试记录账号信息用于代码中配置添加测试号码用于测试 2.接口配置(js) var md5 = require('blueimp-md5') v ...
容联云通讯短信接口 Python3 文档
容联云通讯官方还未发布python3以上的版本,此文档是向云通讯的工作人员获取的,下载后解压可以直接使用
容联云通讯完成发送验证码
容联云通讯完成发送验证码不是广告,真人编写,学习记录分享而已容联云通讯官方网站 https://www.yuntongxun.com/ 进入网站后,找到测试号码绑定测试的手机号,最多绑定是三个 ...
android 极光环信,环信、容联云通讯、极光推送和网易云信IM即时通讯功能接入方式_部署方式_企业服务汇...
编者按:企业在挑选IM即时通讯功能服务商时,对于企业应当如何接入其IM功能.接入方式和部署方式有哪些等问题不太清楚.今天企业服务汇通过评测环信.容联云通讯.极光推送和网易云信这四家服务商来为你详细说明 ...
开发者福利丨容联云通讯、LeanCloud 官方集成云账户红包SDK
聊天场景下匹配账户体系以及收发红包的功能,对于IM产品来说如虎添翼,也为开发者节省了大量的开发成本. 近日,两大即时通讯云服务提供商容联云通讯.LeanCloud先后在其官网发布了完美集成云账户红包S ...

SpringCloud集成发送短信--容联云通讯--Redis

SpringCloud集成–容联云通讯–Redis

发送短信微服务

项目结构

配置文件

启动类

config

mq

utils

测试

SpringCloud集成发送短信--容联云通讯--Redis相关推荐

最新文章

热门文章