pom.xml com.aliyun aliyun-java-sdk-core 3.2.3 com.aliyun aliyun-java-sdk-dysmsapi 1.0.0 企业版 com.aliyun.mns aliyun-sdk-mns 1.1.8 jar-with-dependencies 短信发送工具 package org.common.serveradmin.utils;/** * @Author:LiuHao * @Date
com.aliyun
aliyun-java-sdk-core
3.2.3
com.aliyun
aliyun-java-sdk-dysmsapi
1.0.0
企业版
com.aliyun.mns
aliyun-sdk-mns
1.1.8
jar-with-dependencies
短信发送工具
package org.common.serveradmin.utils;
/**
* @Author:LiuHao
* @Date: Create in 17:25 2017/10/16
**/
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest;
import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.MethodType;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import org.common.serveradmin.emuns.ServerAdminCodeEmun;
import org.common.serveradmin.exception.ServerAdminException;
/**
* 短信发送工具
* @author Administrator
*
*/
public class SmsUtil {
//产品名称:云通信短信API产品,开发者无需替换
static final String product = "Dysmsapi";
//产品域名,开发者无需替换
static final String domain = "dysmsapi.aliyuncs.com";
// TODO 此处需要替换成开发者自己的AK(在阿里云访问控制台寻找)
static final String accessKeyId = "******";
static final String accessKeySecret = "******";
/**
* 发送短信方法
* @param tel 电话号码
* @return
* @throws ClientException
*/
public static SendSmsResponse sendSms(String tel,String code) throws ServerAdminException{
SendSmsResponse sendSmsResponse = null;
try {
//可自助调整超时时间
System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
System.setProperty("sun.net.client.defaultReadTimeout", "10000");
//初始化acsClient,暂不支持region化
IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
IAcsClient acsClient = new DefaultAcsClient(profile);
//组装请求对象
SendSmsRequest request = new SendSmsRequest();
//使用post提交
request.setMethod(MethodType.POST);
//必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式
request.setPhoneNumbers(tel);
//必填:短信签名-可在短信控制台中找到
request.setSignName("***");
//必填:短信模板-可在短信控制台中找到
request.setTemplateCode("SMS_10475***");
//可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
//友情提示:如果JSON中需要带换行符,请参照标准的JSON协议对换行符的要求,比如短信内容中包含\r\n的情况在JSON中需要表示成\\r\\n,否则会导致JSON在服务端解析失败
request.setTemplateParam("{\"code\":\""+code+"\"}");
//可选-上行短信扩展码(无特殊需求用户请忽略此字段)
//request.setSmsUpExtendCode("90997");
//可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
request.setOutId("yourOutId");
//请求失败这里会抛ClientException异常
sendSmsResponse = acsClient.getAcsResponse(request);
if(sendSmsResponse.getCode() != null && sendSmsResponse.getCode().equals("OK")) {
System.out.println("成功");
}else{
System.out.println("失败");
System.out.println(sendSmsResponse.getCode());
}
} catch (ClientException e) {
e.printStackTrace();
throw new ServerAdminException(ServerAdminCodeEmun.SMS_IS_FAIL);
}
return sendSmsResponse;
}
public static void main(String[] args) throws ClientException {
try {
SmsUtil.sendSms("18691496390","1232");
} catch (ServerAdminException e) {
e.printStackTrace();
}
}
/**
* 获取验证码方法
*/
public static String getCode(){
int code = (int)(Math.random()*9999)+1; //每次调用生成一次四位数的随机数
if(code>=10000||code<1000){
code=7654;
}
return code+"";
}
}
企业版
package org.woke.oss.common.utils;
/**
* @Author:LiuHao
* @Date: Create in 17:25 2017/10/16
**/
import com.aliyun.mns.client.CloudAccount;
import com.aliyun.mns.client.CloudTopic;
import com.aliyun.mns.client.MNSClient;
import com.aliyun.mns.common.ServiceException;
import com.aliyun.mns.model.BatchSmsAttributes;
import com.aliyun.mns.model.MessageAttributes;
import com.aliyun.mns.model.RawTopicMessage;
import com.aliyun.mns.model.TopicMessage;
import org.woke.oss.common.emuns.AdminCoreCodeEmun;
import org.woke.oss.common.exception.AdminCoreException;
/**
* 短信发送工具
* @author Administrator
*
*/
public class SmsUtil {
//产品名称:云通信短信API产品,开发者无需替换
static final String product = "Dysmsapi";
//产品域名,开发者无需替换
static final String domain = "dysmsapi.aliyuncs.com";
// TODO 此处需要替换成开发者自己的AK(在阿里云访问控制台寻找)
static final String accessKeyId = "xxx";
static final String accessKeySecret = "xxx";
//企业版的需要下面2个数据
//点击获取Endpoint 复制里面的公网地址
static final String accountEndpoint = "xxx";
//主题名称
static final String yourTopic = "xxx";
// static final String accessKeyId = "LTAIzNLBnO0rfhns";
// static final String accessKeySecret = "YeWvzpNqgRvdkQgnkOZDe2Fg3ePpCg";
// static final String accessKeyId = "LTAIzNLBnO0rfhns";
// static final String accessKeySecret = "YeWvzpNqgRvdkQgnkOZDe2Fg3ePpCg";
/**
* 发送短信方法
*
* @return
* @throws
*/
//企业版
public static void sendSms(String tel,String code) throws AdminCoreException{
MNSClient client = null;
try {
/**
* Step 1. 获取主题引用 accountEndpoint
*/
CloudAccount account = new CloudAccount(accessKeyId, accessKeySecret, accountEndpoint);
client = account.getMNSClient();
CloudTopic topic = client.getTopicRef(yourTopic);
/**
* Step 2. 设置SMS消息体（必须）
*
* 注：目前暂时不支持消息内容为空，需要指定消息内容，不为空即可。
*/
RawTopicMessage msg = new RawTopicMessage();
msg.setMessageBody("sms-message");
/**
* Step 3. 生成SMS消息属性
*/
MessageAttributes messageAttributes = new MessageAttributes();
BatchSmsAttributes batchSmsAttributes = new BatchSmsAttributes();
// 3.1 设置发送短信的签名（SMSSignName）
batchSmsAttributes.setFreeSignName("xx");
// 3.2 设置发送短信使用的模板（SMSTempateCode）
batchSmsAttributes.setTemplateCode("xx");
// 3.3 设置发送短信所使用的模板中参数对应的值（在短信模板中定义的，没有可以不用设置）
BatchSmsAttributes.SmsReceiverParams smsReceiverParams = new BatchSmsAttributes.SmsReceiverParams();
smsReceiverParams.setParam("code", code);
// 3.4 增加接收短信的号码
batchSmsAttributes.addSmsReceiver(tel, smsReceiverParams);
messageAttributes.setBatchSmsAttributes(batchSmsAttributes);
try {
/**
* Step 4. 发布SMS消息
*/
TopicMessage ret = topic.publishMessage(msg, messageAttributes);
} catch (ServiceException se) {
System.out.println(se.getErrorCode() + se.getRequestId());
System.out.println(se.getMessage());
se.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}catch (Exception e) {
throw new AdminCoreException(AdminCoreCodeEmun.SMS_IS_FAIL);
}
client.close();
}
//个人版
// public static SendSmsResponse sendSms(String tel,String code) throws AdminCoreException{
// SendSmsResponse sendSmsResponse = null;
// try {
// //可自助调整超时时间
// System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
// System.setProperty("sun.net.client.defaultReadTimeout", "10000");
// //初始化acsClient,暂不支持region化
// IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", accessKeyId, accessKeySecret);
// DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
// IAcsClient acsClient = new DefaultAcsClient(profile);
// //组装请求对象
// SendSmsRequest request = new SendSmsRequest();
// //使用post提交
// request.setMethod(MethodType.POST);
// //必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式
// request.setPhoneNumbers(tel);
// //必填:短信签名-可在短信控制台中找到
// request.setSignName("沃克科技");
// //必填:短信模板-可在短信控制台中找到
// request.setTemplateCode("SMS_110180006");
// //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
// //友情提示:如果JSON中需要带换行符,请参照标准的JSON协议对换行符的要求,比如短信内容中包含\r\n的情况在JSON中需要表示成\\r\\n,否则会导致JSON在服务端解析失败
// request.setTemplateParam("{\"code\":\""+code+"\"}");
// //可选-上行短信扩展码(无特殊需求用户请忽略此字段)
// //request.setSmsUpExtendCode("90997");
// //可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
// request.setOutId("yourOutId");
// //请求失败这里会抛ClientException异常
// sendSmsResponse = acsClient.getAcsResponse(request);
// if(sendSmsResponse.getCode() != null && sendSmsResponse.getCode().equals("OK")) {
// System.out.println("成功");
// }else{
// System.out.println("失败");
// System.out.println(sendSmsResponse.getCode());
// }
// } catch (ClientException e) {
// e.printStackTrace();
// throw new AdminCoreException(AdminCoreCodeEmun.SMS_IS_FAIL);
// }
// return sendSmsResponse;
// }
public static void main(String[] args) {
try {
sendSms("18691496390","2222");
} catch (AdminCoreException e) {
e.printStackTrace();
}
}
/**
* 获取验证码方法
*/
public static String getCode(){
int code = (int)(Math.random()*9999)+1; //每次调用生成一次四位数的随机数
if(code>=10000||code<1000){
code=7654;
}
return code+"";
}
}