多线程(六)TCP文件上传和循环接收小练习

1.实现文件的上传

客户端:

//客户端
public class TCPClient {
    public static void main(String[] args) throws UnknownHostException, IOException {
        //创建客户端对象，明确要连接的服务器端ip和端口号
        Socket socket = new Socket("192.168.1.171",9000);
        //创建字节输入流，明确数据源
        FileInputStream fis = new FileInputStream("D:\io0429\a.png");
        //获取字节输出流，目的地是服务器
        OutputStream out = socket.getOutputStream();
        //开始复制
        byte[] bytes = new byte[1024];
        int len = 0;
        while((len = fis.read(bytes)) != -1){
            out.write(bytes,0,len);
        }
        //告知服务器结束
        socket.shutdownOutput();
        //接受服务器端的回复
        InputStream in = socket.getInputStream();
        len = in.read(bytes);
        System.out.println(new String(bytes,0,len));
        //释放资源
        socket.close();
        fis.close();
    }
}

服务器端:

//服务器端
public class TCPServer {
    public static void main(String[] args) throws IOException {
        //创建服务器端对象，明确端口号
        ServerSocket server = new ServerSocket(9000);
        //创建与客户端的链接，并获取与之连接的客户端对象
        Socket socket = server.accept();
        //明确目的地
        File file = new File("D:\upload");
        //如果文件夹不存在
        if(!file.exists()){
            //则创建文件夹
            file.mkdir();
        }
        String filename = "oralce"+System.currentTimeMillis()+new Random().nextInt(999999)+".png";
        FileOutputStream fos = new FileOutputStream(file+File.separator+filename);
        //明确数据源
        InputStream in = socket.getInputStream();
        byte[] bytes = new byte[1024];
        //开始复制
        int len = 0;
        while((len = in.read(bytes)) != -1){
            fos.write(bytes,0,len);
        }
        
        //回复客户端
        //获取目的地是客户端的字节输出流
        OutputStream out = socket.getOutputStream();
        out.write("上传成功".getBytes());
        //释放资源
        server.close();
        fos.close();
    }
}

2.循环接收文件

服务器端代码

public class Upload implements Runnable {
    private Socket socket;
    public Upload(){}
    public Upload(Socket socket){
        this.socket = socket;
    }
    public void run() {
        try {
            //明确目的地
            File file = new File("D:\upload");
            //如果文件夹不存在
            if(!file.exists()){
                //则创建文件夹
                file.mkdir();
            }
            String filename = "oralce"+System.currentTimeMillis()+new Random().nextInt(999999)+".png";
            FileOutputStream fos = new FileOutputStream(file+File.separator+filename);
            //明确数据源
            InputStream in = socket.getInputStream();
            byte[] bytes = new byte[1024];
            //开始复制
            int len = 0;
            while((len = in.read(bytes)) != -1){
                fos.write(bytes,0,len);
            }
            
            //回复客户端
            //获取目的地是客户端的字节输出流
            OutputStream out = socket.getOutputStream();
            out.write("上传成功".getBytes());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

测试端

public class demo01 {
    public static void main(String[] args) throws IOException {
        //创建服务器对象
        ServerSocket server = new ServerSocket(8000);
        while(true){
            //创建客户端链接，并获取与之连接 的客户端对象
            Socket socket = server.accept();
            //创建线程任务对象
            Upload u = new Upload(socket);
            Thread t = new Thread(u);
            t.start();
        }
    }
    
}

客户端

//客户端
public class TCPClient {
    public static void main(String[] args) throws UnknownHostException, IOException {
        //创建客户端对象，明确要连接的服务器端ip和端口号
        Socket socket = new Socket("192.168.1.171",8000);
        //创建字节输入流，明确数据源
        FileInputStream fis = new FileInputStream("D:\io0429\a.png");
        //获取字节输出流，目的地是服务器
        OutputStream out = socket.getOutputStream();
        //开始复制
        byte[] bytes = new byte[1024];
        int len = 0;
        while((len = fis.read(bytes)) != -1){
            out.write(bytes,0,len);
        }
        //告知服务器结束
        socket.shutdownOutput();
        //接受服务器端的回复
        InputStream in = socket.getInputStream();
        len = in.read(bytes);
        System.out.println(new String(bytes,0,len));
        //释放资源
        socket.close();
        fis.close();
    }
}