08年了，我也把07年所做的工作总结一下。望各位朋友不吝指教。
一、名词解释
SMPP：短消息点对点协议，SMPP协议是一个国际标准，有SMS论坛制定，官方网址为smsforum.net，截至2006年7月2日，最新版本是5.0。曾经流行的版本是3.3、3.4。SMPP协议向后兼容的。
SMC：短消息服务中心
ECME：扩展短消息实体
二、简要介绍
基于SMPP协议研发的互通短信网关，所有unicom发向中国移动和中国电信的短信都通过此系统提交给unicom互通短信网关，系统角色为SMC，unicom充当ECME，由SMSC主动下发短消息(DeliverSM)给unicom短信中心，设计速度为250条/秒（运营商规定）。
系统采用spring进行ioc配置，h2内存数据库，数据库访问采用spring jdbc，基于多线程和Socket编程。
主要程序介绍：
三、主体程序介绍
SMSCService：系统启动的主程序，实现启动、暂停监听服务，启动暂停消息下发服务功能。
while (keepRunning) {
System.out.println();
System.out.println("- 1 start listener");
System.out.println("- 2 stop listener");
System.out.println("- 3 client");
System.out.println("- 4 start deliverMessage");
System.out.println("- 5 stop deliverMessage");
System.out.println("- 0 exit");
System.out.print("> ");
optionInt = -1;
try {
option = keyboard.readLine();
optionInt = Integer.parseInt(option);
} catch (Exception e) {
optionInt = -1;
}
switch (optionInt) {
case 1:
startlistener();
break;
case 2:
stoplistener();
break;
case 3:
listclienter();
break;
case 4:
startdeliverMessage();
break;
case 5:
stopdeliverMessage();
SMSCListener：服务监听程序，当ECME连接上SMC后，生成SMSCSession。
public synchronized void start() throws IOException {
debug.write("going to start SMSCListener on port " + port);
if (!isReceiving) {
serverConn = new com.logica.smpp.TCPIPConnection(port);
serverConn.setReceiveTimeout(getAcceptTimeout());
serverConn.open();
keepReceiving = true;
if (asynchronous) {
debug.write("starting listener in separate thread.");
Thread serverThread = new Thread(this);
serverThread.start();
debug.write("listener started in separate thread.");
} else {
debug.write("going to listen in the context of current thread.");
run();
}
} else {
debug.write("already receiving, not starting the listener.");
}
}
try {
Connection connection = null;
serverConn.setReceiveTimeout(getAcceptTimeout());
connection = serverConn.accept();
if (connection != null) {
SMSCSession session = new SMSCSession(connection);
session.setHashSet(hashSet);
Thread thread = new Thread(session);
thread.start();
sessionFactory.register(session);
debug.write("SMSCListener launched a session on the accepted connection.");
} else {
debug.write("no connection accepted this time.");
}
} catch (InterruptedIOException e) {
debug.write("InterruptedIOException accepting, timeout? -> " + e);
} catch (IOException e) {
event.write(e, "IOException accepting connection");
keepReceiving = false;
}
SMSCSession：实现ECME连接上来的消息解码，调度相应的服务（接受消息或发送消息）。
if (calendar.getTimeInMillis() < (enquire_LinkTime + enquire_LinkTimeout * 1000)) {
//判断是否连接超时
try {
debug.write("SMSCSession going to receive a PDU");
pdu = receiver.receive(getReceiveTimeout());
} catch (Exception e) {
debug
.write("SMSCSession caught exception receiving PDU "
+ e.getMessage());
}
if (pdu != null) {
if (pdu.isRequest()) {
debug.write("SMSCSession got request "
+ pdu.debugString());
requestWorker.clientRequest((Request) pdu);
} else if (pdu.isResponse()) {
debug.write("SMSCSession got response "
+ pdu.debugString());
requestWorker.clientResponse((Response) pdu);
} else {
debug
.write("SMSCSession not reqest nor response => not doing anything.");
}
}
}else
{
keepReceiving=false;
}
RequestWorker：处理ECME和SMC之间的消息，缋SUBMIT_SM,SUBMIT_MULTI,ENQUIRE_LINK等消息。
// TODO 根据业务规则进行用户合法性验证
commandStatus = checkIdentity((BindRequest) request);
if (commandStatus == 0) { // authenticated
System.out.println(request.debugString());
BindResponse bindResponse = (BindResponse) request
.getResponse();
serverResponse(bindResponse);
// success => bound
bound = true;
} else { // system id not authenticated
// get the response
response = request.getResponse();
// set it the error command status
response.setCommandStatus(commandStatus);
// and send it to the client via serverResponse
serverResponse(response);
// bind failed, stopping the session
session.stop();
}
ResponseWorker：处理DELIVER_RESP消息，与发送消息的时间进行对比，实现超时重发和保存消息预处理。
if (isOutTime(sendsm.getDealTime())) {// dealTime如果没有填写，此时永远处理不到
sendsm.setState(SendSM.STATE_SMSC_FAIL);
reportFailQueue.put(sendsm, 100);
//分类保存
if (sendsm.getMessageType() == SendSM.MESSAGETYPE_CORP) {
reportQueue.put(sendsm, 100);
} else if (sendsm.getMessageType() == SendSM.MESSAGETYPE_CLIENT) {
reportQueue_P.put(sendsm, 100);
}
} else {
// 重新压回接收队列
deliverQueue.put(sendsm, 100);
}
DeliverMessage：从发送队列里取出待发短信，提交DELIVERSM消息至RequestWorker，由RequestWorker下发消息至ECME.
while (list != null && list.size() > 0) {
try {
sendsm = list.remove(list.size() - 1);
if (sendsm != null) {
deliverSM = this.convertSendsm(sendsm);
} else {
deliverSM = null;
}
if (deliverSM != null) {
if (session.send(deliverSM)) {
SMSCLog.SendLog(deliverSM);
sendsm.setSequenceNumber(String
.valueOf(deliverSM
.getSequenceNumber()));
sendsm.setDealTime(DataFormat.yyyy_MM_dd_HH_mm_ss
.format(new Date()));
deliverQueue.put(sendsm, 1000);
}
}
Thread.sleep(intervalTime);
} catch (Exception e) {
log.error(e.getMessage(), e);
}
}
SaveService：基于spring jdbc实现的批量取出消息和批量保存的DAO实现。
count = saveQueue.drainTo(list, batchSize);
if (logger.isDebugEnabled()) {
logger.debug("get element count["+count+"] from saveQeueue.");
}
if (count > 0) {
int total = batchSave.batachSave(list);
if (logger.isDebugEnabled()) {
logger.debug("Save ["+total+"] records.");
}
}
if (count < batchSize) {
if (logger.isDebugEnabled()) {
logger.debug("sleep "+sleepTime);
}
//小于0, 休眠
Thread.sleep(sleepTime);
} else {
Thread.yield(); //让其他程序有机会运行
}
其它若干辅助类，就不一一介绍了。
因为时间比较紧，系统是在logica smsc的基础修改完成的，本人1周完成。主是加入了业务所需要的东西。因涉及非技术问题，此处只取了一部份代码。
ps:
做这个项目的时候，主要是为适应xx省smsc经过huiway改造之后的话单分检，大家开始都没有注意有可能出现这种情况，时间紧（大约只有1周时间），压力大（自己以前还没有smsc角色的程序,对smpp中的DeliverSM消息不太熟，后来果然在上面载了跟头，测试时总发现下发出去的消息是乱码，反复测试，编码格式也换了9种，后来才发现有个DeliverSM中的setDataCoding没有设置，郁闷），经过自己的努力和同事的帮助。基本上在一周内完成，包括测试用例。
现在这个系统已上线，到目前为止已正常运行2个月，从未出现过大问题。运行平台为redhat enterprise 4。
分享到：
相关推荐
由于本人疏忽，此代码有误，请勿下载，之前下载的朋友抱歉抱歉，如有需要请留邮箱，我可直接发送至邮箱。
20130608更新的Unicom IP
UNICOM是工厂flash站常用的编程工具，资料来自CSM的官方网站。
让小米伙伴用着顺手的工具
new-unicom-sign
Unicom-Mini 是一款实现中国联通MINI电子营业厅设备的业务功能；该项目主要由客户端和服务器组成。客户端主要有购买电子卡，充值缴费，话费查询等功能，服务器主要是接收客户端发过来的业务包，然后查询数据后再把...
com.sinovatech.unicom.ui.apk
推荐使用github免费提供动作机制执行脚本，联通手厅签到用户请自行添加秘钥参数（ 然后单击“新存储库秘密”） ENABLE_UNICOM（填true） sckey（服务酱） unicom_password（服务密码） unicom_user（手机号） ...
这是运营商ipcc文件，版本号40.1，适用于IOS12系统，硬件IPHONE 8PLUS，本版本可以搞定低版本系统联通volte
Windows unicom
Unicom_ShouJiYingYeTing.apk
中国联通 China Unicom2022年发布的通信相关白皮书
联通 这是联通IG 出版物 本实施指南在以下位置发布： 连续构建： : 规范/永久网址： 问题 在这里管理问题和变更请求： 问题： : 看板板： :
unicom.dll
由Unicom Solutions支持的集成 Unicom Solutions API集成平台可提供数据库驱动的屏幕弹出窗口。 Unicom Solutions应用程序使用API（Salesforce.com，Zendesk等）与后台应用程序集成。通过利用API，Unicom ...
ChinaUnicom无线网连接工具，可以便捷的帮你连接联通无线网，专门应对获取不到IP的情况！
pac_segabj_unicom.txt
88-自动签名机 联通挂机任务积分脚本 推荐使用github免费提供动作机制执行脚本，联通手厅签到用户请自行添加... unicom_user（手机号） unicom_appid（ 开抓包你再打开手厅可以找到了） NOTIFY_SCKEY（服务酱得key）