基于UDP的简单的Client/Server程序设计

[java]代码库
//1. 客户方程序 QuoteClient.java
 
import java.io.*;
import java.net.*;
import java.util.*;
 
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 DatagramSocket();
        // 创建数据报套接字
 
        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
 
class QuoteServer {
    public static void main(String args[]) throws java.io.IOException {
        new QuoteServerThread().start();
        // 启动一个QuoteServerThread线程
    }
}
 
// 3. 程序QuoteServerThread.java
 
// 服务器线程
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 = getNextQuotes();
                // 否则调用成员函数从文件中读出字符串
                buf = dString.getBytes();
                // 把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 (IOException e) { // 异常处理
            returnValue = "IOException occurred in server";
            // 置异常返回值
        }
        return returnValue; // 返回字符串
    }
}
用户注册

用户登录

发表随想

该用户最新代码

编程随想

[java]代码库

网友评论 (发表评论)

回复评论

发表评论：

评论须知：

扫码下载

输入口令后可复制整站源码
