程序清单 codes/ / /Client java

public class Client

{

public static void main（String[] args）

throws IOException

{

Socket socket = new Socket（ ）

//将Socket对应的输入流包装成BufferedReader

BufferedReader br = new BufferedReader（

new InputStreamReader（socket getInputStream（）））

//进行普通IO操作

String line = br readLine（）

System out println（ 来自服务器的数据 + line）

//关闭输入流 socket

br close（）

socket close（）

}

}

上面程序中粗体字代码是使用ServerSocket和Socket建立网络连接的代码 斜体字代码是通过Socket获取输入流 输出流进行通信的代码 通过程序不难看出 一旦使用ServerSocket Socket建立网络连接之后 程序通过网络通信与普通IO并没有太大的区别

先运行上面程序中的Server类 将看到服务器一直处于等待状态 因为服务器使用了死循环来接受来自客户端的请求 再运行Client类 将可看到程序输出 来自服务器的数据 您好 您收到了服务器的新年祝福！ 这表明客户端和服务器端通信成功

上面程序为了突出通过ServerSocket和Socket建立连接 并通过底层IO流进行通信的主题 程序没有进行异常处理 也没有使用finally块来关闭资源

实际应用中 程序可能不想让执行网络连接 读取服务器数据的进程一直阻塞 而是希望当网络连接 读取操作超过合理时间之后 系统自动认为该操作失败 这个合理时间就是超时时长 Socket对象提供了一个setSoTimeout（int timeout）来设置超时时长 如下的代码片段所示

Socket s = new Socket（ ）

//设置 秒之后即认为超时

s setSoTimeout（ ）

当我们为Socket对象指定了超时时长之后 如果在使用Socket进行读 写操作完成之前已经超出了该时间限制 那么这些方法就会抛出SocketTimeoutException异常 程序可以对该异常进行捕捉 并进行适当处理 如下代码所示

try

{

//使用Scanner来读取网络输入流中的数据

Scanner scan = new Scanner（s getInputStream（））

//读取一行字符

String line = scan nextLine（）

…

}

//捕捉SocketTimeoutException异常

catch（SocketTimeoutException ex）

{

//对异常进行处理

…

}

假设程序需要为Socket连接服务器时指定超时时长 即经过指定时间后 如果该Socket还未连接到远程服务器 则系统认为该Socket连接超时 但Socket的所有构造器里都没有提供指定超时时长的参数 所以程序应该先创建一个无连接的Socket 再调用Socket的connect（）方法来连接远程服务器 而connect方法就可以接受一个超时时长参数 如下代码所示

//创建一个无连接的Socket

Socket s = new Socket（）

//让该Socket连接到远程服务器 如果经过 秒还没有连接到 则认为连接超时

s connconnect（new InetAddress（host port） ）

       返回目录 疯狂Java讲义

       编辑推荐

       Java程序性能优化 让你的Java程序更快 更稳定

       新手学Java 编程

       Java程序设计培训视频教程

lishixinzhi/Article/program/Java/hx/201311/27265

程序客户端代码也与此类似 客户端采用循环不断地读取用户键盘输入 每当读到用户输入内容后就将该内容封装成DatagramPacket数据报 再将该数据报发送出去 接着把DatagramSocket中的数据读入接收用的DatagramPacket中（实际上是读入该DatagramPacket所封装的字节数组中） 客户端代码如下

程序清单 codes/ / /UdpClient java

public class UdpClient

{

//定义发送数据报的目的地

public static final int DEST_PORT =

public static final String DEST_IP =

//定义每个数据报的最大大小为 K

private static final int DATA_LEN =

//定义该客户端使用的DatagramSocket

private DatagramSocket socket = null

//定义接收网络数据的字节数组

byte[] inBuff = new byte[DATA_LEN]

//以指定字节数组创建准备接受数据的DatagramPacket对象

private DatagramPacket inPacket =

new DatagramPacket（inBuff inBuff length）

//定义一个用于发送的DatagramPacket对象

private DatagramPacket outPacket = null

public void init（）throws IOException

{

try

{

//创建一个客户端DatagramSocket 使用随机端口

socket = new DatagramSocket（）

//初始化发送用的DatagramSocket 它包含一个长度为 的字节数组

outPacket = new DatagramPacket（new byte[ ]

InetAddress getByName（DEST_IP） DEST_PORT）

//创建键盘输入流

Scanner scan = new Scanner（System in）

//不断读取键盘输入

while（scan hasNextLine（））

{

//将键盘输入的一行字符串转换字节数组

byte[] buff = scan nextLine（） getBytes（）

//设置发送用的DatagramPacket里的字节数据

outPacket setData（buff）

//发送数据报

socket send（outPacket）

//读取Socket中的数据 读到的数据放在inPacket所封装的字节数组里

socket receive（inPacket）

System out println（new String（inBuff

inPacket getLength（）））

}

}

//使用finally块保证关闭资源

finally

{

if （socket != null）

{

socket close（）

}

}

}

public static void main（String[] args）

throws IOException

{

new UdpClient（） init（）

}

}

上面程序的粗体字代码同样也是通过DatagramSocket发送 接收DatagramPacket的关键代码 这些代码与服务器的代码基本相似 而客户端与服务器端的唯一区别在于 服务器所在IP地址 端口是固定的 所以客户端可以直接将该数据报发送给服务器 而服务器则需要根据接收到的数据报来决定将 反馈 数据报的目的地

读者可能会发现 使用DatagramSocket进行网络通信时 服务器端无须 也无法保存每个客户端的状态 客户端把数据报发送到服务器后 完全有可能立即退出 但不管客户端是否退出 服务器无法知道客户端的状态

当使用UDP协议时 如果想让一个客户端发送的聊天信息可被转发到其他所有客户端则比较困难 可以考虑在服务器使用Set来保存所有客户端信息 每当接收到一个客户端的数据报之后 程序检查该数据报的源SocketAddress是否在Set集合中 如果不在就将该SocketAddress添加到该Set集合中 但这样一来又涉及一个问题 可能有些客户端发送一个数据报之后永久性地退出了程序 但服务器端还将该客户端的SocketAddress保存在Set集合中……总之 这种方式需要处理的问题比较多 编程比较烦琐 幸好Java为UDP协议提供了MulticastSocket类 通过该类可以轻松实现多点广播

       返回目录 疯狂Java讲义

       编辑推荐

       Java程序性能优化 让你的Java程序更快 更稳定

       新手学Java 编程

       Java程序设计培训视频教程

lishixinzhi/Article/program/Java/hx/201311/27260

《疯狂java讲义》第二版 李刚 建议.里面增加了JDK7。

视频：马士兵、毕向东、张孝祥等。

JAVA基础是后面的必备功，学好了JAVA基础，其实后面的不是很难。

---