1. 客户方程序 QuoteClient.java

　　import java.io.*;
　　import java.net.*;
　　import java.util.*;
　　public class QuoteClient {
　　　public static void main(String[] args) throws IOException
　　　{
　　　　if(args.length!=1) {
　　　　//如果启动的时候没有给出Server的名字，那么出错退出
　　　　　System.out.println("Usage:java QuoteClient <hostname>");
　　　　　//打印出错信息
　　　　　return; //返回
　　　　}

　　　　DatagramSocket socket=new DatagramSocklet();
　　　　//创建数据报套接字

　　　　Byte[] buf=new byte[256]; //创建缓冲区
　　　　InetAddress address=InetAddress.getByName(args [0]);
//由命令行给出的第一个参数默认为Server的名字，通过它得到Server的IP信息
　　　　DatagramPacket packet=new DatagramPacket (buf, buf.length, address, 4445);
　　　　//创建DatagramPacket对象
　　　　socket.send(packet); //发送
　　　　packet=new DatagramPacket(buf,buf.length);
　　　　//创建新的DatagramPacket对象，用来接收数据报
　　　　socket.receive(packet); //接收
　　　　String received=new String(packet.getData());
　　　　//根据接收到的字节数组生成相应的字符串
　　　　System.out.println("Quote of the Moment:"+received );
　　　　//打印生成的字符串

　　　　socket.close(); //关闭套接口
　　　}
　}

　2. 服务器方程序:QuoteServer.java

　　public class QuoteServer{
　　　public static void main(String args[]) throws java.io.IOException
　　　{
　　　　new QuoteServerThread().start();
　　　　//启动一个QuoteServerThread线程
　　　}
　　}

　3. 程序QuoteServerThread.java

　　import java.io.*;
　　import java.net.*;
　　import java.util.*;
　　//服务器线程
　　public class QuoteServerThread extends Thread
　　{
　　protected DatagramSocket socket=null;
　　//记录和本对象相关联的DatagramSocket对象
　　protected BufferedReader in=null;
　　//用来读文件的一个Reader
　　protected boolean moreQuotes=true;
　　//标志变量，是否继续操作

　　public QuoteServerThread() throws IOException {
　　//无参数的构造函数
　　　　this("QuoteServerThread");
　　　　//以QuoteServerThread为默认值调用带参数的构造函数
　　}
　　public QuoteServerThread(String name) throws IOException {
　　　　super(name); //调用父类的构造函数
　　　　socket=new DatagramSocket(4445);
　　　　//在端口4445创建数据报套接字
　　　　try{
　　　　　　in= new BufferedReader(new FileReader(" one-liners.txt"));
　　　　　　//打开一个文件，构造相应的BufferReader对象
　　　　}catch(FileNotFoundException e) { //异常处理
　　　　　　System.err.println("Could not open quote file. Serving time instead.");
　　　　　　　//打印出错信息
　　　　}
　　}
　　public void run() //线程主体
　　{
　　　　while(moreQuotes) {
　　　　　try{
　　　　　　　byte[] buf=new byte[256]; //创建缓冲区
　　　　　　　DatagramPacket packet=new DatagramPacket(buf,buf.length);
　　　　　　　//由缓冲区构造DatagramPacket对象
　　　　　　　socket.receive(packet); //接收数据报
　　　　　　　String dString=null;
　　　　　　　if(in= =null) dString=new Date().toString();
　　　　　　　//如果初始化的时候打开文件失败了，
　　　　　　　//则使用日期作为要传送的字符串
　　　　　　　else dString=getNextQuote();
　　　　　　　//否则调用成员函数从文件中读出字符串
　　　　　　　buf=dString.getByte();
　　　　　　　//把String转换成字节数组，以便传送

　　　　　　　InetAddress address=packet.getAddress();
　　　　　　　//从Client端传来的Packet中得到Client地址
　　　　　　　int port=packet.getPort(); //和端口号
　　　　　　　packet=new DatagramPacket(buf,buf.length,address,port);
　　　　　　　//根据客户端信息构建DatagramPacket
　　　　　　　socket.send(packet); //发送数据报
　　　　　　}catch(IOException e) { //异常处理
　　　　　　　e.printStackTrace(); //打印错误栈
　　　　　　　moreQuotes=false; //标志变量置false，以结束循环
　　　　　　}
　　　　}
　　　　socket.close(); //关闭数据报套接字
　　}

　　protected String getNextQuotes(){
　　//成员函数，从文件中读数据
　　　　String returnValue=null;
　　　　try {
　　　　　　　if((returnValue=in.readLine())= =null) {
　　　　　　　//从文件中读一行，如果读到了文件尾
　　　　　　　in.close( ); //关闭输入流
　　　　　　　moreQuotes=false;
　　　　　　　//标志变量置false，以结束循环
　　　　　　　returnValue="No more quotes. Goodbye.";
　　　　　　　//置返回值
　　　　　　　} //否则返回字符串即为从文件读出的字符串
　　　　}catch(IOEception e) { //异常处理
　　　　　　　returnValue="IOException occurred in server";
　　　　　　　//置异常返回值
　　　　}
　　　　return returnValue; //返回字符串
　　}
}

　　可以看出使用UDP和使用TCP在程序上还是有很大的区别的。一个比较明显的区别是，UDP的Socket编程是不提供监听功能的，也就是说通信双方更为平等，面对的接口是完全一样的。但是为了用UDP实现C/S结构，在使用UDP时可以使用DatagramSocket.receive()来实现类似于监听的功能。因为receive()是阻塞的函数，当它返回时，缓冲区里已经填满了接受到的一个数据报，并且可以从该数据报得到发送方的各种信息，这一点跟accept()是很相象的，因而可以根据读入的数据报来决定下一步的动作，这就达到了跟网络监听相似的效果。