一:服务端 ServerSocket
- ServerSocket包含一个监听来自客户端连接请求的方法:
accept();
如果服务端接收到一个客户端的Socket连接请求,会返回一个与客户端Socket对应的服务端Socket,否则该方法一直处于等待状态,线程阻塞。
ServerSocket类提供如下构造器:
ServerSocket(int port);
使用指定端口来创建,port范围:0-65535。注意,在选择端口时,必须小心。每一个端口提供一种特定的服务,只有给出正确的端口,才能获得相应的服务。0~1023的端口号为系统所保留
,例如http服务的端口号为80,telnet服务的端口号为21,ftp服务的端口号为23, 所以我们在选择端口号时,最好选择一个大于1023的数以防止发生冲突。ServerSocket(int port, int backlog);
增加一个用来改变连接队列长度的参数backlog。ServerSocket(int port, int backlog, InetAddress bindAddr);
在机器存在多个IP地址的情况下,bindAddr参数指定将ServerSocket绑定到指定IP。
当ServerSocket使用完毕,应使用close()
方法来关闭此ServerSocket。通常情况下,服务器不应该只接收一个客户端请求,而应该不断接收来自客户端的请求,所以程序可以通过循环,不断调用ServerSocket的accept方法:
while (true) {
Socket socket = serverSocket.accept();//阻塞
....
}
二:客户端 Socket
Socket 常用构造器
Socket(InetAddress/String remoteAddress, int port);
创建连接到指定远程主机、远程端口的Socket,本地IP地址和端口使用默认值。Socket(InetAddress/String remoteAddress, int port, InetAddress localAddr, int localPort);
绑定本地IP地址和端口,适用于本地主机有多个IP地址的情形。
注:上面两个构造器指定远程主机时既可以使用InetAddress来指定,也可以直接使用String对象来指定远程IP。本地主机只有一个IP地址时,使用第一个方法更简单。
三、心跳机制
在与服务器进行通讯的时候,无法判断远程的服务器是否断开连接。如果使用OutputStream
发送数据则会影响正常的数据发送(无法区分)。所以就引入了一个心跳机制。
心跳机制实现,使用Socket.sendUrgentData()方法发送一个字节流数据(紧急数据)。可以通过判断服务端的OOBINLINE属性是否打开,来确定是否断开连接;
当设置OOBINLINE选项时,套接字上接收到的任何TCP紧急数据将通过套接字输入流接收。当该选项被禁用时(这是默认设置),紧急数据将被静默丢弃。
setSoTimeout()理解:设置超时时间;例如:设置为2s,如果阻塞的时间>2s ,那么就会报错。
[SO_TIMEOUT] 使用指定的超时启用/禁用,以毫秒为单位。如果将此选项设置为非零超时,则与此Socket关联的InputStream上的read()调用将仅阻塞这段时间。如果超时过期,则会引发java.net.SocketTimeoutException,但Socket仍然有效。该选项必须在进入阻止操作生效之前启用。超时必须是
> 0
。超时为零被解释为无限超时。