java - Java应用程序中的线程

大家好。我正在尝试用Java编写文件传输应用程序，到目前为止，一切正常：我先启动服务器和客户端，然后再传输文件。我无法将多个客户端连接到同一台服务器。我用谷歌搜索，发现我的服务器端应该在线程中运行。我该如何使用我的应用程序呢？谢谢。

服务器：

package filesharing;
import java.io.*;
import java.net.*;

public class Server
{
    public static void main(String args[])throws Exception
    {
        System.out.println("Server pornit...");

        /* Asteapta pe portul  1412 */

        ServerSocket server = new ServerSocket(1412);

        /* Accepta socketul */

        Socket sk = server.accept();

        System.out.println("Client acceptat de catre server pe portul: "+server.getLocalPort());
        InputStream input = sk.getInputStream();
        BufferedReader inReader = new BufferedReader(new InputStreamReader(sk.getInputStream()));
        BufferedWriter outReader = new BufferedWriter(new OutputStreamWriter(sk.getOutputStream()));

        /* Citeste calea fisierului */
        String filename = inReader.readLine();

        if ( !filename.equals("") ){

            /* Trimite status READY catre client */

            outReader.write("READY\n");
            outReader.flush();
        }

        /* Creaza fila noua in directorul tmp */
        FileOutputStream wr = new FileOutputStream(new File("C://tmp/" + filename));

        byte[] buffer = new byte[sk.getReceiveBufferSize()];

        int bytesReceived = 0;

        while((bytesReceived = input.read(buffer))>0)
        {
            /* Scrie in fila */
           wr.write(buffer,0,bytesReceived);
        }
    }
}

客户：

package filesharing;

import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.net.*;
import java.io.*;

public class Client extends JFrame implements ActionListener {

    private JTextField txtFile;

    public static void main(String args[]){

        /* Creare pannel client */

        Client clientForm = new Client();
        clientForm.Display();
    }

    public void Display(){

        JFrame frame = new JFrame();
        frame.setTitle("Client");

        FlowLayout layout = new FlowLayout();
        layout.setAlignment(FlowLayout.LEFT);

        JLabel lblFile = new JLabel("Fisier:");

        txtFile = new JTextField();
        txtFile.setPreferredSize(new Dimension(150,30));

        JButton btnTransfer = new JButton("Transfer");
        btnTransfer.addActionListener(this);

        JPanel mainPanel = new JPanel();
        mainPanel.setLayout(layout);
        mainPanel.add(lblFile);
        mainPanel.add(txtFile);
        mainPanel.add(btnTransfer);

        frame.getContentPane().add(mainPanel);
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        frame.pack();
        frame.setVisible(true);

    }

    public void actionPerformed(ActionEvent e) {

        /* Casuta File Open Dialog pentru selectarea fisierului */

        JFileChooser fileDlg = new JFileChooser();
        fileDlg.showOpenDialog(this);
        String filename = fileDlg.getSelectedFile().getAbsolutePath();
        txtFile.setText(filename);

        try{

            /* Incearca conectarea la serverul localhost pe portul 1412 */

            Socket sk = new Socket("localhost", 1412);
            OutputStream output = sk.getOutputStream();

            /* Trimite numele fisierului la server */

            OutputStreamWriter outputStream = new OutputStreamWriter(sk.getOutputStream());
            outputStream.write(fileDlg.getSelectedFile().getName() + "\n");
            outputStream.flush();

            /* Asteapta raspunsul de la server */

            BufferedReader inReader = new BufferedReader(new InputStreamReader(sk.getInputStream()));

            String serverStatus = inReader.readLine(); // Citeste prima linie

            /* Daca serverul e READY trimite fisierul */

            if ( serverStatus.equals("READY") ){

                FileInputStream file = new FileInputStream(filename);

                byte[] buffer = new byte[sk.getSendBufferSize()];

                int bytesRead = 0;

                while((bytesRead = file.read(buffer))>0)
                {
                    output.write(buffer,0,bytesRead);
                }

                output.close();
                file.close();
                sk.close();

                JOptionPane.showMessageDialog(this, "Transfer complet");

            }
        }
        catch (Exception ex){
            /* Catch pentru eventuale erori */
            JOptionPane.showMessageDialog(this, ex.getMessage());
        }
    }
}

最佳答案

如果您想处理多个连接，那么您是正确的，您需要在单个线程中运行每个服务器请求。背后的理论是...

while (true)
    accept a connection ;
    create a thread to deal with the client ;
end while

或更多类似Java的代码：

while(true) {
     clientSocket = serverSocket.accept();
     YourWorkerThread thread = new YourWorkerThread(clientSocket);
     thread.start();
}

哪里...
YourWorkerThread是扩展Thread并实现服务器逻辑所在的方法run的类。

因此，查看您的服务器端代码，Socket sk = server.accept();之后的所有代码行都应进入扩展run的类的方法Thread中。