connectionwrap.java

彩信发送源代码,实现mm7接口

/**
 * File Name:MM7Config.java Company: 中国移动集团公司 Date : 2004-1-3
 */

package com.cmcc.mm7.vasp.common;

import java.net.Socket;

import org.apache.log4j.Logger;

import com.cmcc.mm7.vasp.conf.MM7Config;

public class ConnectionWrap {
	private static final Logger log = Logger.getLogger(ConnectionWrap.class);

	MM7Config mm7c;

	private Socket socket;

	private boolean Free; // 标志是否空闲

	public long start;

	private boolean AuthFlag; // 标志是否经过了摘要鉴权

	private String DigestInfor;

	private int ConnectIndex;

	private boolean UserfulFlag = true;

	public ConnectionWrap() {
		Free = true;
		AuthFlag = false;
		DigestInfor = "";
		start = 0;
	}

	public ConnectionWrap(MM7Config mm7config) throws Exception {
		mm7c = mm7config;

		/*
		 * try{ String MMSCIP = (String)mm7c.getMMSCIP().get(0); int index =
		 * MMSCIP.indexOf(":"); String ip; int port; if(index == -1) { ip =
		 * MMSCIP; port = 80; } else { ip = MMSCIP.substring(0,index); port =
		 * Integer.parseInt(MMSCIP.substring(index+1)); } socket = new
		 * Socket(ip,port); //socket = new Socket( (String)
		 * mm7c.getMMSCIP().get(0), 80); Free = true; start = 0;
		 * }catch(Exception e) { System.out.println(e); }
		 */
	}

	public boolean BuidLink() {
		try {
			String MMSCIP = (String) mm7c.getMMSCIP().get(0);
			int index = MMSCIP.indexOf(":");
			String ip;
			int port;
			if (index == -1) {
				ip = MMSCIP;
				port = 80;
			}
			else {
				ip = MMSCIP.substring(0, index);
				port = Integer.parseInt(MMSCIP.substring(index + 1));
			}
			socket = new Socket(ip, port);
			// socket = new Socket( (String) mm7c.getMMSCIP().get(0), 80);
			Free = true;
			// start = 0;
			// modified by liuhuafeng on 2006/7/26,起始时间换为当前时间
			start = System.currentTimeMillis();
			if (log.isDebugEnabled())
				log.debug("到IP:" + ip + ",PORT:" + port + "的连接建立成功!!!");
			return true;
		}
		catch (Exception e) {
			// System.out.println("没有成功建链！原因：" + e);
			log.error("ConnectionWrap.buildLink():没有成功建链！原因：" + e);
			return false;
		}

	}

	public Socket getSocket() {
		return socket;
	}

	public boolean getFree() {
		return (Free);
	}

	public void setFree(boolean bfree) {
		Free = bfree;
	}

	public void setAuthFlag(boolean authflag) {
		AuthFlag = authflag;
	}

	public boolean getAuthFlag() {
		return AuthFlag;
	}

	public void setDigestInfor(String infor) {
		DigestInfor = infor;
	}

	public String getDigestInfor() {
		return DigestInfor;
	}

	public void setConnectIndex(int index) {
		this.ConnectIndex = index;
	}

	public int getConnectIndex() {
		return ConnectIndex;
	}

	public void setUserfulFlag(boolean flag) {
		this.UserfulFlag = flag;
	}

	public boolean getUserfulFlag() {
		return UserfulFlag;
	}
	//added by liuhuafeng on 2006/7/26
	public void setStart(long start) {
		this.start = start;
	}

	public long getStart() {
		return start;
	}
}