package?dtu.model;
/**???
?*?項目名：****************?
?*?包名：dtu.model.NKLongSocket
?*?文件名：LongSocket.java?
?*?文件描述:（長連接獲取DTU數據接口）
?*?作者?：huastone?E-mail:?huastone_he@163.com?
?*?創建時間：2013-3-22-上午11:25:21??
?*?版本信息：@version?V1.0.0????
?*/
import?java.io.BufferedReader;
import?java.io.ByteArrayOutputStream;
import?java.io.DataInputStream;
import?java.io.IOException;
import?java.io.InputStream;
import?java.io.InputStreamReader;
import?java.io.PrintWriter;
import?java.net.InetAddress;
import?java.net.InetSocketAddress;
import?java.net.Socket;
import?java.net.UnknownHostException;

import?org.apache.commons.logging.Log;
import?org.apache.commons.logging.LogFactory;


public?class?NKLongSocket?extends?Thread{
	//日志處理接口
	private?Log?mylog?=?LogFactory.getLog（NKLongSocket.class）;
	
	private?String?ip=null;//連接服務器的IP
	private?Integer?port=null;//連接服務器的端口
	private?String?operName?=?““;?//操作人
	private?Integer?timeout?=?1000*30;?//連接超時設置?以毫秒為單位
	
	private?Socket?socket=null;//套節字對象
	private?boolean?close?=?false;?//?關閉連接標志位，true表示關閉，false表示連接
	private?Integer?sotimeout=1000*60;//讀取超時時間，以毫秒為單位
	//------------------------------------------------------------------------------
	private?ByteArrayOutputStream?out;
	
	public?NKLongSocket（）{
//		init（）;
	}
	
	public?NKLongSocket（String?ipInteger?portString?operName）{
		this.ip?=?ip;
		this.port?=?port;
		this.operName?=?operName;
//		init（）;
	}
	/**
	?*?初始化socket對象
	?*?@throws?IOException?
	?*/
	public?void?init（）?throws?IOException{
		try?{
			out?=?new?ByteArrayOutputStream（）;
			?//--------------------------------------------------
			InetAddress?address?=?InetAddress.getByName（ip）;
			socket?=?new?Socket（）;??
//			socket?=?new?Socket（addressport）;
			socket.setKeepAlive（true）;//開啟保持活動狀態的套接字
			socket.setSoTimeout（sotimeout）;//設置超時時間
			socket.connect（new?InetSocketAddress（address?port）?timeout）;
			close=!send（socket“2“）;//發送初始數據，發送成功則表示已經連接上，發送失敗表示已經斷開
			if（!close）{
				mylog.info（“建立連接成功：“+ip+“:“+port）;
			}else{
				mylog.error（“創建連接失敗:“+ip+“:“+port）;
			}
		}catch（UnknownHostException?e）?{
			e.printStackTrace（）;
			socket.close（）;
			mylog.error（“init?socket?Error:“+e.getMessage（））;
			throw?e;
		}catch（IOException?e）{
			e.printStackTrace（）;
			socket.close（）;
			mylog.error（“init?socket?error:“+e.getMessage（））;
			throw?e;
		}
	}
	
	/**
	?*?讀數據線程
	?*/
	public?void?run（）?{
		while（true）{
			//---------讀數據---------------------------
			close?=?isServerClose（）;//判斷是否斷開
			if（!close）{//沒有斷開，開始讀數據
				try?{
					//?讀取數據
					byte[]?bytes?=?readStreamByte（）;
					//處理數據方法
					getLongByte（bytes）;
				}?catch?（Exception?e）?{
					e.printStackTrace（）;
				}
			}
			//---------創建連接-------------------------
			while（close）{//已經斷開，重新建立連接
				try{
					mylog.info（“重新建立連接：“+ip+“:“+port）;
					//初始化連接
					init（）;
				}catch（Exception?se）{
					mylog.error（“創建連接失敗:“+ip+“:“+port）;
					close=true;
				}
	

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件??????11383??2013-08-30?10:31??model\NKLongSocket.java

?????文件????????811??2013-08-30?10:28??model\TestDTU.java

?????目錄??????????0??2013-08-30?10:24??model

-----------?---------??----------?-----??----

????????????????12194????????????????????3