發(fā)送短信的接口
創(chuàng)新互聯(lián)建站專注于企業(yè)成都全網(wǎng)營銷、網(wǎng)站重做改版、大東網(wǎng)站定制設計、自適應品牌網(wǎng)站建設、H5開發(fā)、電子商務商城網(wǎng)站建設、集團公司官網(wǎng)建設、成都外貿(mào)網(wǎng)站建設、高端網(wǎng)站制作、響應式網(wǎng)頁設計等建站業(yè)務，價格優(yōu)惠性價比高，為大東等各大城市提供網(wǎng)站開發(fā)制作服務。
根據(jù)自己的情況選擇服務商。
開發(fā)文檔
從開發(fā)文檔中我們可以看到. 可以直接使用http請求也可以使用WebService請求發(fā)送短信. 由于DEMO文件夾下的java和jsp文件夾中的代碼都是使用http請求發(fā)送短信. 所以這里就不再細說了, 我們使用WebService的方式演示發(fā)送短信.
生成客戶端代碼
從接口文檔中我們知道它的WebService的WSDL的url為:?那么我們可以執(zhí)行下面的命令生成客戶端代碼:
wsimport -keep
其中wsimport是JDK自帶的工具, -keep url選項是"保留生成的文件". 該命令會在當前目錄下生成sms.cn.ihuyi._106包, 以及眾多的類. 接下來開始編寫我們自己的代碼.
定義接口
為了方便, 這里我們首先定義一個接口:
Sms.java
public?interface?Sms?{
/**
*?向mobile發(fā)送短信,?內(nèi)容為message
*?
*?@param?mobile?手機號
*?@param?message?短信內(nèi)容
*?@return?成功返回-1,?否則返回其他值
*/
int?sendMessage(String?mobile,?String?message);
}
這個接口很簡單, 只有一個方法. 這個方法用來發(fā)送短信.
同步發(fā)送短信
接下來我們首先實現(xiàn)一個同步發(fā)送短信的類:
IhuyiSmsImpl.java
public?class?IhuyiSmsImpl?implements?Sms?{
private?String?account;
private?String?password;
public?void?setAccount(String?account)?{
this.account?=?account;
}
public?void?setPassword(String?password)?{
this.password?=?password;
}
@Override
public?int?sendMessage(String?mobile,?String?message)?{
cn.ihuyi._106.Sms?factory?=?new?cn.ihuyi._106.Sms();
SmsSoap?smsSoap?=?factory.getSmsSoap();
SubmitResult?submit?=?smsSoap.submit(account,?password,?mobile,?message);
int?code?=?submit.getCode();
if(code?==?2){
return?-1;
}
System.out.println("發(fā)送短信失敗,?code:"?+?code);
return?code;
}
}
異步發(fā)送短信
由于發(fā)送短信涉及到網(wǎng)絡通信, 因此sendMessage方法可能會有一些延遲. 為了改善用戶體驗, 我們可以使用異步發(fā)送短信的方法. 原理很簡單: 如果用戶請求發(fā)送短信, 我們不是直接調(diào)用IhuyiSmsImpl的sendMessage方法, 而是將請求保存起來(生產(chǎn)者), 然后告訴用戶: 短信發(fā)送成功. 之后有若干個消費者取出任務, 調(diào)用sendMessage方法發(fā)送短信.
這里, 我使用線程池完成上面的任務:
AsyncSmsImpl.java
public?class?AsyncSmsImpl?implements?Sms?{
public?Sms?sendSms;
private?ExecutorService?executorService?=?Executors.newFixedThreadPool(3);
public?void?setSendSms(Sms?sendSms)?{
this.sendSms?=?sendSms;
}
@Override
public?int?sendMessage(String?mobile,?String?message)?{
try?{
executorService.submit(()?-?sendSms.sendMessage(mobile,?message));
}
catch(Exception?e)?{
Sysemt.out.println("提交任務時發(fā)生錯誤"?+?e);
return?0;
}
return?-1;
}
public?void?destroy(){
try{
executorService.shutdown();
}
catch(Exception?e){}
}
}
在第17行, 我們獲得遠程對象的一個代理對象. 之后就可以通過這個代理對象進行發(fā)送短信, 查詢賬戶余額等操作.
第18行, 使用該代理對象的submit方法提交了短信內(nèi)容. 該方法的參數(shù)信息及返回值含義在接口文檔中有詳細的說明.
第19行我們獲得了結(jié)果的狀態(tài)碼. 根據(jù)文檔上的說明, 狀態(tài)碼為2說明提交成功. 簡單起見, 這里我們只關注提交成功的情況. 需要注意的是, 狀態(tài)碼為2只是說明提交成功. 根據(jù)官網(wǎng)上的"3-5秒內(nèi)響應、100%到達", 我們可以推測. 如果提交成功, 那么基本上3-5秒內(nèi),短信就會發(fā)送成功, 根據(jù)用戶的網(wǎng)絡情況, 可能稍有延遲用戶就可以收到短信.
使用這段代碼發(fā)送短信也很簡單, 直接new一個對象, 設置好賬號和密碼就可以發(fā)送短信了.
代碼很簡單, 直接將Sms接口的sendMessage(mobile, message)方法作為一個任務加到線程池的任務隊列中. 這樣等到有空閑線程時, 就會執(zhí)行sendSms.sendMessage(mobile, message)發(fā)送短信. 這里我們假設只要保存到線程池就可以成功發(fā)送短信. 因為發(fā)送失敗的情況實際上很罕見.
JAVA實現(xiàn)短信群發(fā)的步驟：
1、使用第三方短信平臺服務商，接入短信服務；
2、調(diào)用短信提交頁面發(fā)送請求；
3、服務器向第三方短信平臺提交發(fā)送請求；
4、短信平臺通過運營商將短信下發(fā)至用戶的手機上。
以下是秒賽短信平臺JAVA短信驗證碼接口代碼示例
package test;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URISyntaxException;
import java.net.URLEncoder;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.lang3.StringUtils;
public class Apis {
// 短信發(fā)送接口的http地址，請咨詢客服
private static String url = “xxxxxxxxxxxxxxxxxxxxxxxxxxxx”;
// 編碼格式。發(fā)送編碼格式統(tǒng)一用UTF-8
private static String ENCODING = “UTF-8”;
public static void main（String[] args） throws IOException, URISyntaxException {
// 賬號
String account = “************************”;
// 密碼
String pswd = “************************”;
// 修改為您要發(fā)送的手機號，多個用，分割
String mobile = “13*********”;
// 設置您要發(fā)送的內(nèi)容
String msg = “【秒賽科技】您的驗證碼是：1234”;
// 發(fā)短信調(diào)用示例
System.out.println（Apis.send（account,pswd, mobile, msg））；
}
/**
* 發(fā)送短信
*
* @param account
* ? ? ? ? ? ?account
* @param pswd
* ? ? ? ? ? ?pswd
* @param mobile
* ? ? ? ? ? ?手機號碼
* @param content
* ? ? ? ? ? ?短信發(fā)送內(nèi)容
*/
public static String send（String account,String pswd, String mobile, String msg） {
NameValuePair[] data = { new NameValuePair（“account”, account），
new NameValuePair（“pswd”, pswd），
new NameValuePair（“mobile”, mobile），
new NameValuePair（“msg”, msg），
new NameValuePair（“needstatus”, “true”），
new NameValuePair（“product”, “”） };
return doPost（url, data）；
}
/**
* 基于HttpClient的post函數(shù)
* PH
* @param url
* ? ? ? ? ? ?提交的URL
*
* @param data
* ? ? ? ? ? ?提交NameValuePair參數(shù)
* @return 提交響應
*/
private static String doPost（String url, NameValuePair[] data） {
HttpClient client = new HttpClient（）；
PostMethod method = new PostMethod（url）；
// method.setRequestHeader（“ContentType”,
// “application/x-www-form-urlencoded;charset=UTF-8”）；
method.setRequestBody（data）；
// client.getParams（）。setContentCharset（“UTF-8”）；
client.getParams（）。setConnectionManagerTimeout（10000）；
try {
client.executeMethod（method）；
return method.getResponseBodyAsString（）；
} catch （Exception e） {
e.printStackTrace（）；
}
return null;
}
}
package?com.winhands.quartz;
import?java.io.PrintWriter;
import?java.io.StringWriter;
import?java.io.UnsupportedEncodingException;
import?java.util.ArrayList;
import?java.util.Date;
import?java.util.HashMap;
import?java.util.List;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?com.winhands.base.service.BaseService;
import?com.winhands.util.BaseConstant;
import?com.winhands.web.dict.entity.DictCommon;
import?com.winhands.web.xfhf.entity.SmsOutBox;
import?com.winhands.web.xfhf.entity.SmsVisit;
import?com.winhands.web.xfhf.entity.TaskInfo;
public?class?SmsSendSync?{
public?BaseService?baseService;
public?BaseService?baseServiceMas;
public?static?final?Logger?logger?=?LoggerFactory.getLogger(SmsSendSync.class);
//同步短信到mas機待發(fā)短信表
public?void?work()?{
//?任務ID?100001
//?首先查詢?nèi)蝿帐欠裾趫?zhí)行
//?查詢列表
TaskInfo?taskInfo?=?new?TaskInfo();
taskInfo.setTask_id("100001");
try?{
taskInfo?=?(TaskInfo)?baseService.queryForObject("sms_send.queryTaskStatus",?taskInfo);
//如果狀態(tài)是處室狀態(tài)則執(zhí)行，否則此次任務不執(zhí)行
if?(BaseConstant.task_status_cs.equals(taskInfo.getTask_status()))?{
taskInfo.setTask_status(BaseConstant.task_status_zx);//設置任務執(zhí)行狀態(tài)為執(zhí)行
taskInfo.setTask_last_start_time(new?Date());//設置任務執(zhí)行開始時間
baseService.update("sms_send.updateTaskStatus",?taskInfo);//
//移動號碼庫
HashMapString,String?hashMap?=?new?HashMapString,String();
//134?、135、136、137、138、139、150、151、152、158、159、182、183、184。157、187、188
hashMap.put("134",?"134");
hashMap.put("135",?"135");
hashMap.put("136",?"136");
hashMap.put("137",?"137");
hashMap.put("138",?"138");
hashMap.put("139",?"139");
hashMap.put("150",?"150");
hashMap.put("151",?"151");
hashMap.put("152",?"152");
hashMap.put("157",?"157");
hashMap.put("158",?"158");
hashMap.put("159",?"159");
hashMap.put("182",?"182");
hashMap.put("183",?"183");
hashMap.put("184",?"184");
hashMap.put("187",?"187");
hashMap.put("188",?"188");
SmsVisit?smsSend?=?new?SmsVisit();
smsSend.setSms_status(BaseConstant.sms_status_csh);
List?list?=?baseService.queryForList("sms_send.queryForSmsTask",?smsSend);
List?smsMasList?=?new?ArrayList();
List?smsList?=?new?ArrayList();
if?(list?==?null||list.size()==0)?return;//?如果列表為空，沒有待辦任務，則任務結(jié)束
for?(int?i?=?0;?i??list.size();?i++)?{
smsSend?=?(SmsVisit)?list.get(i);
//String?msg?=?messagecontent(smsSend);
String?msg?=?smsSend.getSpare_2();
if(hashMap.get(smsSend.getVisit_phone().substring(0,?3))!=null){
SmsOutBox?smsOutBox?=?new?SmsOutBox();
smsOutBox.setSismsid(smsSend.getP_id());
smsOutBox.setReqdeliveryreport(BaseConstant.NoReport);
smsOutBox.setApplicationid(BaseConstant.APPLICATIONID);
smsOutBox.setDestaddr(smsSend.getVisit_phone());
smsOutBox.setMsgfmt(BaseConstant.MSGFMT);
smsOutBox.setRequesttime(new?Date());
smsOutBox.setExtcode(smsSend.getExtccode());
smsOutBox.setSendmethod(BaseConstant.NoMsg);//?正常短信
smsOutBox.setMessagecontent(msg);
smsMasList.add(smsOutBox);
}else{
boolean?con?=?true;
String?lastMsg?=?msg;
int?xh?=0;
while(con){
lastMsg?=?msg.substring(0,msg.length()??55???55?:?msg.length());
msg?=?msg.substring(msg.length()??55???55?:?msg.length(),msg.length());
if?(msg.equals(""))?{
con?=?false;
}
SmsOutBox?smsOutBox?=?new?SmsOutBox();
smsOutBox.setSismsid(smsSend.getP_id()+(xh==0?"":xh));
xh++;
smsOutBox.setReqdeliveryreport(BaseConstant.NoReport);
smsOutBox.setApplicationid(BaseConstant.APPLICATIONID);
smsOutBox.setDestaddr(smsSend.getVisit_phone());
smsOutBox.setMsgfmt(BaseConstant.MSGFMT);
smsOutBox.setRequesttime(new?Date());
smsOutBox.setExtcode(smsSend.getExtccode());
smsOutBox.setSendmethod(BaseConstant.NoMsg);//?正常短信
smsOutBox.setMessagecontent(lastMsg);
smsMasList.add(smsOutBox);
}
}
SmsVisit?smsSendTemp?=?new?SmsVisit();
smsSendTemp.setP_id(smsSend.getP_id());?
//smsSendTemp.setSpare_2(msg);//短信內(nèi)容
smsSendTemp.setSms_status_time(new?Date());
smsSendTemp.setSms_status(BaseConstant.sms_status_yfswg);?
smsList.add(smsSendTemp);
}
baseService.insertBatch("sms_send.insertSmsOutBox",?smsMasList);//插入本地歷史記錄表
baseServiceMas.insertBatch("sms_mas.insertSmsOutBox",?smsMasList);//插入mas機待發(fā)送表
baseService.updateBatch("sms_send.updateSmsVisit",?smsList);//更新回訪記錄狀態(tài)
}
}?catch?(Exception?e)?{
e.printStackTrace();
//baseService.saveLog("同步短信到mas機待發(fā)短信表",?"100001",?"同步短信到mas機待發(fā)短信表錯誤");
logger.error("同步短信到mas機待發(fā)短信表錯誤",?getTrace(e));
}finally{
try?{
taskInfo.setTask_status(BaseConstant.task_status_cs);//設置任務執(zhí)行狀態(tài)為初始
taskInfo.setTask_last_end_time(new?Date());//設置任務執(zhí)行結(jié)束時間
taskInfo.setTask_status_desc("任務執(zhí)行結(jié)束");
baseService.update("sms_send.updateTaskStatus",?taskInfo);//
}?catch?(Exception?e2)?{
e2.printStackTrace();
//?TODO:?handle?exception
}
}
}
public?String?messagecontent(SmsVisit?smsSend){
//XX，您好！您于XX月XX日辦理XX業(yè)務(或XX，您好！XX大隊于XX月XX日對你單位進行監(jiān)督檢查/行政處罰/火災調(diào)查)，現(xiàn)進行滿意度回訪，請回復數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對消防工作的支持！回復免費。宿遷市公安消防支隊
//首先根據(jù)業(yè)務類型來判斷采用哪種模板?監(jiān)察
StringBuffer?msg?=?new?StringBuffer("");?
if(BaseConstant.jiancha.equals(smsSend.getVisit_deal_business_type())){
msg.append(smsSend.getVisit_name_cn())
???.append(",您好!")
???.append(smsSend.getVisit_deal_org_name())
???.append("于")
???.append(smsSend.getVisit_deal_time().substring(4,?6)).append("月")
???.append(smsSend.getVisit_deal_time().substring(6,?8)).append("日")
???.append("對你單位進行").append(DictCommon.getEntryMap(BaseConstant.jiancha).get(smsSend.getVisit_deal_business()))
???.append(",現(xiàn)進行滿意度回訪，請回復數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對消防工作的支持！");
}else?if(BaseConstant.yewu.equals(smsSend.getVisit_deal_business_type())){
msg.append(smsSend.getVisit_name_cn())
???.append(",您好!您于")
???.append(smsSend.getVisit_deal_time().substring(4,?6)).append("月")
???.append(smsSend.getVisit_deal_time().substring(6,?8)).append("日")
???.append("辦理").append(smsSend.getVisit_deal_business()).append("業(yè)務,")
???.append("現(xiàn)進行滿意度回訪，請回復數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對消防工作的支持！");
}
return?msg.toString();
}
public?BaseService?getBaseService()?{
return?baseService;
}
public?void?setBaseService(BaseService?baseService)?{
this.baseService?=?baseService;
}
public?BaseService?getBaseServiceMas()?{
return?baseServiceMas;
}
public?void?setBaseServiceMas(BaseService?baseServiceMas)?{
this.baseServiceMas?=?baseServiceMas;
}
public?static?void?main(String[]?args){
List?smsMasList?=?new?ArrayList();?
try?{
String?msg?=?"***，您好！*********于2015年5月2日對你單位進行監(jiān)督檢查，現(xiàn)進行滿意度回訪，請回復數(shù)字：1為滿意；2為基本滿意；3為不滿意。感謝您對消防工作的支持！";
SmsOutBox?smsOutBox?=?new?SmsOutBox();
smsOutBox.setSismsid("12344");
smsOutBox.setReqdeliveryreport(BaseConstant.NoReport);
smsOutBox.setApplicationid(BaseConstant.APPLICATIONID);
smsOutBox.setDestaddr("111");
smsOutBox.setMsgfmt(BaseConstant.MSGFMT);
smsOutBox.setRequesttime(new?Date());
smsOutBox.setExtcode("2222");
smsOutBox.setSendmethod(BaseConstant.NoMsg);//?正常短信
boolean?con?=?true;
String?lastMsg?=?msg;
while(con){
lastMsg?=?msg.substring(0,msg.length()??55???55?:?msg.length());
msg?=?msg.substring(msg.length()??55???55?:?msg.length(),msg.length());
if?(msg.equals(""))?{
con?=?false;
}
SmsOutBox?smOutBox_temp?=?new?SmsOutBox();?
smOutBox_temp?=?smsOutBox;
smOutBox_temp.setMessagecontent(lastMsg);
?
smsMasList.add(smOutBox_temp);
}
for(Object?o:smsMasList){
SmsOutBox?smsOutBox2?=?(SmsOutBox)o;
System.out.println(smsOutBox2.getMessagecontent());
}
}?catch?(Exception?e)?{
//?TODO?Auto-generated?catch?block
e.printStackTrace();
}
}
public?static?String?getTrace(Throwable?t)?{
StringWriter?stringWriter=?new?StringWriter();
PrintWriter?writer=?new?PrintWriter(stringWriter);
t.printStackTrace(writer);
StringBuffer?buffer=?stringWriter.getBuffer();
return?buffer.toString();
}
}
短信不是你想發(fā)??想發(fā)就能發(fā)，是收費的，我們公司是租用的移動MAS平臺的短信發(fā)送接收平臺，上面那是和一個和mas同步的一個小程序，租用別人的mas平臺是收費的，平臺有很多自己選擇，有發(fā)送接口可以調(diào)，發(fā)送內(nèi)容自己提供
1.通過移動或聯(lián)通短信網(wǎng)關發(fā)送短信，這需要通信服務商給你開通短信端口，發(fā)送短信協(xié)議各個服務商都不一樣，比如移動的是cmpp2，cmpp3等
2.第二種是通過硬件設備發(fā)送短信，這個需要你有專門的硬件設備，比如一個上網(wǎng)卡或者一個手機模塊,通過調(diào)用com遵從一些協(xié)議發(fā)送短信
單純靠寫代碼是無法發(fā)短信的，至少要有一個WEBSERVICE接口或者硬件接口。
重慶分公司
重慶分公司
