| | |
| | | import java.net.InetSocketAddress;
|
| | | import java.net.Socket;
|
| | | import java.net.SocketAddress;
|
| | | import java.net.StandardSocketOptions;
|
| | | import java.util.ArrayList;
|
| | | import java.util.List;
|
| | |
|
| | |
| | | mSocket.connect(new InetSocketAddress(ip, port), 3 * 1000);
|
| | | mSocket.setTcpNoDelay(true);
|
| | | mSocket.setReuseAddress(true);
|
| | | mSocket.setKeepAlive(true);
|
| | | mSocket.setSoTimeout(20 * 1000);
|
| | | // mSocket.setKeepAlive(true);
|
| | | mSocket.setSoTimeout(25 * 1000);
|
| | |
|
| | | tcpClientList.add(this);
|
| | | }
|
| | |
| | | if (handleMessage != null) {
|
| | | byte []bytes = new byte[len];
|
| | | System.arraycopy(readBuffer,0,bytes,0,len);
|
| | | LogUtils.i("收到TCP数据",new String(bytes));
|
| | | //完整的数据才回调
|
| | | handleMessage.read(bytes);
|
| | | handleMessage.read(bytes,ip);
|
| | | }
|
| | | }
|
| | | }
|