Как отправить ответ конкретному клиенту в Java?

Question

У меня есть сервер Java с несколькими подключениями клиентов. Если один клиент отправляет сообщение на сервер v, сервер передает сообщение всем клиентам. Что я должен изменить в коде, чтобы он отвечал только клиенту, отправившему сообщение?

Настоящий код:

EchoServer.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class EchoServer
{
public static void main(String[] args) throws IOException
{
    EchoServer server = new EchoServer();
    server.start();
}

private ArrayList<PrintWriter> writers = new ArrayList<>();

public void start() {
    ServerSocket serverSocket = null;

    try
    {
        serverSocket = new ServerSocket(5000);

        while (true) {
            Socket clientSocket = serverSocket.accept();

            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
            writers.add(out);
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

            Thread t = new ClientHandler(in, this);
            t.start();
        }
    }
    catch (IOException e)
    {
        System.out.println("Exception caught when trying to listen on port 5000 or listening for a connection");
        System.out.println(e.getMessage());
    }
    finally
    {
        try {
            serverSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public synchronized void broadcast(String inputLine) {
    for (PrintWriter writer : writers) {
        writer.println(inputLine);
    }
}
}

EchoClient.java

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

public class EchoClient
{
public static void main(String[] args) throws IOException
{
    String hostName = "localhost";
    int portNumber = 5000;
    Socket echoSocket = null;

    try
    {
        echoSocket = new Socket(hostName, portNumber);
        PrintWriter out = new PrintWriter(echoSocket.getOutputStream(), true);

        BufferedReader in = new BufferedReader(new InputStreamReader(echoSocket.getInputStream()));
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));

        Thread t = new ServerHandler(in);
        t.start();

        String userInput;
        while ((userInput = stdIn.readLine()) != null)
        {
            out.println(userInput);
        }
    }
    catch (UnknownHostException e)
    {
        System.err.println("Don't know about host " + hostName);
        System.exit(1);
    }
    catch (IOException e)
    {
        System.err.println("Couldn't get I/O for the connection to " + hostName);
        System.exit(1);
    }
    finally
    {
        echoSocket.close();
    }
}
}

ServerHandler

import java.io.BufferedReader;
import java.io.IOException;

public class ServerHandler extends Thread {
private BufferedReader reader;

public ServerHandler(BufferedReader reader) {
    super();
    this.reader = reader;
}

@Override
public void run() {
    String readLine;
    try {
        while((readLine = reader.readLine()) != null) {
            System.out.println(readLine);
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}
}

ClientHandler

import java.io.BufferedReader;
import java.io.IOException;

public class ClientHandler extends Thread {
private BufferedReader reader;

private EchoServer server;

public ClientHandler(BufferedReader reader, EchoServer server) 
{
    this.reader = reader;
    this.server = server;
}

@Override
public void run() {
    while (true) {
        String inputLine;
        try {
            while ((inputLine = reader.readLine()) != null)
            {
                server.broadcast(inputLine);
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}
}

Answer 1

В настоящее время, когда вы получаете сообщение от клиента, ваш ClientHandler вызывает метод широковещания сервера.Вот как я бы отозвался только к одному клиенту.

1) Передайте clientSocket в ClientHandler.Таким образом, приведенный ниже код заменит код в EchoServer.

    Thread t = new ClientHandler(in, clientSocket, this);
    t.start();

Тогда у вашего обработчика клиента будет сокет, который он тоже сможет отписать.

import java.io.BufferedReader;
import java.io.IOException;
import java.net.Socket;

public class ClientHandler extends Thread {
private BufferedReader reader;
private Socket clientSocket;
private EchoServer server;

public ClientHandler(BufferedReader reader, Socket clientSocket EchoServer server) 
{
    this.reader = reader;
    this.server = server;
    this.clientSocket = clientSocket;
}

@Override
public void run() {
    while (true) {
        String inputLine;
        try {
            while ((inputLine = reader.readLine()) != null)
            {
                PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
                out.println(inputLine);
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}
}