receivemessagepdu.java

wap短信发送

/*
 * Created on 2005-9-21
 * 
 */

/**
 * @author XenonGas Copyright http://www.04tech.com
 *  
 */

package net.mcool.www.message;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Enumeration;

import javax.comm.CommPortIdentifier;
import javax.comm.PortInUseException;
import javax.comm.SerialPort;
import javax.comm.UnsupportedCommOperationException;

public class ReceiveMessagePDU {

    static Enumeration portList;

    static CommPortIdentifier portId;

    static SerialPort serialPort;

    static OutputStream OutputStream;

    static InputStream InputStream;

    private String message;

    private int commandDelay;

    private String replyString;

    private int getReplyInterval;

    //********************************************************************
    //对串口的读写操作
    //方法： writeToSerialPort 对串口的写操作
    //参数： msgString 传递字符串到接口
    private void writeToSerialPort(String msgString) {
        try {
            ReceiveMessagePDU.OutputStream.write(msgString.getBytes());
        } catch (IOException e) {
            System.out.println(e.getMessage());
        }
    }

    //方法： waitForRead 等待返回信息
    //参数： waitTime 进程等待时间
    private void waitForRead(int waitTime) {
        try {
            Thread.sleep(waitTime);
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }

    //********************************************************************
    //********************************************************************
    //发送信息:
    //    1. 打开串口
    //    2. at + cmgf = 0 设置待发送短消息的格式。
    //    3. 转换传来的字符串（参数messageString）。
    //    4. at + cmgs = 被转换完成的16位字串。
    //    5. System.out.println() 返回到命令行串口的信息。
    //    6. 关闭IO流和串口
    public void sendmsg(String messageString, String phoneNumber)
            throws Exception {
        //打开串口
        portList = CommPortIdentifier.getPortIdentifiers();
        while (portList.hasMoreElements()) {
            portId = (CommPortIdentifier) portList.nextElement();
            if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
                if (portId.getName().equals("COM1")) {
                    try {
                        serialPort = (SerialPort) portId.open("SendMessagePDU", 2000);
                    } catch (PortInUseException e) {
                        e.printStackTrace();
                    }
                    try {
                        OutputStream = serialPort.getOutputStream();
                        InputStream = serialPort.getInputStream();
                    } catch (IOException e) {
                    	e.printStackTrace();
                    }
                    try {
                        serialPort.setSerialPortParams(9600,
                                SerialPort.DATABITS_8, SerialPort.STOPBITS_1,
                                SerialPort.PARITY_NONE);
                    } catch (UnsupportedCommOperationException e) {
                    	e.printStackTrace();
                    }
                }
            }
        }
        //********

        writeToSerialPort("AT+CMGF=0\r");
        waitForRead(this.commandDelay);
        byte[] readBuffer = new byte[1];
        int msglength;
        String sendmessage, tempSendString;
        msglength = messageString.length();
        String atcmgs = "AT+CMGS=" + (msglength * 2 + 15);
        //"000801"说明：分为00,08,01,
        //"00",普通GSM类型，点到点方式
        //"08",UCS2编码
        //"01",有效期
        if (msglength < 8) {
            tempSendString = "000800" + "0"
                    + Integer.toHexString(msglength * 2).toUpperCase()
                    + asc2unicode(new StringBuffer(messageString));
        } else {
            tempSendString = "000800"
                    + Integer.toHexString(msglength * 2).toUpperCase()
                    + asc2unicode(new StringBuffer(messageString));
        }
        if (phoneNumber.trim().length() > 0) {
            sendmessage = "011000D91" + "68" + changePhoneNumber(phoneNumber)
                    + tempSendString;
            this.message = "";
            writeToSerialPort(atcmgs + "\r\n");
            waitForRead(this.commandDelay);
            writeToSerialPort(sendmessage + (char) 26);
            waitForRead(this.commandDelay);
            try {
                InputStream = serialPort.getInputStream();
            } catch (IOException e) {
            }
            try {
                while (InputStream.available() > 0) {
                    int numBytes = InputStream.read(readBuffer);
                    waitForRead(this.commandDelay);
                    //System.out.print(new String(readBuffer));
                }
            } catch (IOException e) {
            }
            waitForRead(this.commandDelay);
        }
        //System.out.println("\n");
        closeIOStream();
        closeSerialPort();
        message = "";
        //System.out.println("发送完毕！");
    }

    //修正号码在内存中的表示，每2位为1组，每组2个数字交换，
    //若号码个数为奇数，则在末尾补'F'凑成偶数，然后再进行变换，
    //因为在计算机中，表示数字高低位顺序与我们的习惯相反.
    //如："8613851872468" --> "683158812764F8"
    private String changePhoneNumber(String phoneNumber) {
        int numberLength = phoneNumber.length();
        if (phoneNumber.length() % 2 != 0) {
            phoneNumber = phoneNumber + "F";
            numberLength += 1;
        }
        char newPhoneNumber[] = new char[numberLength];
        for (int i = 0; i < numberLength; i += 2) {
            newPhoneNumber[i] = phoneNumber.charAt(i + 1);
            newPhoneNumber[i + 1] = phoneNumber.charAt(i);
        }
        return (new String(newPhoneNumber));
    }

    //将要发送的字符串(String messageString)转换为UNICODE编码
    private String asc2unicode(StringBuffer msgString) {
        StringBuffer msgReturn = new StringBuffer();
        int msgLength = msgString.length();
        if (msgLength > 0) {
            for (int i = 0; i < msgLength; i++) {
                new Integer((int) msgString.charAt(0)).toString();
                msgReturn.append(new StringBuffer());
                String msgCheck = new String(Integer
                        .toHexString((int) msgString.charAt(i)));
                if (msgCheck.length() < 4) {
                    msgCheck = "00" + msgCheck;
                }
                msgReturn.append(new StringBuffer(msgCheck));
            }
        }
        return (new String(msgReturn).toUpperCase());
    }

    //*****************************************************************
    //********************************************************************
    //操作结束，关闭所用资源
    public void closeSerialPort() {
        if (ReceiveMessagePDU.serialPort != null) {
            try {
                ReceiveMessagePDU.serialPort.close();
            } catch (RuntimeException e) {
                System.out.println(e.getMessage());
            }
        }
        //System.out.println("已断开连接！");
    }

    public void closeIOStream() {
        if (ReceiveMessagePDU.InputStream != null) {
            try {
                ReceiveMessagePDU.InputStream.close();
            } catch (IOException e) {
                System.out.println(e.getMessage());
            }
        }
        if (ReceiveMessagePDU.OutputStream != null) {
            try {
                ReceiveMessagePDU.OutputStream.close();
            } catch (IOException e1) {
                System.out.println(e1.getMessage());
            }
        }
        //System.out.println("已关闭I/O流！");
    }

    //********************************************************************

    public boolean sendSMS(String message, String phoneNumber) {
        try {
            sendmsg(message, phoneNumber);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    public static void main(String[] args) {
        ReceiveMessagePDU smp = new ReceiveMessagePDU();
        smp.sendSMS("您好您好", "13521262171");
    }
}