java socket长连接

package top.tupobi.client; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; public class ClientSocketProcessor { private OnSocketListener mOnSocketListener; private Socket mSocket = null; private DataOutputStream mDataOutputStream = null; private DataInputStream mDataInputStream = null; private boolean isConnected; public void setOnSocketListener(OnSocketListener onSocketListener) { mOnSocketListener = onSocketListener; } public void connect(String ip, int port) { try { // 连接服务器，连接不上直接进异常，不会继续执行下面语句，是同步的 mSocket = new Socket(ip, port); mDataOutputStream = new DataOutputStream(mSocket.getOutputStream()); mDataInputStream = new DataInputStream(mSocket.getInputStream()); System.out.println("~~~~~~~~连接成功~~~~~~~~!"); isConnected = true; ClientSocketReceiverThread clientSocketReceiverThread = new ClientSocketReceiverThread(mDataInputStream); clientSocketReceiverThread.setOnReceiveDataListener(new OnReceiveDataListener() { @Override public void onReceiveData(String data) { mOnSocketListener.onReceiveData(data); } @Override public void onDisconnectedNormally() { System.out.println("服务端正常关闭连接"); isConnected = false; } @Override public void onDisConnectedAbNormally() { System.out.println("服务端异常关闭连接"); isConnected = false; } }); new Thread(clientSocketReceiverThread).start(); } catch (UnknownHostException e) { e.printStackTrace(); mOnSocketListener.onUnknownHostError(); } catch (IOException e) { e.printStackTrace(); mOnSocketListener.onConnectFail(); } } public void disConnect() { if (mSocket != null && mDataInputStream != null && mDataOutputStream != null && isSocketConnected()) { try { mDataOutputStream.close(); mDataInputStream.close(); System.out.println(); mSocket.close(); isConnected = false; } catch (IOException e) { e.printStackTrace(); System.out.println("客户端断开连接失败：IOException"); } } } public void sendData(String data) { if (isSocketConnected()) { try { mDataOutputStream.writeUTF(data); mDataOutputStream.flush(); } catch (IOException e) { e.printStackTrace(); System.out.println("客户端发送数据失败：IOException"); } } else { System.out.println("socket未连接，发送不了消息"); } } public boolean isSocketConnected() { return isConnected; } public void reConnect(String ip, int port) { connect(ip, port); } } interface OnSocketListener { void onUnknownHostError(); void onConnectFail(); void onReceiveData(String data); }