java服务器多线程一次只应答一个客户机

3 月，2 周 Questions & Answers 205

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

服务器一次只能应答一个客户端。如果第一个客户端还没有收到服务器的响应，我就无法从第二个客户端发送任何内容

这是我的服务器的代码：

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é");在从客户机收到每条消息后执行。通常，只有当新客户机到来时，才应该执行它

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

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中的两个不同项目中

Python中文网

有 Java 编程相关的问题?

java服务器多线程一次只应答一个客户机

共 (1) 个答案

# 1 楼答案