案例 1

要求：

• 编写客户端程序和服务器端程序；
• 客户端可以输入一个音乐文件名，比如“高山流水”，服务端收到音乐名后，可以给客户端返回这个音乐文件，如果服务器本地没有这个文件，返回一个默认的音乐即可。；
• 客户端接收到文件后，保存到本地；

本质：其实就是指定下载文件的应用，可以结合文件上传来做

Server 端 - 提供文件下载服务

package Atest;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
    public static void main(String[] args) throws Exception {
        // 监听 9999 端口
        int port = 9999;
        ServerSocket serverSocket = new ServerSocket(port);
        // 等待客户端连接后发送下载文件的名称
        Socket socket = serverSocket.accept();
        // 读取客户端要下载的文件名
        InputStream inputStream = socket.getInputStream();
        String downloadFileName = null;
        byte[] buffer = new byte[1024];
        int len = 0;
        while ((len = inputStream.read(buffer)) != -1) {
            downloadFileName = new String(buffer, 0, len);
        }
        System.out.println("客户端需要下载的文件：" + downloadFileName);
        // 服务器上有两个文件， 无名.mp3  高山流水.mp3
        // 如果客户端下载的是高山流水，就返回该文件，否则一律返回 无名.mp3
        String resFilePath = "";
        if ("高山流水".equals(downloadFileName)) {
            resFilePath = "./高山流水.mp3";
        } else {
            resFilePath = "./无名.mp3";
        }
        // 创建一个输入流，读取文件到输入流对象中
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream(resFilePath));
        byte[] bytes = streamToByteArray(bis);
        // 得到 socket 关联的输出流
        BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
        // 写入到数据通道，返回给客户端
        bos.write(bytes);
        socket.shutdownOutput();
        // 关闭相关的资源
        bis.close();
        bos.close();
        socket.close();
        serverSocket.close();
        System.out.println("服务端退出");
    }
    public static byte[] streamToByteArray(InputStream is) throws Exception {
        // 创建输出流对象
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        byte[] buffer = new byte[1024];
        int len = 0;
        while ((len = is.read(buffer)) != -1) {
            bos.write(buffer, 0, len);
        }
        byte[] bytes = bos.toByteArray();
        bos.close();
        return bytes;
    }
}

Client 端 - 下载者

package Atest;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class Client {
    public static void main(String[] args) throws Exception {
        // 接收用户输入，指定下载文件名
        Scanner sc = new Scanner(System.in);
        System.out.println("请输入下载文件名：");
        String downloadFileName = sc.next();

        // 客户端连接服务器，准备发送文件名给服务器
        Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
        // 获取 socket 相关的输出流
        OutputStream os = socket.getOutputStream();
        os.write(downloadFileName.getBytes());
        socket.shutdownOutput();

        // 读取服务端返回的文件（字节数据）
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        byte[] bytes = streamToByteArray(bis);
        // 得到一个输出流，准备将 byte[] 数组写入到磁盘文件
        String filePath = "./" + downloadFileName + "_download.mp3";
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filePath));
        bos.write(bytes);

        // 关闭相关资源
        bos.close();
        bis.close();
        os.close();
        socket.close();

        System.out.println("客户端下载完毕");

    }

    public static byte[] streamToByteArray(InputStream is) throws Exception {
        // 创建输出流对象
        ByteArrayOutputStream bos = new ByteArrayOutputStream();

        byte[] buffer = new byte[1024];
        int len = 0;

        while ((len = is.read(buffer)) != -1) {
            bos.write(buffer, 0, len);
        }
        byte[] bytes = bos.toByteArray();
        bos.close();

        return bytes;
    }
}