mtclientsocket.java

中国联通短信通信协议

package com.wireless.sms.gwif.test.send;

import java.util.Vector;
//import java.net.Socket;
//import java.io.BufferedOutputStream;
import java.io.IOException;
import java.util.*;
//import java.io.FileOutputStream;
import com.wireless.sms.pub.entity.MT;
//import java.io.ObjectOutputStream;
import java.nio.channels.SocketChannel;
import java.net.*;
import java.nio.*;
import org.apache.log4j.Logger;
import com.wireless.sms.pub.util.CryptoTool;

/**
 * <p>Title: 无线增值业务平台----短信平台-----应用框架</p>
 * <p>Description: 主要接收MO/MT交换中心发送过来的MT，压入MTQueue中，解析MT的数据包，写入文件，分解数据为中国移动认可的数据</p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: moon</p>
 * @author tech team
 * @version 1.0
 */

public class MTClientSocket {

    private Vector mthost = new Vector();
    private Vector mtport = new Vector();
    private static MTClientSocket mtClientSocket = null;
    private Logger log = null;
    private String[] address = new String[0];
    private String[] ports = new String[0];

    /**
     * 设置监控地址
     * @param address String[]  IP 地址
     * @param ports String[]  端口号
     */
    public void setMonitor(String[] address, String[] ports) {
        this.address = address;
        this.ports = ports;
    }

    public static MTClientSocket getInstance() {
        if (mtClientSocket == null) {
            mtClientSocket = new MTClientSocket();
        }
        return mtClientSocket;
    }

    public MTClientSocket(String[] host, String[] port) {

        for (int i = 0; i < host.length; i++) {
            mthost.add(host[i]);
        }

        for (int i = 0; i < port.length; i++) {
            mtport.add(port[i]);
        }
    }

    public MTClientSocket(String host, String port) {
        mthost.add(host);
        mtport.add(port);
    }

    private MTClientSocket() {

        String hosts = "211.94.156.167";
        String ports = "8700,8701,8702,8703,8704,8705,8706,8707,8708,8709,8710,8711,8712,8713,8714,8715,8716,8717,8718,8719,8720";

        StringTokenizer hostips = new StringTokenizer(hosts, ",");
        StringTokenizer hostports = new StringTokenizer(ports, ",");
        String tmpStr = null;

        while (hostips.hasMoreTokens()) {
            tmpStr = hostips.nextToken().toString();
            mthost.add(tmpStr);
        }

        while (hostports.hasMoreTokens()) {
            tmpStr = hostports.nextToken().toString();
            mtport.add(tmpStr);
        }
    }

    public void setLog(Logger log) {
        this.log = log;
    }

    public boolean sendMT(MT mt) throws Exception {

        mt.setMsgContent(CryptoTool.base64Encode(mt.getMsgContent()));

        boolean thisflag = false;
        String host = null;
        int port = 0;

        for (int i = 0; i < mthost.size() && thisflag == false; i++) {
            for (int j = 0; j < mtport.size() && thisflag == false; j++) {
                try {

                    host = (String)this.mthost.elementAt(i);
                    port = Integer.parseInt((String)this.mtport.elementAt(j));

                    SocketChannel sc = SocketChannel.open();
                    InetSocketAddress address = new InetSocketAddress(InetAddress.getByName(host), port);
                    sc.connect(address);

                    ByteBuffer buffer = ByteBuffer.allocate(2048);

                    if (sc.isConnected()) {

                        try {
                            buffer.clear();
                            buffer.put(mt.toString().getBytes());
                            buffer.flip();
                            sc.write(buffer);
                            sc.close();
                            thisflag = true;
                        } catch (IOException ex) {
                            sc.close();
                            thisflag = false;
                            throw ex;
                        }
                    }
                } catch (IOException ex) {
                    thisflag = false;
                    throw ex;
                }
            }
        }

        return thisflag;
    }

    public static void main(String[] argv) throws Exception {
        MTClientSocket mtClientSocket = new MTClientSocket("192.168.2.85", "8700");
        MT mt = MT.getInstance("<?xml version=\"1.0\" encoding=\"GB2312\"?><mt><msgID></msgID><atTime></atTime><cityID></cityID><classID>http://sms.etong.net/sp/httpmo.php</classID><destTermID>13951018139</destTermID><feeCode></feeCode><feeTermID>13951018139</feeTermID><feeType></feeType><feeUserType></feeUserType><gateWayID></gateWayID><isImBalance>2</isImBalance><moID></moID><mouseID>1</mouseID><mousePackageID>1</mousePackageID><msgContent>中文字符大雨75个长度，BASE 64 编码结果</msgContent><msgContentID></msgContentID><msgFormat>15</msgFormat><msgID></msgID><msgLen>11</msgLen><mtType>2</mtType><needReply>1</needReply><provinceID></provinceID><respTime></respTime><sendTime>200410212315</sendTime><serviceCode></serviceCode><serviceID>245</serviceID><smTypeID>1138</smTypeID><srcTermID>666</srcTermID><valIdTime></valIdTime><msgLevel>1</msgLevel><mouseGroupID></mouseGroupID><status></status><linkID></linkID><spnumber>8866</spnumber><subType>0</subType></mt>");
        mtClientSocket.sendMT(mt);
    }

	public synchronized String[] getAddress() {
		return address;
	}

	public synchronized void setAddress(String[] address) {
		this.address = address;
	}

	public synchronized String[] getPorts() {
		return ports;
	}

	public synchronized void setPorts(String[] ports) {
		this.ports = ports;
	}

	public synchronized Logger getLog() {
		return log;
	}
}