亿美软通短信
最近公司在用亿美软通短信，这个整体下来感觉不错。文档写的也很清晰，整合起来也不费事。下面来介绍一下整合步骤；
一
首先找到相关的网站，需要向管理人员获取相关的账号（appId）和秘钥（secretkey16位）
然后下面是
国内接口http标准协议文档和demo的地址：
http://www.b2m.cn/static/doc/sms/onlysms_or.html
接口的url地址：
http://bjmtn.b2m.cn（北京地址）
http://shmtn.b2m.cn （上海地址）
http://gzmtn.b2m.cn （广州地址）
二
读懂相关文档，整合相关代码
这里可以查看相关的接口文档，在工作需求中大多会用到单发短信和批量发送。
这个官网上也附带有相关的短信 demo ,有C有Java有PHP，这里我们只看JAVA。
三
整合接口，根据demo进行整理
这些都是软通的工具类 其中有各种加密的方式等等的封装，其中
这些是调用各种短信的例子demo,调用时可以查看。
四
整合项目，实现短信发送，首先在整合时需要查看一些注意事项
必要参数appId,secretKey需向亿美软通获取
默认UTF-8字符集,默认不进行GZip压缩
获取上行和扩展码需账号支持
支持短信单发,群发,获取账号短信剩余条数,获取状态报告,上行
单发短信支持自定义信息id,与扩展码,群发支持扩展码
项目是对亿美软通demo进行简单封装方便使用
PS,短信内容必须带上类似此【前缀】,否则无法发送成功(运营商要求)
PS,短信内容含有群发等非法关键字也无法正常发送
本包依赖一个gson-2.6.2.jar
MAVEN项目时 ，需引用
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.4</version>
</dependency>
接下来只需要写一个工具类就可以了，
这些是demo里可以取出来需要取出来。下面是简单的需要的工具类的例子
@Component
public class EmaySMSUtils {
// appId
private static String appId = "EUCP-EMY-SMS0-27TIT ";//需要向软通获取
// 密钥
private static String secretKey = "LB663MSJC8W51LET";// 需要向软通获取
// 接口地址
private static String host = "http://bjmtn.b2m.cn";// 北京接口
// 加密算法
private static String algorithm = "AES/ECB/PKCS5Padding";
// 编码
private static String encode = "UTF-8";
// 是否压缩
private static Boolean isGzip = true;
/**
* 发送单条短信 这里R是我所用的架构 封装的 需要什么可以更改
*/
public static R sendSingleSms(String content, String mobile){
Boolean flag =checkKeyParam(content,mobile);
SysMail sysMail = new SysMail();
if(flag){
content ="【测试】"+content;
try {
SmsResponse smsResponse = setSingleSms(appId, secretKey, host, algorithm, content, null, null, mobile, isGzip, encode);
return R.ok("发送成功！");
}catch (Exception exception){
return R.fail("发送失败！");
}
}else{
return R.fail("发送失败！");
}
}
/**
* @描述 群发短信不需要扩展码
* @参数 @param content
* @参数 @param mobiles
* @参数 @return
* @return SmsResponse[]
*/
public static R sendBatchOnlySms(String content, String[] mobiles){
Boolean flag =checkKeyParam(appId,secretKey,mobiles);
SysMail sysMail = new SysMail();
if(flag){
try {
content ="【测试】"+content;
//调用批量发送
SmsResponse[] smsResponses = setBatchOnlySms(appId, secretKey, host, algorithm, content, null, mobiles, isGzip, encode);
return R.ok("发送成功！");
}catch (Exception exception){
return R.fail("发送失败！");
}
}else{
return R.fail("发送失败！");
}
}
/**
* 发送单条短信
*
* @param isGzip
* 是否压缩
* @param content
* 内容
*/
private static SmsResponse setSingleSms(String appId, String secretKey, String host, String algorithm, String content, String customSmsId, String extendCode, String mobile, boolean isGzip, String encode) {
Boolean flag = checkKeyParam(appId, secretKey, mobile);
if (flag) {
System.out.println("=============begin setSingleSms==================");
SmsSingleRequest pamars = new SmsSingleRequest();
pamars.setContent(content);
pamars.setCustomSmsId(customSmsId);
pamars.setExtendedCode(extendCode);
pamars.setMobile(mobile);
ResultModel result = request(appId, secretKey, algorithm, pamars, host + "/inter/sendSingleSMS", isGzip, encode);
System.out.println("result code :" + result.getCode());
if ("SUCCESS".equals(result.getCode())) {
SmsResponse response = JsonHelper.fromJson(SmsResponse.class, result.getResult());
if (response != null) {
System.out.println("data : " + response.getMobile() + "," + response.getSmsId() + "," + response.getCustomSmsId());
}
return response;
}
System.out.println("=============end setSingleSms==================");
return null;
} else {
System.out.println("=============param check error==================");
return null;
}
}
/**
* 发送批次短信
*
* @param isGzip
* 是否压缩
*/
private static SmsResponse[] setBatchOnlySms(String appId, String secretKey, String host, String algorithm, String content, String extendCode, String[] mobiles, boolean isGzip, String encode) {
Boolean flag = checkKeyParam(appId, secretKey, mobiles);
if (flag) {
System.out.println("=============begin setBatchOnlySms==================");
SmsBatchOnlyRequest pamars = new SmsBatchOnlyRequest();
pamars.setMobiles(mobiles);
pamars.setExtendedCode(extendCode);
pamars.setContent(content);
ResultModel result = request(appId, secretKey, algorithm, pamars, host + "/inter/sendBatchOnlySMS", isGzip, encode);
System.out.println("result code :" + result.getCode());
if ("SUCCESS".equals(result.getCode())) {
SmsResponse[] response = JsonHelper.fromJson(SmsResponse[].class, result.getResult());
if (response != null) {
for (SmsResponse d : response) {
System.out.println("data:" + d.getMobile() + "," + d.getSmsId() + "," + d.getCustomSmsId());
}
}
return response;
}
System.out.println("=============end setBatchOnlySms==================");
return null;
} else {
System.out.println("=============param check error==================");
return null;
}
}
@PostConstruct // 初始化
public void init(){
emaySMSUtils = this;
emaySMSUtils.iSysMailService = this.iSysMailService;
}
/**
*
* @描述 校验key与secret
* @参数 @param appId
* @参数 @param secretKey
* @参数 @param mobile
* @参数 @return
* @return Boolean
*/
private static Boolean checkKeyParam(String appId, String secretKey) {
if (null == appId || secretKey == null || appId.trim().equals("") || secretKey.trim().equals("")) {
return false;
}
return true;
}
/**
*
* @描述 校验key与secret,mobile
* @参数 @param appId
* @参数 @param secretKey
* @参数 @param mobile
* @参数 @return
* @return Boolean
*/
private static Boolean checkKeyParam(String appId, String secretKey, String mobile) {
if (null == appId || secretKey == null || mobile == null || appId.trim().equals("")
|| secretKey.trim().equals("") || mobile.trim().equals("") || mobile.trim().equals("")) {
return false;
}
return true;
}
/**
*
* @描述 校验key与secret,mobiles[]
* @参数 @param appId
* @参数 @param secretKey
* @参数 @param mobiles
* @参数 @return
* @return Boolean
*/
private static Boolean checkKeyParam(String appId, String secretKey, String[] mobiles) {
if (null == appId || secretKey == null || mobiles == null || appId.trim().equals("")
|| secretKey.trim().equals("") || mobiles.length == 0) {
return false;
}
return true;
}
/**
* 公共请求方法
*/
public static ResultModel request(String appId, String secretKey, String algorithm, Object content, String url, final boolean isGzip, String encode) {
Map<String, String> headers = new HashMap<String, String>();
HttpRequest<byte[]> request = null;
try {
headers.put("appId", appId);
headers.put("encode", encode);
String requestJson = JsonHelper.toJsonString(content);
System.out.println("result json: " + requestJson);
byte[] bytes = requestJson.getBytes(encode);
System.out.println("request data size : " + bytes.length);
if (isGzip) {
headers.put("gzip", "on");
bytes = GZIPUtils.compress(bytes);
System.out.println("request data size [com]: " + bytes.length);
}
byte[] parambytes = AES.encrypt(bytes, secretKey.getBytes(), algorithm);
System.out.println("request data size [en] : " + parambytes.length);
HttpRequestParams<byte[]> params = new HttpRequestParams<byte[]>();
params.setCharSet("UTF-8");
params.setMethod("POST");
params.setHeaders(headers);
params.setParams(parambytes);
params.setUrl(url);
if (url.startsWith("https://")) {
request = new HttpsRequestBytes(params, null);
} else {
request = new HttpRequestBytes(params);
}
} catch (Exception e) {
System.out.println("加密异常");
e.printStackTrace();
}
HttpClient client = new HttpClient();
String code = null;
String result = null;
try {
HttpResponseBytes res = client.service(request, new HttpResponseBytesPraser());
if (res == null) {
System.out.println("请求接口异常");
return new ResultModel(code, result);
}
if (res.getResultCode().equals(HttpResultCode.SUCCESS)) {
if (res.getHttpCode() == 200) {
code = res.getHeaders().get("result");
if (code.equals("SUCCESS")) {
byte[] data = res.getResult();
System.out.println("response data size [en and com] : " + data.length);
data = AES.decrypt(data, secretKey.getBytes(), algorithm);
if (isGzip) {
data = GZIPUtils.decompress(data);
}
System.out.println("response data size : " + data.length);
result = new String(data, encode);
System.out.println("response json: " + result);
}
} else {
System.out.println("请求接口异常,请求码:" + res.getHttpCode());
}
} else {
System.out.println("请求接口网络异常:" + res.getResultCode().getCode());
}
} catch (Exception e) {
System.out.println("解析失败");
e.printStackTrace();
}
ResultModel re = new ResultModel(code, result);
return re;
}
/**
*
* @描述 获取剩余短信条数
* @参数 @param appId
* @参数 @param secretKey
* @参数 @return
* @return Long
*/
public static Long getBalance(String appId, String secretKey) {
Boolean flag = checkKeyParam(appId, secretKey);
if (flag) {
System.out.println("=============begin getBalance==================");
BalanceRequest pamars = new BalanceRequest();
ResultModel result = request(appId, secretKey, algorithm, pamars, host + "/inter/getBalance",
isGzip, encode);
System.out.println("result code :" + result.getCode());
if ("SUCCESS".equals(result.getCode())) {
BalanceResponse response = JsonHelper.fromJson(BalanceResponse.class, result.getResult());
if (response != null) {
System.out.println("result data : " + response.getBalance());
System.out.println("=============end getBalance==================");
return response.getBalance();
}
}
System.out.println("=============end getBalance==================");
return null;
} else {
System.out.println("=============param check error==================");
return null;
}
}
public static void main(String[] args) {
Long balance = getBalance(appId, secretKey);
System.out.print("====剩余短信条数: "+"\033[0;31m"+balance+"条");
}
}
看这demo写的话，其实很容易。有需要的可以私聊我！！！