所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。\x0d\x0a以J2SDK-1.3为例，Socket和ServerSocket类库位于java.net包中。ServerSocket用于服务器端，Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例，操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别，不因为在服务器端或在客户端而产生不同级别。不管是Socket还是ServerSocket它们的工作都是通过SocketImpl类及其子类完成的。\x0d\x0a重要的Socket API：\x0d\x0ajava.net.Socket继承于java.lang.Object，有八个构造器，其方法并不多，下面介绍使用最频繁的三个方法，其它方法大家可以见JDK-1.3文档。\x0d\x0a. Accept方法用于产生"阻塞"，直到接受到一个连接，并且返回一个客户端的Socket对象实例。"阻塞"是一个术语，它使程序运行暂时"停留"在这个地方，直到一个会话产生，然后程序继续；通常"阻塞"是由循环产生的。\x0d\x0a. getInputStream方法获得网络连接输入，同时返回一个InputStream对象实例。\x0d\x0a. getOutputStream方法连接的另一端将得到输入，同时返回一个OutputStream对象实例。\x0d\x0a注意：其中getInputStream和getOutputStream方法均会产生一个IOException，它必须被捕获，因为它们返回的流对象，通常都会被另一个流对象使用。\x0d\x0a2ServerSocket类例子编辑\x0d\x0a\x0d\x0apackage com.lanber.socket\x0d\x0aimport java.io.DataInputStream\x0d\x0aimport java.io.DataOutputStream\x0d\x0aimport java.io.IOException\x0d\x0aimport java.net.ServerSocket\x0d\x0aimport java.net.Socket\x0d\x0apublic class ServerDemo {\x0d\x0a/**\x0d\x0a* 注意：Socket的发送与接收是需要同步进行的，即客户端发送一条信息，服务器必需先接收这条信息，\x0d\x0a* 而后才可以向客户端发送信息，否则将会有运行时出错。\x0d\x0a* @param args\x0d\x0a*/\x0d\x0apublic static void main(String[] args) {\x0d\x0aServerSocket ss = null\x0d\x0atry {\x0d\x0ass = new ServerSocket(8888)\x0d\x0a//服务器接收到客户端的数据后，创建与此客户端对话的Socket\x0d\x0aSocket socket = ss.accept()\x0d\x0a//用于向客户端发送数据的输出流\x0d\x0aDataOutputStream dos = new DataOutputStream(socket.getOutputStream())\x0d\x0a//用于接收客户端发来的数据的输入流\x0d\x0aDataInputStream dis = new DataInputStream(socket.getInputStream())\x0d\x0aSystem.out.println("服务器接收到客户端的连接请求：" + dis.readUTF())\x0d\x0a//服务器向客户端发送连接成功确认信息\x0d\x0ados.writeUTF("接受连接请求，连接成功!")\x0d\x0a//不需要继续使用此连接时，关闭连接\x0d\x0asocket.close()\x0d\x0ass.close()\x0d\x0a} catch (IOException e) {\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0a}\x0d\x0a}\x0d\x0a\x0d\x0a3客户端的例子编辑\x0d\x0apackage com.lanber.socket\x0d\x0aimportjava.io.DataInputStream\x0d\x0aimport java.io.DataOutputStream\x0d\x0aimportjava.io.IOException\x0d\x0aimport java.io.OutputStream\x0d\x0aimport java.net.Socket\x0d\x0aimport java.net.UnknownHostException\x0d\x0apublic class ClientDemo {\x0d\x0a/**\x0d\x0a* @param args\x0d\x0a*/\x0d\x0apublic static void main(String[] args) {\x0d\x0aSocket socket = null\x0d\x0atry {\x0d\x0asocket = new Socket("localhost",8888)\x0d\x0a//获取输出流，用于客户端向服务器端发送数据\x0d\x0aDataOutputStream dos = new DataOutputStream(socket.getOutputStream())\x0d\x0a//获取输入流，用于接收服务器端发送来的数据\x0d\x0aDataInputStream dis = new DataInputStream(socket.getInputStream())\x0d\x0a//客户端向服务器端发送数据\x0d\x0ados.writeUTF("我是客户端，请求连接!")\x0d\x0a//打印出从服务器端接收到的数据\x0d\x0aSystem.out.println(dis.readUTF())\x0d\x0a//不需要继续使用此连接时，记得关闭哦\x0d\x0asocket.close()\x0d\x0a} catch (UnknownHostException e) {\x0d\x0ae.printStackTrace()\x0d\x0a} catch (IOException e) {\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0a}\x0d\x0a}

二 用于获得和设置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 mynetimport  *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 mynetimport  *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类中向服务器发送 中国 字符串 由于 中 是由 和 两个字节组成的 而 国 是由 和 两个字节组成的 因此 可分别发送这四个字节来传送 中国 字符串

lishixinzhi/Article/program/Java/hx/201311/26387

Socket,又称为套接字，Socket是计算机网络通信的基本的技术之一。如今大多数基于网络的软件，如浏览器，即时通讯工具甚至是P2P下载都是基于Socket实现的。本文会介绍一下基于TCP/IP的Socket编程，并且如何写一个客户端/服务器程序。

方法/步骤

Java中的socket编程 下面的部分将通过一些示例讲解一下如何使用socket编写客户端和服务器端的程序。 注意：在接下来的示例中，我将使用基于TCP/IP协议的socket编程，因为这个协议远远比UDP/IP使用的要广泛。并且所有的socket相关的类都位于java.net包下，所以在我们进行socket编程时需要引入这个包。

写入数据 接下来就是写入请求数据，我们从客户端的socket对象中得到OutputStream对象，然后写入数据后。很类似文件IO的处理代码。

打开服务器端的socket

读取数据 通过上面得到的socket对象获取InputStream对象，然后安装文件IO一样读取数据即可。这里我们将内容打印出来。

使用socket实现一个回声服务器，就是服务器会将客户端发送过来的数据传回给客户端。

---