package?com.cesi.oritest;

import?java.io.BufferedWriter;
import?java.io.DataInputStream;
import?java.io.IOException;
import?java.io.OutputStreamWriter;
import?java.net.InetSocketAddress;
import?java.net.Socket;

/**
?*?Created?by?xiaodukai?on?2018/11/14.
?*/

public?class?TcpHelper?{
????private?Socket?socket;
????private?BufferedWriter??bufferedWriter;
????private?DataInputStream?inputStream;
????private?boolean?NeedStop;
????private?InetSocketAddress?SerAddr;
????public??String?ErrMsg;
????private?ReadThread?readThread;???????????//讀取數據線程
????private?OnReceiveEvent?receiveEvent;?????//此事件用于當接收到數據時向主線程通知接收到的數據
????private?long?LastCheckTime;
????public?static?interface?OnReceiveEvent{
????????public??void?ReceiveBytes（byte[]?iData）;
????????public??void?ReceiveString（String?iData）;
????}
????public?enum?EDataType{EDT_BYTEEDT_STRING};
????private?EDataType?dataType;
????public?TcpHelper（String?HostIpint?HostPort）?{
????????try?{
????????????LastCheckTime=System.currentTimeMillis（）;
????????????readThread?=new?ReadThread（）;
????????????NeedStop=false;
????????????SerAddr?=??new?InetSocketAddress（HostIpHostPort）;
????????????NeedStop=false;
????????????socket?=?new?Socket（）;
????????????readThread.start（）;
????????}catch?（Exception?e）
????????{
????????????ErrMsg=e.getMessage（）;
????????}
????}
????public?void?SendString（String?iText）{???????//發送字符串
????????dataType=EDataType.EDT_STRING;
????????toSend（iText）;
????}
????public?void?SendBytes（byte[]?iBuf）{?????//發送字節流指令
????????dataType=EDataType.EDT_BYTE;
????????String?iText?=?new??String（iBuf）;
????????toSend（iText）;
????}
????public?void?close（）{
????????if（socket!=null）{
????????????try?{
????????????????socket.close（）;
????????????????readThread.stop（）;
????????????}?catch?（IOException?e）?{
????????????????e.printStackTrace（）;
????????????}
????????}
????}
????//發送數據線程
????private?void?toSend（final?String?iText）{
????????new?Thread（
????????????????new?Runnable（）?{
????????????????????@Override
????????????????????public?void?run（）?{
????????????????????????try?{
????????????????????????????bufferedWriter.write（iText）;
????????????????????????????bufferedWriter.flush（）;
????????????????????????}?catch?（Exception?e）?{
????????????????????????????e.printStackTrace（）;
????????????????????????}
????????????????????}
????????????????}
????????）.start（）;
????}
????public?boolean?isConnected（）{
????????if（socket==null）?return?false;
????????return?socket.isConnected（）;
????}
?