1. 首页
  2. 文章中心
  3. smslib

SMSLIB接入系统开发

71 阅读 0 评论
我是靠谱客的博主 美好野狼，最近开发中收集的这篇文章主要介绍SMSLIB接入系统开发，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

最近项目中，需要用到smslib，在研究了两天之后，在这里写下一些心得，大家相互学习与交流。

一、前期工作
1. 准备工作：
a) 下载开源代码smslib.
b) 下载串口驱动包 javacomm20-win32
2. 环境配置：
在javacomm20-win32内找到comm.jar,win32com.dll,javac.com.propertites
%JAVA_HOME%jrelibext 下面放 comm.jar
%JAVA_HOME%bin 下面放win32com.dll
%JAVA_HOME%jrelib 下面放 javax.comm.properties
3. 测试环境是否配置成功：
打开命令行工具，到路径为：E:javacomm20-win32commapisamplesBlackBox
输入命令 java BlackBox:
a. 如果有界面产生，环境配置成功。
b. 如果显示找不到某一个类，可能是jdk环境变量的问题。
c. 如果显示找不到端口，那么步骤2出错。
二、服务类接口编写

包含方法：
Method1:int readMessage(MessageClasses classes,Llist<InBoundMessage> msgs);
Param1: 包含3种类别READ,UNREAD,ALL。
Param2: 读到消息所放容器。
Return : 返回数据条数。
Method2:Boolean sendMessage(String mobileNum,String content);
Param1: 要发送的电话号码。
Param2: 要发送的内容。
Return : true|false
Method3:Boolean deleteMessage(InBoundMessage msg);
Param1: 要删除的消息
Return: true|false
Mehtod4:void deleteMessages(List<InBoundMessage> msgs);
Params1: 要删除的消息
2. 包含变量：
Variable1:String smsInfos; sms信息
Format: simNum#gateId#comNum#baud#factory#SMS_centor;
Variable2:SmsMessageProcessor processor;
Method: public Boolean process(InboundMessage msg);
userFor:用于处理收到的消息，使用的人实现处理类。
3. 工作线程:
由于InboundNotification测试过程中，不能达到要求，只能写一个线程，一直读sms的内容。 


		While(true){
	       readMessage(ALL,msgs);
	       for(InboundMessage msg:msgs){
	       processor.process(msg);
               deleteMessage(msg);
                }
              Thread.sleep(1000);
}

这里需要注明一下：本来想利用InboundNotification,每当有消息进来，就使用processor去处理，可是，后来测试发现，这个类，使用起来不是特别灵活，无法做到，已有消息就进入，这里如果有知道的朋友，可以指导一下我。
下面将代码贴上。
启动类。 
package cn.hexing.sms;

import cn.hexing.sms.processor.DefaultSmsMsgProcessor;


public class Start {
	public static void main(String[] args) throws Exception {
		SmsService.getInstance().setSmsInfos("+8613989464741#modem.com3#COM3#115200#Simcom#+8613800571500");

		SmsService.getInstance().setProcessor(new DefaultSmsMsgProcessor());

		SmsService.getInstance().startService();
	}

}

Sms服务类 
package cn.hexing.sms;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import javax.crypto.spec.SecretKeySpec;

import org.smslib.AGateway;
import org.smslib.AGateway.GatewayStatuses;
import org.smslib.AGateway.Protocols;
import org.smslib.GatewayException;
import org.smslib.ICallNotification;
import org.smslib.IGatewayStatusNotification;
import org.smslib.IInboundMessageNotification;
import org.smslib.IOrphanedMessageNotification;
import org.smslib.IOutboundMessageNotification;
import org.smslib.InboundMessage;
import org.smslib.InboundMessage.MessageClasses;
import org.smslib.Message.MessageEncodings;
import org.smslib.Message.MessageTypes;
import org.smslib.OutboundMessage;
import org.smslib.SMSLibException;
import org.smslib.Service;
import org.smslib.TimeoutException;
import org.smslib.crypto.AESKey;
import org.smslib.modem.SerialModemGateway;

import cn.hexing.sms.processor.DefaultSmsMsgProcessor;
import cn.hexing.sms.processor.SmsMsgProcessor;

public class SmsService {

	private static SmsService instance;

	private Service smsService;

	/**消息处理器*/
	private SmsMsgProcessor processor = new DefaultSmsMsgProcessor();

	/**
	 * formate: simNum#gateId#comNum#baud#factory#SMS_centor;
	 **/
	private String smsInfos;

	private SmsService(){
	}



	public synchronized static SmsService getInstance(){
		if (instance == null)
			instance = new SmsService();
		return instance;
	}

	public void stopService() throws Exception{
		smsService.stopService();
	}

	public void startService() throws Exception{

		smsService = Service.getInstance();

		InboundNotification inboundNotification = new InboundNotification();

		CallNotification callNotification = new CallNotification();

		GatewayStatusNotification statusNotification = new GatewayStatusNotification();

		OrphanedMessageNotification orphanedMessageNotification = new OrphanedMessageNotification();

		smsService.setInboundMessageNotification(inboundNotification);

		smsService.setCallNotification(callNotification);

		smsService.setGatewayStatusNotification(statusNotification);

		smsService.setOrphanedMessageNotification(orphanedMessageNotification);

		OutboundNotification outboundNotification = new OutboundNotification();

		smsService.S.SERIAL_POLLING = true;

		smsService.setOutboundMessageNotification(outboundNotification);

		String[] infos=smsInfos.split(";");
		for(String info : infos){

			String[] infomation = info.split("#");

			SerialModemGateway gateway = new SerialModemGateway(infomation[1], infomation[2], Integer.parseInt(infomation[3]), infomation[4], "");

			gateway.setProtocol(Protocols.PDU);

			gateway.setInbound(true);

			gateway.setOutbound(true);

			gateway.setSimPin("0000");

			gateway.setSmscNumber(infomation[5]); //短信中心号码+8613800571500
													//当前sim卡号码
			smsService.getKeyManager().registerKey(infomation[0], new AESKey(new SecretKeySpec("0011223344556677".getBytes(), "AES")));

			smsService.addGateway(gateway);
		}


		smsService.startService();

		//启动读线程
		new WorkThread().start();
	}
	/**
	 * @param messageClasses  消息类，READ,UNREAD,ALL,读到的消息，直接删除了。
	 * @throws TimeoutException
	 * @throws GatewayException
	 * @throws IOException
	 * @throws InterruptedException
	 */
	public int readMessages(MessageClasses messageClasses,List<InboundMessage> msgList) throws Exception{
		return smsService.readMessages(msgList,messageClasses);
	}
	/**
	 * 批量删除消息
	 * @param msgs
	 */
	public void deleteMessages(List<InboundMessage> msgs) {
		for(InboundMessage msg:msgs){
			deleteMessage(msg);
		}
	}

	/**
	 * 删除一个消息
	 * @param msg
	 * @return
	 */
	public boolean deleteMessage(InboundMessage msg) {
		try {
			return this.smsService.deleteMessage(msg);
		} catch (TimeoutException e) {
		} catch (GatewayException e) {
		} catch (IOException e) {
		} catch (InterruptedException e) {
		}
		return false;
	}
	/**
	 * @param mobileNum 要发送的手机号码
	 * @param content	内容
	 * @return
	 * @throws TimeoutException
	 * @throws GatewayException
	 * @throws SMSLibException
	 * @throws IOException
	 * @throws InterruptedException
	 */
	public boolean sendMessage(String mobileNum,String content) throws Exception{
		OutboundMessage message = new OutboundMessage(mobileNum,content);
		message.setEncoding(MessageEncodings.ENCUCS2);
		return smsService.sendMessage(message);
	}

	public class InboundNotification implements IInboundMessageNotification
	{
		public void process(AGateway gateway, MessageTypes msgType, InboundMessage msg)
		{
//			if (msgType == MessageTypes.INBOUND) System.out.println(">>> New Inbound message detected from Gateway: " + gateway.getGatewayId());
//			else if (msgType == MessageTypes.STATUSREPORT) System.out.println(">>> New Inbound Status Report message detected from Gateway: " + gateway.getGatewayId());
		}
	}

	public class CallNotification implements ICallNotification
	{
		public void process(AGateway gateway, String callerId)
		{
//			System.out.println(">>> New call detected from Gateway: " + gateway.getGatewayId() + " : " + callerId);
		}
	}

	public class GatewayStatusNotification implements IGatewayStatusNotification
	{
		public void process(AGateway gateway, GatewayStatuses oldStatus, GatewayStatuses newStatus)
		{
			//System.out.println(">>> Gateway Status change for " + gateway.getGatewayId() + ", OLD: " + oldStatus + " -> NEW: " + newStatus);
		}
	}

	public class OrphanedMessageNotification implements IOrphanedMessageNotification
	{
		public boolean process(AGateway gateway, InboundMessage msg)
		{
			//System.out.println(">>> Orphaned message part detected from " + gateway.getGatewayId());
			//System.out.println(msg);
			// Since we are just testing, return FALSE and keep the orphaned message part.
			return false;
		}
	}
	public class OutboundNotification implements IOutboundMessageNotification
	{
		public void process(AGateway gateway, OutboundMessage msg)
		{
			//System.out.println("Outbound handler called from Gateway: " + gateway.getGatewayId());
			//System.out.println(msg);
		}
	}

	class WorkThread extends Thread{

		@Override
		public void run() {
			while(true){

				try {
					List<InboundMessage> msgs = new ArrayList<InboundMessage>(); 
					readMessages(MessageClasses.ALL,msgs);
					for(InboundMessage msg:msgs){
						processor.process(msg);
						deleteMessage(msg);
					}
					Thread.sleep(1000);
				} catch (Exception e1) {
					e1.printStackTrace();
				}
			}
		}


	}

	public final SmsMsgProcessor getProcessor() {
		return processor;
	}


	public final void setProcessor(SmsMsgProcessor processor) {
		this.processor = processor;
	}


	public final String getSmsInfos() {
		return smsInfos;
	}


	public final void setSmsInfos(String smsInfos) {
		this.smsInfos = smsInfos;
	}
}

processor接口 
package cn.hexing.sms.processor;

import org.smslib.InboundMessage;

public interface SmsMsgProcessor {
	public boolean process(InboundMessage msg);
}

默认实现的processor类 
package cn.hexing.sms.processor;

import org.smslib.InboundMessage;

public class DefaultSmsMsgProcessor implements SmsMsgProcessor{

	@Override
	public boolean process(InboundMessage msg) {
		System.out.println(msg.getText());
		return false;
	}

}

最后

以上就是美好野狼为你收集整理的SMSLIB接入系统开发的全部内容，希望文章能够帮你解决SMSLIB接入系统开发所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(47)

相关文章

JAVA 短信API接口调用 附 文档 Demo
JAVA 短信API接口调用 附 文档 Demo
找不到类型*它在 ServiceHost 指令中提供为 Service 特性值，或在配置元素 *serviceModel/serviceHostingEnvironment/serviceActiva
找不到类型*它在 ServiceHost 指令中提供为 Service 特性值，或在配置元素 *serviceModel/serviceHostingEnvironment/serviceActiva
java发送串口命令_用 Java 通过串口发送手机短信
java发送串口命令_用 Java 通过串口发送手机短信
用Java通过串口发送手机短信
用Java通过串口发送手机短信
SMSLIB接入系统开发
SMSLIB接入系统开发
使用SMSLib发短信（收集）
使用SMSLib发短信（收集）
短信猫（GSM MODEM）linux64_Java开发指南
短信猫（GSM MODEM）linux64_Java开发指南
java message包_outboundmessage.java 源代码在线查看 - java平台 smslib 短 信 开 发 包 资源下载 虫虫电子下载站...
java message包_outboundmessage.java 源代码在线查看 - java平台 smslib 短 信 开 发 包 资源下载 虫虫电子下载站...

评论列表共有 0 条评论

立即
投稿
返回
顶部