标签:des style blog http color java 使用 os
用java实现短信收发的功能,目前一般项目中短信群发功能的实现方法大致有下面三种:
· 1、 向运行商申请短信网关,不需要额外的设备,利用运行商提供的API调用程序发送短信,适用于大型的通信公司。
· 2、 借助像GSM MODEM之类的设备(支持AT指令的手机也行),通过数据线连接电脑来发送短信,这种方法比较适用于小公司及个人。要实现这种方式必须理解串口通信、AT指令、短信编码、解码。
· 3、 借助第三方运行的网站实现,由网站代发短信数据,这种方法对网站依赖性太高,对网络的要求也比较高。
SMSLib官方网站:http://smslib.org/,使用SMSLib的一些基本要点:
· SUN JDK 1.6 or newer. (Java环境)
· Java CommunicationsLibrary. (Java串口通信)
· Apache ANT for building thesources. (编译源码时需要的)
· Apache log4j. (日志工具)
· Apache Jakarta Commons -NET. (网络操作相关的)
· JSMPP Library (SMPP协议时需要的)
有关Java串口通信需要补充说明:
· window系统可以用SUN Java Comm v2. (该版本好像也支持solaris)
其下载地址:http://smslib.googlecode.com/files/javacomm20-win32.zip
· 其他操作系统(比如:Linux, Unix, BSD,等等),你可以选择 Java Comm v3 或者是RxTx。
Java Comm v3下载地址:http://java.sun.com/products/javacomm/(需要注册);
RxTx官网:http://users.frii.com/jarvi/rxtx/index.html or http://rxtx.qbang.org/wiki/index.php/Main_Page
附件提供相关下载:
· java串口通信v2:javacomm20-win32.zip
· 短信modem驱动:PL2303_Prolific_DriverInstaller_v130.zip
本次测试的环境是window,GSM modem是wavecom,所以这次主要描述window环境下简单的实现过程:
【一】、配置相应的环境
首先解压下载的Java Comm v2文件javacomm20-win32.zip,具体配置步骤如下:
· 把文件:comm.jarcopy 到目录:JDKDIR/jre/lib/ext/,当然这一步也可以不要这样做,你只需把comm.jar copy到所要运行的项目对应的lib/下既可
· 把文件:javax.comm.propertiescopy 到目录:JDKDIR/jre/lib/
· 把DLL文件:win32com.dll(windows) copy 到目录:JDKDIR/jre/bin/
如果存在JRE目录, 最好安装上面步骤把文件copy到JREDIR相应的目录下测试串口端口程序:
Test .java
Java代码
package test; import java.util.Enumeration; import javax.comm.CommDriver; import javax.comm.CommPortIdentifier; import javax.comm.SerialPort; public class Test { public static void main(String[] args) throws Exception { // 人工加载驱动 // MainTest.driverInit(); Test.getCommPortList(); // 人工加载驱动获取端口列表 // TestGetPortList.getPortByDriver(); } /** * 手工加载驱动<br> * 正常情况下程序会自动加载驱动,故通常不需要人工加载<br> * 每重复加载一次,会把端口重复注册,CommPortIdentifier.getPortIdentifiers()获取的端口就会重复 */ public static void driverManualInit() { String driverName = "com.sun.comm.Win32Driver"; String libname = "win32com"; CommDriver commDriver = null; try { System.loadLibrary("win32com"); System.out.println(libname + " Library Loaded"); commDriver = (javax.comm.CommDriver) Class.forName(driverName) .newInstance(); commDriver.initialize(); System.out.println("comm Driver Initialized"); } catch (Exception e) { System.err.println(e); } } /** * 获取端口列表 */ public static void getCommPortList() { CommPortIdentifier portId; Enumeration portEnum = CommPortIdentifier.getPortIdentifiers(); while (portEnum.hasMoreElements()) { portId = (CommPortIdentifier) portEnum.nextElement(); if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) { System.out.println("串口: name-" + portId.getName() + " 是否占用-" + portId.isCurrentlyOwned()); } else { System.out.println("并口: name-" + portId.getName() + " 是否占用-" + portId.isCurrentlyOwned()); } } System.out.println("-------------------------------------"); } /** * */ public static void getPortByDriver() { String driverName = "com.sun.comm.Win32Driver"; String libname = "win32com"; CommDriver commDriver = null; try { System.loadLibrary("win32com"); System.out.println(libname + " Library Loaded"); commDriver = (CommDriver) Class.forName(driverName).newInstance(); commDriver.initialize(); System.out.println("comm Driver Initialized"); } catch (Exception e) { System.err.println(e); } SerialPort sPort = null; try { sPort = (SerialPort) commDriver.getCommPort("COM24", CommPortIdentifier.PORT_SERIAL); System.out.println("find CommPort:" + sPort.toString()); } catch (Exception e) { System.out.println(e.getMessage()); } } }
本机运行结果:
引用
串口: name-COM10 是否占用-false
串口: name-COM21 是否占用-false
串口: name-COM23 是否占用-false
串口: name-COM20 是否占用-false
串口: name-COM22 是否占用-false
串口: name-COM24 是否占用-false
串口: name-COM9 是否占用-false
串口: name-COM19 是否占用-false
串口: name-COM3 是否占用-false
串口: name-COM8 是否占用-false
串口: name-COM98 是否占用-false
串口: name-COM99 是否占用-false
串口: name-COM4 是否占用-false
串口: name-COM5 是否占用-false
串口: name-COM6 是否占用-false
并口: name-LPT1 是否占用-false
并口: name-LPT2 是否占用-false
-------------------------------------
【三】、检查串口设备信息:
TestCommPort .java
Java代码
package test; import java.io.InputStream; import java.io.OutputStream; import java.util.Enumeration; import javax.comm.CommPortIdentifier; import javax.comm.SerialPort; public class TestCommPort { static CommPortIdentifier portId; static Enumeration portList; static int bauds[] = { 9600, 19200, 57600, 115200 }; /** * @param args */ public static void main(String[] args) { portList = CommPortIdentifier.getPortIdentifiers(); System.out.println("GSM Modem 串行端口连接测试开始..."); String portName = "COM4"; while (portList.hasMoreElements()) { portId = (CommPortIdentifier) portList.nextElement(); if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL && portName.equals(portId.getName())) { System.out.println("找到串口: " + portId.getName()); for (int i = 0; i < bauds.length; i++) { System.out.print(" Trying at " + bauds[i] + "..."); try { SerialPort serialPort; InputStream inStream; OutputStream outStream; int c; StringBuffer response = new StringBuffer(); serialPort = (SerialPort) portId.open( "SMSLibCommTester", 1971); serialPort .setFlowControlMode(SerialPort.FLOWCONTROL_RTSCTS_IN); serialPort.setSerialPortParams(bauds[i], SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE); inStream = serialPort.getInputStream(); outStream = serialPort.getOutputStream(); serialPort.enableReceiveTimeout(1000); c = inStream.read(); while (c != -1) { c = inStream.read(); } outStream.write(‘A‘); outStream.write(‘T‘); outStream.write(‘\r‘); try { Thread.sleep(1000); } catch (Exception e) { } c = inStream.read(); while (c != -1) { response.append((char) c); c = inStream.read(); } if (response.indexOf("OK") >= 0) { System.out.print(" 正在检测设备:"); try { outStream.write(‘A‘); outStream.write(‘T‘); outStream.write(‘+‘); outStream.write(‘C‘); outStream.write(‘G‘); outStream.write(‘M‘); outStream.write(‘M‘); outStream.write(‘\r‘); response = new StringBuffer(); c = inStream.read(); while (c != -1) { response.append((char) c); c = inStream.read(); } System.out.println(" 发现设备: " + response.toString().replaceAll( "(\\s+OK\\s+)|[\n\r]", "")); } catch (Exception e) { System.out.println(" 检测设备失败,获取设备信息异常:" + e.getMessage()); } } else { System.out.println(" 检测设备失败,沒有接收到响应结果!"); } serialPort.close(); } catch (Exception e) { System.out.println(" 检测设备失败,发生异常:" + e.getMessage()); } } } } } }
运行结果如下:
引用
GSM Modem 串行端口连接测试开始...
找到串口: COM24
Trying at 9600... 正在检测设备: 发现设备: AT+CGMM MULTIBAND 900E 1800
Trying at 19200... 发现设备失败,沒有接收到响应结果!
Trying at 57600... 发现设备失败,沒有接收到响应结果!
Trying at 115200... 发现设备失败,沒有接收到响应结果!
【四】、测试收发短信:
Java代码
package test; import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import org.apache.log4j.Level; import org.apache.log4j.Logger; import org.smslib.AGateway; import org.smslib.AGateway.Protocols; import org.smslib.GatewayException; import org.smslib.InboundMessage; import org.smslib.Message.MessageEncodings; import org.smslib.OutboundMessage; import org.smslib.Service; import org.smslib.modem.SerialModemGateway; public class SendSmsHandler { private static final Logger logger = Logger.getLogger(SendSmsHandler.class); private Service smsService; /** * 发送短信的类 */ public SendSmsHandler() { smsService = Service.getInstance(); //获得服务实例 单例模式的 List<AGateway> agatewayList = new ArrayList<AGateway>(); String portName = "COM4";//"/dev/ttyUSB0";// COM24 //使用的端口号 SerialModemGateway gateway = new SerialModemGateway( "modem." + portName, portName, 9600, "wavecom", "PL2303"); //通过端口号频率名称等内容获得设备实例 gateway.setInbound(true); gateway.setOutbound(true); gateway.setProtocol(Protocols.PDU); //发送凡是PDU gateway.setSimPin("0000"); agatewayList.add(gateway); //放到队列中,群发可以放多条就可以了 try { for (AGateway gatewayTmp : agatewayList) { smsService.addGateway(gatewayTmp); } } catch (GatewayException ex) { logger.error(ex.getMessage()); } } /** * 启动发送短信的服务 */ public void start() { logger.info("SMS service start....."); try { smsService.startService(); } catch (Exception ex) { logger.error("SMS service start error:", ex); } } /** * 停止发送短信服务 */ public void destroy() { try { smsService.stopService(); //停止服务 } catch (Exception ex) { logger.error("SMS service stop error:", ex); } logger.info("SMS service stop"); } /** * send SMS * 发送短信的方法 * @param msg 发送的内容 * @return Boolean 返回是否发送成功 */ public Boolean sendSMS(OutboundMessage msg) { try { msg.setEncoding(MessageEncodings.ENCUCS2); //设置编码 return smsService.sendMessage(msg); //发送短信并返回结果 } catch (Exception e) { logger.error("send error:", e); } return false; } //服务是否已经启动 private boolean isStarted() { if (smsService.getServiceStatus() == Service.ServiceStatus.STARTED) { //服务的状态是否是启动 for (AGateway gateway : smsService.getGateways()) { if (gateway.getStatus() == AGateway.GatewayStatuses.STARTED) { return true; } } } return false; } /** * read SMS 去读接收到的短信信息 * @return List */ public List<InboundMessage> readSMS() { List<InboundMessage> msgList = new LinkedList<InboundMessage>(); if (!isStarted()) { return msgList; } try { this.smsService.readMessages(msgList, InboundMessage.MessageClasses.ALL); logger.info("read SMS size: " + msgList.size()); } catch (Exception e) { logger.error("read error:", e); } return msgList; } /** * @param args 测试类 */ public static void main(String[] args) { Logger.getRootLogger().setLevel(Level.INFO); OutboundMessage outMsg = new OutboundMessage("189*****", "信息测试"); //绑定接收电话号码和发送的消息 SendSmsHandler smsHandler = new SendSmsHandler(); smsHandler.start(); //启动 //发送短信 smsHandler.sendSMS(outMsg); //读取短信 List<InboundMessage> readList = smsHandler.readSMS(); for (InboundMessage in : readList) { System.out.println("发信人:" + in.getOriginator() + " 短信内容:" + in.getText()); } smsHandler.destroy(); //停止服务 System.out.println("-----------"); } }
发送短信亲测,手机能正常接收显示。读取设备的短信程序运行结果结果如下:
引用
INFO
- Service.listSystemInformation(113) | SMSLib: A Java API library
forsending and receiving SMS via a GSM modem or other supported
gateways.
This software is distributed under the terms of the Apache v2.0 License.
Web Site: http://smslib.org
INFO - Service.listSystemInformation(114) | Version: 3.5.1
INFO - Service.listSystemInformation(115) | JRE Version: 1.6.0_18
INFO - Service.listSystemInformation(116) | JRE Impl Version: 16.0-b13
INFO - Service.listSystemInformation(117) | O/S: Windows Vista / x86 /6.0
INFO - SmsHandler.start(55) | SMS service start.....
INFO - DefaultQueueManager.init(92) | Queue directory not defined. Queuedmessages will not be saved to filesystem.
INFO - ModemGateway.startGateway(188) | GTW: modem.COM24: Starting gateway,using Generic AT Handler.
INFO - SerialModemDriver.connectPort(68) | GTW: modem.COM24: Opening: COM24@9600
INFO - AModemDriver.waitForNetworkRegistration(459) | GTW: modem.COM24: GSM:Registered to foreign network (roaming).
INFO - AModemDriver.connect(175) | GTW: modem.COM24: MEM: Storage LocationsFound: SMBM
INFO - CNMIDetector.getBestMatch(142) | CNMI: No best match, returning: 1
INFO - ModemGateway.startGateway(191) | GTW: modem.COM24: Gatewaystarted.
INFO - SmsHandler.readSMS(113) | read SMS size: 1
发信人:8618918001030 短信内容:hello 回复测试
INFO - ModemGateway.stopGateway(197) | GTW: modem.COM24: Stoppinggateway...
INFO - SerialModemDriver.disconnectPort(120) | GTW: modem.COM24: Closing: COM24@9600
INFO - ModemGateway.stopGateway(201) | GTW: modem.COM24: Gateway stopped.
INFO - SmsHandler.destroy(72) | SMS service stop
-----------
java 短信猫发送短信的方法,布布扣,bubuko.com
标签:des style blog http color java 使用 os
原文地址:http://www.cnblogs.com/tangkai/p/3927551.html