网络编程应用：基于TCP协议【实现文件上传】--练习

水深无声 2022-06-16 03:39 242阅读 0赞

**要求：**

基于TCP协议实现一个向服务器端上传文件的功能

--------------------

客户端代码：

package Homework2;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    public class Client {
        
        public static void main(String[] args){
            System.out.println("客户端已启动");
    
            //1.在本工程下创建一个文件夹，并创建文件，使用这个文件来进行文件传输功能
            //当然你也可以在自己电脑上找一个文件直接上传
            File file=new File("Example");
            file.mkdirs();
            File file2=new File("Example\\a.txt");
    
    
            Socket socket=null;
            OutputStream os=null;
            FileInputStream fis=null;
    
            try {
                //2.创建Socket对象，并得到相应的输出流----以及创建文件输入流
                socket=new Socket("127.0.0.1",7000);
                os=socket.getOutputStream();
                fis=new FileInputStream(file2);
    
    
                byte[] bs=new byte[1024];
                int count=0;
                //3.发送文件
                while((count=fis.read(bs))!=-1){
                    os.write(bs, 0, count);
                    os.flush();
                }
            } catch (UnknownHostException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally {
                if(os!=null){
                    try {
                        os.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(fis!=null){
                    try {
                        fis.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(socket!=null){
                    try {
                        socket.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }
    
        }
    
    }

--------------------

服务器端代码

package Homework2;
    
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    //2 实现上传文件
    public class Server {
        public static void main(String[] args){
            System.out.println("服务器已启动");
    
    
            Socket socket=null;
            InputStream is=null;
            FileOutputStream fos=null;
            ServerSocket serverSocket=null;
    
            try {
                //1.创建ServerSocket对象，获得Socket对象以及输入流
                serverSocket=new ServerSocket(7000);
                socket=serverSocket.accept();
                is=socket.getInputStream();
    
                //2.接收过来的文件存放位置
                fos=new FileOutputStream(new File("Example\\e.txt"));
    
                //3.接收文件
                byte[] bs=new byte[1024];
                int count=0;
                while((count=is.read(bs))!=-1){
                    fos.write(bs, 0, count);
                    fos.flush();
                }
                System.out.println("文件已接收：over!");
    
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally {
                if(is!=null){
                    try {
                        is.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(fos!=null){
                    try {
                        fos.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(socket!=null){
                    try {
                        socket.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if(serverSocket!=null){
                    try {
                        serverSocket.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }
    
        }
    }

--------------------

**运行结果：**

![这里写图片描述][SouthEast]

[SouthEast]: /images/20220616/99a10424b5fe44a9b15b7a773e134051.png