java上传文件-蒲公英云

服务器端

package cn.net.update;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class tcpserver { 
/** * 创建一个服务器serversocket对象，和系统要指定的端口号 * 使用serversocket中的方法accept,获取到请求的客户端socket * 使用socket对象中的方法getinputstream获取到网络字节输入流inputstream对象 * 判断路径是否存在 * 创建一个本地字节输出流fileoutputstream对象构造方法中绑定要输出的目的地 * 使用网络字节输入流inputstream对象中read方法读取客户端上传的文件 * 使用本地字节输出流fileoutputstream 获取到网络字节输出流outputstream对象 * 使用网络字节输出流 outputstream中的write给客户端写上传成功 * 释放资源 */
public static void main(String[] args) throws IOException { 
    ServerSocket server = new ServerSocket(8888);
    Socket socket = server.accept();//客户端获取到字节流数据
    InputStream is = socket.getInputStream();
    File file = new File("D:\\IdeaProjects\\basic-code\\day04-code\\src\\cn\\net\\update");
    if (!file.exists()){ 
        file.mkdirs();
    }
    FileOutputStream fos = new FileOutputStream(file+"\\2.txt");
    int len=0;
    byte[] bytes = new byte[1024];
    while ((len=is.read(bytes))!=-1){ 
        fos.write(bytes,0,len);
    }
    socket.getOutputStream().write("上传成功".getBytes());
    fos.close(); //读写文件关闭
    socket.close();//socket关闭
    server.close();//服务器关闭
}
}

客户端

package cn.net.update;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class tpccliebt { 
/** * 创建一个本地字节输入流fileinputstream对象构造方法中绑定要读取的数据源 * 创建一个客户端socket对象 构造方法中绑定服务器的ip地址和端口号 * 使用socket中方法getoutputstream 获取网络字节输出流outputstream * 使用本地字节输入流 fileinputputstream 对象中writef读取到文件上传服务器 */
public static void main(String[] args) throws IOException { 
    FileInputStream fis =new FileInputStream("D:\\IdeaProjects\\basic-code\\day04-code\\src\\cn\\net\\update\\1.TXT");
    Socket socket = new Socket("127.0.0.1",8888);
    OutputStream os = socket.getOutputStream();
    int len=0;
    byte[] bytes = new byte[1024];
    while ((len=fis.read(bytes))!=-1){ 
        os.write(bytes,0,len);
    }
    socket.shutdownOutput();
// 回血数据
    InputStream is = socket.getInputStream();
    while ((len=is.read(bytes))!=-1){ 
        System.out.println(new String(bytes,0,len));
    }
    fis.close();
    socket.close();
}
}

优化过后的服务端

package cn.net.update;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;
public class tcpserver { 
/** * 创建一个服务器serversocket对象，和系统要指定的端口号 * 使用serversocket中的方法accept,获取到请求的客户端socket * 使用socket对象中的方法getinputstream获取到网络字节输入流inputstream对象 * 判断路径是否存在 * 创建一个本地字节输出流fileoutputstream对象构造方法中绑定要输出的目的地 * 使用网络字节输入流inputstream对象中read方法读取客户端上传的文件 * 使用本地字节输出流fileoutputstream 获取到网络字节输出流outputstream对象 * 使用网络字节输出流 outputstream中的write给客户端写上传成功 * 释放资源 */
public static void main(String[] args) throws IOException { 
    ServerSocket server = new ServerSocket(8888);
    while (true){ 
        Socket socket = server.accept();//客户端获取到字节流数据
        new Thread(new Runnable() { 
            @Override
            public void run() { 
                    try { 
                        InputStream is = socket.getInputStream();
                        File file = new File("D:\\IdeaProjects\\basic-code\\day04-code\\src\\cn\\net\\update");
                        if (!file.exists()){ 
                            file.mkdirs();
                        }
                        String filename = "itcast"+System.currentTimeMillis()+new Random(999999)+".txt";
                        FileOutputStream fos = new FileOutputStream(file+"\\"+filename);
                        int len=0;
                        byte[] bytes = new byte[1024];
                        while ((len=is.read(bytes))!=-1){ 
                            fos.write(bytes,0,len);
                        }
                        socket.getOutputStream().write("上传成功".getBytes());
                        fos.close(); //读写文件关闭
                        socket.close();//socket关闭
                    }catch (IOException e){ 
                        System.out.println(e);
                    }
            }
        }).start();
    }
// server.close();//服务器关闭
}
}