知识大全 Socket类的getter和setter方法（2）

Posted 2022-07-19 知

篇首语：知识比金钱宝贵，比刀剑锋利，比枪炮威力大。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Socket类的getter和setter方法（2）相关的知识，希望对你有一定的参考价值。

Java网络编程从入门到精通（18）：Socket类的getter和setter方法（2） 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　二用于获得和设置Socket选项的getter和setter方法

　　Socket选择可以指定Socket类发送和接受数据的方式在JDK 中共有个Socket选择可以设置这个选项都定义在 SocketOptions接口中定义如下

　　 public final static int TCP_NODELAY = x ; public final static int SO_REUSEADDR = x ; public final static int SO_LINGER = x ; public final static int SO_TIMEOUT = x ; public final static int SO_SNDBUF = x ; public final static int SO_RCVBUF = x ; public final static int SO_KEEPALIVE = x ; public final static int SO_OOBINLINE = x ;

　　有趣的是这个选项除了第一个没在SO前缀外其他个选项都以SO作为前缀其实这个SO就是Socket Option的缩写因此在Java中约定所有以SO为前缀的常量都表示Socket选项当然也有例外如TCP_NODELAY 在Socket类中为每一个选项提供了一对get和set方法分别用来获得和设置这些选项

　　 TCP_NODELAY

　　 public boolean getTcpNoDelay() throws SocketExceptionpublic void setTcpNoDelay(boolean on) throws SocketException

　　在默认情况下客户端向服务器发送数据时会根据数据包的大小决定是否立即发送当数据包中的数据很少时如只有个字节而数据包的头却有几十个字节（IP头+TCP头）时系统会在发送之前先将较小的包合并到软大的包后一起将数据发送出去在发送下一个数据包时系统会等待服务器对前一个数据包的响应当收到服务器的响应后再发送下一个数据包这就是所谓的Nagle算法在默认情况下 Nagle算法是开启的

　　这种算法虽然可以有效地改善网络传输的效率但对于网络速度比较慢而且对实现性的要求比较高的情况下（如游戏 Telnet等）使用这种方式传输数据会使得客户端有明显的停顿现象因此最好的解决方案就是需要Nagle算法时就使用它不需要时就关闭它而使用setTcpToDelay正好可以满足这个需求当使用setTcpNoDelay（true）将Nagle算法关闭后客户端每发送一次数据无论数据包的大小都会将这些数据发送出去

　　 SO_REUSEADDR

　　 public boolean getReuseAddress() throws SocketException public void setReuseAddress(boolean on) throws SocketException

　　通过这个选项可以使多个Socket对象绑定在同一个端口上其实这样做并没有多大意义但当使用close方法关闭Socket连接后 Socket对象所绑定的端口并不一定马上释放系统有时在Socket连接关闭才会再确认一下是否有因为延迟面未到达的数据包这完全是在底层处理的也就是说对用户是透明的因此在使用Socket类时完全不会感觉到

　　这种处理机制对于随机绑定端口的Socket对象没有什么影响但对于绑定在固定端口的Socket对象就可能会抛出 Address already in use JVM_Bind 例外因此使用这个选项可以避免个例外的发生

　　 package mynet;import *;import java io *;public class Test public static void main(String[] args) Socket socket = new Socket(); Socket socket = new Socket(); try socket setReuseAddress(true); socket bind(new InetSocketAddress( )); System out println( socket getReuseAddress(): + socket getReuseAddress()); socket bind(new InetSocketAddress( )); catch (Exception e) System out println( error: + e getMessage()); try socket setReuseAddress(true); socket bind(new InetSocketAddress( )); System out println( socket getReuseAddress(): + socket getReuseAddress()); System out println( 端口第二次绑定成功! ); catch (Exception e ) System out println(e getMessage());

　　上面的代码的运行结果如下

　　 socket getReuseAddress():trueerror:Address already in use: JVM_Bindsocket getReuseAddress():true端口第二次绑定成功!

　　使用SO_REUSEADDR选项时有两点需要注意

　　必须在调用bind方法之前使用setReuseAddress方法来打开SO_REUSEADDR选项因此要想使用SO_REUSEADDR选项就不能通过Socket类的构造方法来绑定端口

　　必须将绑定同一个端口的所有的Socket对象的SO_REUSEADDR选项都打开才能起作用如在例程中 socket 和socket 都使用了setReuseAddress方法打开了各自的SO_REUSEADDR选项

　　 SO_LINGER

　　 public int getSoLinger() throws SocketExceptionpublic void setSoLinger(boolean on int linger) throws SocketException

　　这个Socket选项可以影响close方法的行为在默认情况下当调用close方法后将立即返回如果这时仍然有未被送出的数据包那么这些数据包将被丢弃如果将linger参数设为一个正整数n时（n的值最大是）在调用close方法后将最多被阻塞n秒在这n秒内系统将尽量将未送出的数据包发送出去如果超过了n秒如果还有未发送的数据包这些数据包将全部被丢弃而close方法会立即返回如果将linger设为和关闭SO_LINGER选项的作用是一样的

　　如果底层的Socket实现不支持SO_LINGER都会抛出SocketException例外当给linger参数传递负数值时 setSoLinger还会抛出一个IllegalArgumentException例外可以通过getSoLinger方法得到延迟关闭的时间如果返回则表明SO_LINGER是关闭的例如下面的代码将延迟关闭的时间设为分钟

　　 if(socket getSoLinger() == ) socket setSoLinger(true );

　　 SO_TIMEOUT

　　 public int getSoTimeout() throws SocketExceptionpublic void setSoTimeout(int timeout) throws SocketException

　　这个Socket选项在前面已经讨论过可以通过这个选项来设置读取数据超时当输入流的read方法被阻塞时如果设置timeout（timeout的单位是毫秒）那么系统在等待了timeout毫秒后会抛出一个InterruptedIOException例外在抛出例外后输入流并未关闭你可以继续通过read方法读取数据

　　如果将timeout设为就意味着read将会无限等待下去直到服务端程序关闭这个Socket 这也是timeout的默认值如下面的语句将读取数据超时设为秒

　　 socket setSoTimeout( * );

　　当底层的Socket实现不支持SO_TIMEOUT选项时这两个方法将抛出SocketException例外不能将timeout设为负数否则setSoTimeout方法将抛出IllegalArgumentException例外

　　 SO_SNDBUF

　　 public int getSendBufferSize() throws SocketExceptionpublic void setSendBufferSize(int size) throws SocketException

　　在默认情况下输出流的发送缓冲区是个字节（ K）这个值是Java所建议的输出缓冲区的大小如果这个默认值不能满足要求可以用setSendBufferSize方法来重新设置缓冲区的大小但最好不要将输出缓冲区设得太小否则会导致传输数据过于频繁从而降低网络传输的效率

　　如果底层的Socket实现不支持SO_SENDBUF选项这两个方法将会抛出SocketException例外必须将size设为正整数否则setSendBufferedSize方法将抛出IllegalArgumentException例外

　　 SO_RCVBUF

　　 public int getReceiveBufferSize() throws SocketExceptionpublic void setReceiveBufferSize(int size) throws SocketException

　　在默认情况下输入流的接收缓冲区是个字节（ K）这个值是Java所建议的输入缓冲区的大小如果这个默认值不能满足要求可以用setReceiveBufferSize方法来重新设置缓冲区的大小但最好不要将输入缓冲区设得太小否则会导致传输数据过于频繁从而降低网络传输的效率

　　如果底层的Socket实现不支持SO_RCVBUF选项这两个方法将会抛出SocketException例外必须将size设为正整数否则setReceiveBufferSize方法将抛出IllegalArgumentException例外

　　 SO_KEEPALIVE

　　 public boolean getKeepAlive() throws SocketExceptionpublic void setKeepAlive(boolean on) throws SocketException

　　如果将这个Socket选项打开客户端Socket每隔段的时间（大约两个小时）就会利用空闲的连接向服务器发送一个数据包这个数据包并没有其它的作用只是为了检测一下服务器是否仍处于活动状态如果服务器未响应这个数据包在大约分钟后客户端Socket再发送一个数据包如果在分钟内服务器还没响应那么客户端Socket将关闭如果将Socket选项关闭客户端Socket在服务器无效的情况下可能会长时间不会关闭 SO_KEEPALIVE选项在默认情况下是关闭的可以使用如下的语句将这个SO_KEEPALIVE选项打开

　　 socket setKeepAlive(true);

　　 SO_OOBINLINE

　　 public boolean getOOBInline() throws SocketException public void setOOBInline(boolean on) throws SocketException

　　如果这个Socket选项打开可以通过Socket类的sendUrgentData方法向服务器发送一个单字节的数据这个单字节数据并不经过输出缓冲区而是立即发出虽然在客户端并不是使用OutputStream向服务器发送数据但在服务端程序中这个单字节的数据是和其它的普通数据混在一起的因此在服务端程序中并不知道由客户端发过来的数据是由OutputStream还是由sendUrgentData发过来的下面是sendUrgentData方法的声明

　　 public void sendUrgentData(int data) throws IOException

　　虽然sendUrgentData的参数data是int类型但只有这个int类型的低字节被发送其它的三个字节被忽略下面的代码演示了如何使用SO_OOBINLINE选项来发送单字节数据

　　 package mynet;import *;import java io *;class Server public static void main(String[] args) throws Exception ServerSocket serverSocket = new ServerSocket( ); System out println( 服务器已经启动端口号 ); while (true) Socket socket = serverSocket accept(); socket setOOBInline(true); InputStream in = socket getInputStream(); InputStreamReader inReader = new InputStreamReader(in); BufferedReader bReader = new BufferedReader(inReader); System out println(bReader readLine()); System out println(bReader readLine()); socket close(); public class Client public static void main(String[] args) throws Exception Socket socket = new Socket( ); socket setOOBInline(true); OutputStream out = socket getOutputStream(); OutputStreamWriter outWriter = new OutputStreamWriter(out); outWriter write( ); // 向服务器发送字符 C outWriter write( hello world\\r\\n ); socket sendUrgentData( ); // 向服务器发送字符 A socket sendUrgentData( ); // 向服务器发送字符 B outWriter flush(); socket sendUrgentData( ); // 向服务器发送汉字中 socket sendUrgentData( ); socket sendUrgentData( ); // 向服务器发送汉字国 socket sendUrgentData( ); socket close();

　　由于运行上面的代码需要一个服务器类因此在加了一个类名为Server的服务器类关于服务端套接字的使用方法将会在后面的文章中详细讨论在类Server类中只使用了ServerSocket类的accept方法接收客户端的请求并从客户端传来的数据中读取两行字符串并显示在控制台上

　　测试

　　由于本例使用了因Server和Client类必须在同一台机器上运行

　　运行Server

　　 java mynet Server

　　运行Client

　　 java mynet Client

　　在服务端控制台的输出结果

　　服务器已经启动端口号 ABChello world中国

　　在ClienT类中使用了sendUrgentData方法向服务器发送了字符 A （）和 B （）但发送 B 时实际发送的是由于sendUrgentData只发送整型数的低字节因此实际发送的是十进制整型的二进制形式如图所示

图十进制整型的二进制形式

　　从图可以看出虽然分布在了两个字节上但它的低字节仍然是

　　在Client类中使用flush将缓冲区中的数据发送到服务器我们可以从输出结果发现一个问题在Client类中先后向服务器发送了 C hello world r n A B 而在服务端程序的控制台上显示的却是ABChello world 这种现象说明使用sendUrgentData方法发送数据后系统会立即将这些数据发送出去而使用write发送数据必须要使用flush方法才会真正发送数据

　　在Client类中向服务器发送中国字符串由于中是由和两个字节组成的而国是由和两个字节组成的因此可分别发送这四个字节来传送中国字符串

cha138/Article/program/Java/hx/201311/26387