Network-Socket

基于TCP的Socket

Socket socket = new Socket(String ip, int port); // 本地进程间通信使用 "localhost"
boolean isConnected = socket.isConnected();
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
writer.write(byte[] data);
writer.flush();
writer.close();

DataInputStream input = new DataInputStream(new BufferedInputStream(socked.getInputStream));
byte[] bytes = new byte[MAX_LENGTH_EACH_TIME];
while(input.read(bytes) != -1) {

}
服务端：
ServerSocket serverSocket = new ServerSocket(int port);
Socket socket = ServerSocket.accept();
InputStream ......

• socket.accept()函数对应着TCP三次握手中哪一次握手，哪个函数代表连接建立完毕，四次挥手的过程？

没有对应关系。accept()发生在三次握手之后。服务器监听请求连接，成功三次握手的连接会被存放到连接队列中，accept()方法只是从服务器的连接队列中取出了具体的一个连接实例。

基于UDP的Socket

// 发送
DatagramSocket socket = new DatagramSocket();
socket.connect(String ip, int port);
DatagramPacket sendPacket = new DatagramPacket(byte[] data, int data.length, String ip, int port);
socket.send(sendPacket);
// 接收
while(socket.isConnect()) {
byte[] data = new byte[MAX_LENGTH_EACH_TIME];
DatagramPacket rcvPacket = new DatagramPacket(data, data.length);
socket.receive(rcvPacket);
rcvPacket.getData().length // 等效于 data.length，等于 MAX_LENGTH_EACH_TIME
rcvPacket.getLength() // 实际接收的数据长度，最大 64k
......
}

Socket长连接

isClosed()、isConnected()、isInputStreamShutdown()、isOutputStreamShutdown()都是本地判断，只是本地操作connect()或close()方法后保存的状态，无法判断服务端是否主动断开，OutputStream.write()在服务端关闭时也能照常发送不会报错。

采用服务端心跳回复的机制，客户端发送心跳后，服务端需要回复心跳，并设置中断超时，超过几次心跳后仍然没有回复则主动断开连接。