服务器多线程一次只能应答一个客户端

Question

我想创建一个同时与多个客户端通信的多线程服务器。这是问题所在：

• 服务器一次只能应答一个客户端。如果第一个客户端尚未获得服务器的响应，则无法从第二个客户端发送任何内容。

这是我服务器的代码：

import java.io.*;
import java.net.*;

public class Serveur extends Thread{

    private MyFrame mf;
    @SuppressWarnings("unused")
    private FileAttente file;
    private ServerSocket serveur ;

    public Serveur(int port,MyFrame f,FileAttente file) throws IOException{
         serveur = new ServerSocket(port);
         this.mf = f;
         this.file=file;
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        mf.console.append("nServeur en écoute ... ");
        while(true){
            try { 
                SoClient threadClient = new SoClient(this.serveur.accept());
                threadClient.start();
                mf.console.append("nUn nouveau client s'est connecté");
            } catch (IOException e) {e.printStackTrace();}

        }
        }



}

我也有这一行：mf.console.append("nUn nouveau client s'est connecté");从客户端收到每条消息后执行。通常，它应该只在新客户端到来时执行。

这是我在客户端和服务器之间放置所有操作的套接字的代码：

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class SoClient extends Thread {
        static MyFrame mf;
        FileAttente file;
        public static Socket client;
        public SoClient(Socket client){
            this.client=client;
        }

        public void run(){
            MyFrame.console.append("nConnexion établi : "+client.getInetAddress());
            //Envoie et reception
            try {
                InputStream in = this.client.getInputStream();
                OutputStream out = client.getOutputStream();
                sleep(2);
                DataInputStream is = new DataInputStream(in);
                @SuppressWarnings("deprecation")
                String request = is.readLine();
                MyFrame.console.append("nMessage d'un Client :"+request);  
                DataInputStream din = new DataInputStream(in);
                sleep(2);
                String chaine_Client=din.readUTF();
                MyFrame.console.append("Client :"+chaine_Client);
                client.close();
            }   catch (IOException | InterruptedException e) {}
        }


    }

所以，我想做的是从服务器向所有连接的客户端发送广播消息，或者发送回显消息。对于客户端，我创建了一个类，并根据需要实例化它。客户端类和服务器类位于 Eclipse 中的两个不同项目中。

Answer 1

您已将 SoClient 中的类变量客户端定义为静态：

public static Socket client;

并在构造函数中设置它。

如果您有多个 SoClient 实例，它们都在同一个客户端套接字上工作。
这可能会导致更奇怪的错误。

删除静态关键字，希望它有效。