mtclientsocket.java

中国联通短信通信协议

package com.wireless.sms.gwif.test;

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.75", "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;
}
}