java - Java Socket 编程中从多个客户端向单个服务器发送文件

Question

嗨，我正在尝试用 java 创建一个程序，用于将文件从多个客户端发送到单个服务器。这可能吗？

我尝试过这可以用于多个客户端和单个服务器，而且它也是从服务器到客户端发送程序。

客户端程序

public class Client {

    public Client(String ip,String path,int i) throws IOException {

        int filesize=2022386;
        int bytesRead;
        int currentTot = 0;

        File file=new File(path);
        File dir=new File("c:/PAMR/Dest"+i+"/");
        String name=file.getName();

        if(!dir.exists())
        {
            dir.mkdir();
        }

        Socket socket = new Socket(ip,9100);
        byte [] bytearray  = new byte [filesize];
        InputStream is = socket.getInputStream();


        FileOutputStream fos = new FileOutputStream(dir+"/"+name);

        BufferedOutputStream bos = new BufferedOutputStream(fos);
        bytesRead = is.read(bytearray,0,bytearray.length);


        currentTot = bytesRead;

        do {
            bytesRead =
              is.read(bytearray, currentTot, (bytearray.length-currentTot));
           if(bytesRead >= 0) currentTot += bytesRead;


        } while(bytesRead > -1);


        bos.write(bytearray, 0 , currentTot);
        bos.flush();
        bos.close();
        socket.close();

    }



}

对于服务器

public class Source {


    public  Source(String path) throws IOException {

           ServerSocket serverSocket = new ServerSocket(9100);
           System.out.println("Server is in Listening Mode");
           Socket socket = serverSocket.accept();

           File transferFile = new File (path);

           byte [] bytearray  = new byte [(int)transferFile.length()];
           FileInputStream fin = new FileInputStream(transferFile);
           BufferedInputStream bin = new BufferedInputStream(fin);

           bin.read(bytearray,0,bytearray.length);
           OutputStream os = socket.getOutputStream();



           os.write(bytearray,0,bytearray.length);
           bin.close();
           os.close();
           os.flush();
           socket.close();
           serverSocket.close();


     }


}

它是我正在做的项目的代码的一部分。

任何人请帮忙。

Answer 1

你想要这样的东西:

boolean working = true;
ServerSocket ss = new ServerSocket(9100);
while(working) {
        Socket s = ss.accept();
        MyThread myThread = new MyThread(s);
        myTread.start();
}

其中MyThread是您的一个类，它扩展了Thread类，接受与刚刚连接的客户端的连接，然后接受发送给它的任何文件或数据。