socket

foryougeljh

浏览: 116374 次
性别:
来自: 上海

最近访客更多访客>>

chsnsz

Jackiezmb

a191535434

笨鸟刃心

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

socket
socket构造方法有几种重载形式，除了不带参数的构造方法外，其它构造方式都试图与服务器建立连接,连接成功，就返回socket对象，连接失败，就会抛出异常。

如果需要设置等待超时时间，此时需要使用不带参数的构造方法
Socket socket = new Socket();
SocketAddress address = new InetSocketAddress("localhost",8000);
socket.connect(address, 60000);//等待建立连接的超时时间为1分钟
//如果1分钟内连接成功，则返回socket，否则抛出SocketTimeoutException

设置服务器地址
Socket(InetAddress address, int port) 创建一个流套接字并将其连接到指定IP地址的指定端口号
Socket(String host, int port) 创建一个流套接字并将其连接到指定主机上的指定端口号
InetAddress类代表服务器的IP地址，InetAddress提供一系列的静态工厂方法用于构造自身的实例
InetAddress address = InetAddress.getLocalHost() //返回本地主机
address = InetAddress.getByName("10.2.17.28") //在给定主机名的情况下确定主机的 IP 地址

设置客户端地址
默认情况下，客户端地址来自于客户端所在的主机，客户端的端口由操作系统随机分配，但socket类也提供2个构造方式用于显示的设置客户端的IP地址和端口
Socket(InetAddress address, int port, InetAddress localAddr, int localPort)
Socket(String host, int port, InetAddress localAddr, int localPort)
如果一个主机同时属于多个网络，它就可能有多个IP地址。
例如：一个主机在internet网络中的IP地址为"222.67.1.34",在一个局域网中的IP地址为"112.5.4.3".如果这个主机的客户端程序希望和同一局域网的一个服务器程序进行通信，客户端可以通过显示的申明IP地址和端口

客户端连接服务器可能抛出的异常
UnknownHostException：无法识别主机的名字和IP地址
ConnectException：没有服务器监听指定的端口或服务器进程拒绝连接(如超过服务端设置的请求队列长度)
SocketTimeoutException：连接超时
BindException：无法把socket与指定的本地IP地址或端口绑定
以上4个异常都直接或间接的继承IOException

服务器进程拒绝连接示例
服务端
public class SimpleServer {
public static void main(String[] args) throws Exception {
ServerSocket server = new ServerSocket(4001,2);//请求队列长度为2
Thread.sleep(60000);
}
}
客户端
public class SimpleClient {
private static Integer port = 4001;
public static void main(String[] args) throws Exception{
Socket socket = new Socket();
SocketAddress address = new InetSocketAddress("localhost",port);
socket.connect(address, port);//等待建立连接的超时时间为1分钟
System.out.println("第一次连接成功");

Socket socket1 = new Socket();
socket1.connect(address, port);
System.out.println("第二次连接成功");

Socket socket2 = new Socket();
socket2.connect(address, port);
System.out.println("第三次连接成功");
}
}
从打印接口可以看出，由于服务端已经有2个客户端连接请求，队列已满，SimpleClient第三次连接被拒绝

获取socket信息
getInetAddress() 获取服务器地址 getPort() 获取服务器端口
getLocalAddress() 获取本地地址 getLocalPort()获取本地端口
getInputStream() 获取输入流 getOutputStream() 获取输出流

关闭socket
当客户端与服务器通讯结束后应关闭socket,以释放socket占用的包括端口在内的资源
socket类提供了3个状态测试方法
isBound()
isClosed()
isConnected()

半关闭
进程A与进程B通过socket通讯，假定进程A输出数据，进程B读入数据，进程A如何告诉进程B所有数据已经输出完毕。
(一)当进程A与进程B交换的是字节流，并且都是一行一行读写数据，可以事先约定以一个特殊标志作为结束标志。
如以字符串"bye"作为结束标志，当进程A向进程B发送一行字符串"bye",进程B读到这行数据后就停止读取数据。
(二)进程A先发送一个消息，告诉线程B所发送的正文长度，然后在发送正文。进程B先获知进程A将发送的正文长度，接下来只需要读完改长度的字符串就停止读取数据。
(三)进程A发送完数据后，关闭socket
(四)进程A发送完数据后，关闭socket输出流
socket提供关闭输入输出流的方法(shutdownInput() ,shutdownOutput() )
socket也提供了2个状态测试方法用于判断输入输出流是否关闭(isInputShutdown(),isOutputShutdown())

socket选项设置
TCP_NODELAY 表示立即发送数据
setTcpNoDelay(boolean on)
getTcpNoDelay()
默认情况下，发送数据采用Negale算法,Negale算法是值发送方发送数据不会立刻发出,而是先放在缓存里，等缓冲区满了再发出。Negale算法适用于发送方需要发送大批数据，并且接收方会及时作出回应的场合，这种算法通过减少传输数据的次数来提高通信效率。
如果发送小批量数据，并且接收方不一定会立即发送响应数据，那么Negale算法反而会使发送方运行慢，对于GUI程序，如网络游戏(服务端需要实时跟踪客户端鼠标的移动)，客户端鼠标位置移动信息需要实时发送到服务端，由Negale采用缓存，大大降低实时响应速度，导致客户端程序运行很慢。
TCP_NODELAY的默认值为false,表示采用Negale算法，调用setTcpNoDelay(true)方法，会关闭socket的缓存,确保数据及时发送，如果socket底层不支持TCP_NODELAY选项，调用方法是回抛出SocketException

SO_REUSEADDR 是否允许重用socket所绑定的本地地址
当接收方通过socket close方法关闭socket时，如果网络上还有发送到这个socket数据，底层socket不会立即释放本地端口，而是等待一段时间，确保接收到了网络上发送过来的延迟数据，然后在释放端口。socket接收到延迟数据后，不会对这些数据作任何处理。socket接收延迟数据目的是确保这些数据不会被其他碰巧绑定到同样的端口的新进程收到。
客户端一般采用随机端口，因此出现两个客户端绑定到同样的端口可能性不大，而服务器端都是使用固定端口，当服务器端程序关闭后，有可能他的端口还会被占用一段时间，如果此时立刻在此主机上重启服务器程序，由于服务器端口被占用，使得服务器程序无法绑定改端口，启动失败。
为了确保一个进程关闭socket后，即使它还没释放端口，同一主机上的其他进程可以立刻重用该端口，可以调用socket的setReuseAddress(true)
需要注意的是setReuseAddress(boolean on)方法必须在socket还未绑定到一个本地端口之前调用，否则无效

SO_TIMEOUT 表示接收数据时的等待超时时间，以毫秒为单位，默认值为0，表示无限等待
当通过socket的输入流读数据时，如果还没有数据，就会等待，
如byte [] buffer = new byte[1024];
InputStream is = socket.getInputStream();
is.read(buffer);
如果输入流中没有数据，is.read(buffer)会等待发送方发送数据，直到满足以下情况才结束
(一)输入流中已有1024字节
(二)......................
(三)已经读到流的末尾，返回-1
(四)连接已断，抛出IOExcepton
(五)超过了socket设置setsoTimeout()方法设置了等待超时时间,setsoTimeout()方法必须在读取数据之前才有效
当输入流的read方法抛出socketTimeoutExcepton后，如果socket任然是连接的，可以再次读取数据

SO_LINGER 表示当执行socket的close方法时，是否立即关闭底层的socket
用来控制socket关闭时的行为，默认情况下，执行socket close方法，该方法立即换回，但底层的socket并不立即关闭，直到发送完所有剩余数据，才会真正关闭socket,断开连接。
socket.setSoLinger(true,0),执行socket close方法后，该方法立即换回，但底层的socket也立即关闭，未发完的数据将被丢弃。
socket.setSoLinger(true,3600)执行socket close方法后，该方法不会立即换回，而是进入阻塞状态，同时底socket会尝试发送完剩余的数据，只有当数据发送完毕或时间超时时，才会关闭socket，单位为秒
(程序发送数据到网络时，由网络发送数据到接收方，当程序关闭socket时，数据可能还在网络上传输)

SO_RCVBUF 表示接收数据的缓冲区大小
一般来说，传输较大的连续输入快可以使用较大的缓冲区，这可以减少传输数据的次数，提高传输效率，而对于交互频繁且单次传送数据量较小的通信方式(Telnet和网络游戏),则应该采用小的缓冲区，确保小批量的数据能及时发送给对方，如果底层socket不支持SO_RCVBUF，调用方法会抛出SocketException

SO_SNDBUF 表示发送数据的缓冲区大小

分享到：