java - 多线程客户端/服务器应用程序java问题

Question

这是我的第一篇文章，如果我做错了什么请指正。

我正在尝试制作一个多线程客户端/服务器应用程序。我在没有线程的情况下制作基本的 1 对 1 客户端/服务器应用程序没有问题，但我希望每个客户端单独与服务器对话，每个客户端只接收属于控制台中特定客户端的消息。这是我无法使其工作的地方。

我在网上看了一些教程，并尝试在 Eclipse 中进行调试，但没有任何运气。我希望应用程序做什么:

如果我运行服务器和 2 个客户端，我希望能够在客户端上写入一条消息，并让服务器返回消息和消息编号，而不会跳过数字。

客户 1:

留言号:0。你说:你好!

消息编号:1.你说:Whats up!

客户 2:

消息编号:0。你说:嘿服务器!

留言序号:1.你说:你现在在做什么？

它与我运行的第一个客户端一起工作并完美地增加了消息编号，但是当我创建第二个客户端时它卡住了，所以我想我的问题要么与套接字声明有关，要么与我的线程处理方式有关。 (也许某处缺少 socket.close()？)

我知道该应用程序还有其他一些缺陷，但请记住，这只是使用线程的学校作业。

如果有人愿意提供帮助，请提前致谢。 :)

服务器代码:

public class Server extends Thread 
{   
  DataInputStream in;
  DataOutputStream out;
  ServerSocket listener;

public Server() throws IOException
{      
    try 
    {
        while (true) 
        {
            listener = new ServerSocket(9090);
            Socket socket = listener.accept(); 
            System.out.println("Test");
            ThreadServer ts = new ThreadServer(socket);
            Thread t1 = new Thread(ts);
            t1.start();   
        }
    }
    finally 
    {
        listener.close();
    }   
}

public static void main(String[] args) throws IOException 
{
    new Server();
}
}

客户端代码:

public class Client extends JFrame 
 {      
   DataOutputStream dos;
   BufferedReader input;
   String answer = null;
   String textString;
   Socket s = new Socket("localhost", 9090);

public Client() throws IOException
{
    JButton btn = new JButton("run");
    final JTextField txf = new JTextField(10);
    btn.addActionListener(new ActionListener() {
        public void actionPerformed(ActionEvent arg0) {             
            try 
            {   
                dos = new DataOutputStream(s.getOutputStream());
                textString = txf.getText();
                dos.writeUTF(textString);
                dos.flush();        
                input = new BufferedReader(new InputStreamReader(s.getInputStream()));
                answer = input.readLine();                      
            } 
            catch (Exception e1) 
            {
                e1.printStackTrace();
            }           
                System.out.println(answer); 
            }       
    });
    setLayout(new GridLayout(2,2));
    add(btn);
    add(txf);
    setVisible(true);
    pack();
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

}

public static void main(String[] args) throws IOException 
{
    new Client();
}
}

线程服务器代码:

public class ThreadServer implements Runnable
{
  DataInputStream in;
  DataOutputStream out;

public ThreadServer (Socket socket) throws IOException
{       
    int i = 0;  

    try 
    {
        while (true) 
        {            
            in = new DataInputStream(socket.getInputStream());
            out = new DataOutputStream(socket.getOutputStream());

            try 
            {
                String message = in.readUTF();          
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
                out.println("Message no: " + i + ". You said: " + message);                  
                out.println("Message no: " + i);
            }
            catch(Exception e) 
            {
                e.printStackTrace();
            }
            i++;
        }
    }
    finally 
    {
        socket.close();
    }
}

@Override
public void run() {
    // TODO Auto-generated method stub

}
  }

Answer 1

让我尝试解决它。​​

• 只创建一个ServerSocket。从 while 循环移到下一行。将它放在 while 循环之前。

  listener = new ServerSocket(9090);
  

• 将 ThreadServer 的构造函数的代码移至 run() 方法，因为它实现了 Runnable 但行为不像一个 Runnable 类。

  public ThreadServer(Socket socket) throws IOException {
      this.socket=socket;
  }
  
  @Override
  public void run() {
     ...
     //code from constructor
  }
  

• 在服务器类中，您向客户端写入两行，但客户端只读取一行。删除多余的行，如下所示

  out.println("Message no: " + i + ". You said: " + message);
  //out.println("Message no: " + i);
  

---

最后一个建议:

在调用 readUTF() 之前始终检查输入，如下所示:

if (in.available() > 0) {
    try {
        String message = in.readUTF();
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        out.println("Message no: " + i + ". You said: " + message);
        //out.println("Message no: " + i);
    } catch (Exception e) {
        e.printStackTrace();
    }
    i++;
}