Валидатор: В классе Client должно быть создано private volatile поле clientConnected типа boolean.
Я: ?! А в классе что?
package com.javarush.task.task30.task3008;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class Server {
private static Map<String, Connection> connectionMap = new ConcurrentHashMap<>();
private static class Handler extends Thread {
private Socket socket;
public Handler (Socket socket) {
this.socket = socket;
}
private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException {
while (true) {
connection.send(new Message(MessageType.NAME_REQUEST, "hello?"));
Message messageGet = connection.receive();
if (messageGet.getType() == MessageType.USER_NAME) {
String ttUserName = messageGet.getData();
if ((ttUserName != null) && !(ttUserName.isEmpty())) {
if (!(connectionMap.containsKey(ttUserName))) {
connection.send(new Message(MessageType.NAME_ACCEPTED));
connectionMap.put(ttUserName, connection);
return ttUserName;
}
}
}
}
}
private void notifyUsers(Connection connection, String userName) throws IOException {
for (String ttUserName : connectionMap.keySet()) {
if (!ttUserName.equals(userName)) {
connection.send(new Message(MessageType.USER_ADDED, ttUserName));
}
}
}
private void serverMainLoop(Connection connection, String userName) {
while (true) {
try {
Message message = connection.receive();
if (message.getType() == MessageType.TEXT) {
sendBroadcastMessage(new Message(MessageType.TEXT, userName + ": " + message.getData()));
} else {
ConsoleHelper.writeMessage("принятое сообщение не MessageType.TEXT");
}
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
}
public void run() {
ConsoleHelper.writeMessage(socket.getRemoteSocketAddress().toString());
String ttUser = null;
try {
Connection connection = new Connection(socket);
ttUser = serverHandshake(connection);
sendBroadcastMessage(new Message(MessageType.USER_ADDED, ttUser));
notifyUsers(connection, ttUser);
serverMainLoop(connection, ttUser);
if (connectionMap.containsKey(ttUser)) connectionMap.remove(ttUser);
sendBroadcastMessage(new Message(MessageType.USER_REMOVED, ttUser));
} catch (IOException e) {
ConsoleHelper.writeMessage(e.getMessage());
} catch (ClassNotFoundException e) {
ConsoleHelper.writeMessage(e.getMessage());
} catch (Exception e) {
ConsoleHelper.writeMessage(e.getMessage());
}
}
}
public static void main(String[] args) throws IOException {
try (ServerSocket serverSocket = new ServerSocket(ConsoleHelper.readInt())) {
System.out.println("Server has started");
while (true) {
new Handler(serverSocket.accept()).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void sendBroadcastMessage(Message message) {
for (String name : connectionMap.keySet()) {
try {
connectionMap.get(name).send(message);
} catch (IOException e) {
ConsoleHelper.writeMessage("Can't send the message to %s" + name);
}
}
}
}