не знаю что еще делать ... все коменты прочитал и все варианты попробывал
package com.javarush.task.task30.task3008;
import com.javarush.task.task30.task3008.client.Client;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class Server {
private static Map<String,Connection> connectionMap = new ConcurrentHashMap<>();
public static void sendBroadcastMessage(Message message) {
for (String name : connectionMap.keySet()) {
try {
connectionMap.get(name).send(message);
} catch (IOException e) {
ConsoleHelper.writeMessage(String.format("Can't send the message to %s", name));
}
}
}
public static void main(String[] args) {
//Запрашивать порт сервера, используя ConsoleHelper.
//Создавать серверный сокет java.net.ServerSocket, используя порт из предыдущего пункта.
//в) Выводить сообщение, что сервер запущен.
//г) В бесконечном цикле слушать и принимать входящие сокетные соединения только что созданного серверного сокета.
//д) Создавать и запускать новый поток Handler, передавая в конструктор сокет из предыдущего пункта.
//е) После создания потока обработчика Handler переходить на новый шаг цикла.
//ж) Предусмотреть закрытие серверного сокета в случае возникновения исключения.
//з) Если исключение Exception все же произошло, поймать его и вывести сообщение об ошибке.
try (ServerSocket serverSocket = new ServerSocket(ConsoleHelper.readInt())) {
System.out.println("Server has started");
while (true) {
Socket socket = serverSocket.accept();
Handler handler = new Handler(socket);
handler.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
private static class Handler extends Thread {
private Socket socket;
@Override
public void run() {
SocketAddress adress = socket.getRemoteSocketAddress();
ConsoleHelper.writeMessage("Connection established with address: "+adress);
try {
Connection connection = new Connection(socket);
String userName = serverHandshake(connection);
sendBroadcastMessage(new Message(MessageType.USER_ADDED,userName));
//5. Метод run() должен вызывать метод notifyUsers() используя в качестве параметров connection и userName.
notifyUsers(connection,userName);
//6. Метод run() должен вызывать метод serverMainLoop используя в качестве параметров connection и userName.
serverMainLoop(connection,userName);
//7. Прежде чем завершиться, метод run() должен удалять из connectionMap запись соответствующую userName,
// и отправлять всем участникам чата сообщение о том, что текущий пользователь был удален.
for (String name : connectionMap.keySet()
) {
if (name.equals(userName)) connectionMap.remove(name);
}
sendBroadcastMessage(new Message(MessageType.USER_REMOVED, userName));
} catch (IOException | ClassNotFoundException e) {
e.printStackTrace();
}
}
//Метод run() должен вызывать метод sendBroadcastMessage() используя в качестве параметра новое сообщение (MessageType.USER_ADDED, userName).
//5. Метод run() должен вызывать метод notifyUsers() используя в качестве параметров connection и userName.
//6. Метод run() должен вызывать метод serverMainLoop используя в качестве параметров connection и userName.
//7. Прежде чем завершиться, метод run() должен удалять из connectionMap запись соответствующую userName, и отправлять всем участникам чата сообщение о том, что текущий пользователь был удален.
//8. Метод run() должен корректно обрабатывать исключения IOException и ClassNotFoundException.
private void serverMainLoop(Connection connection, String userName) throws IOException, ClassNotFoundException {
while (true){
Message message = connection.receive();
String s;
if (message.getType() == (MessageType.TEXT)) {
s = userName +": "+ message.getData();
sendBroadcastMessage(new Message(MessageType.TEXT, s));
}else{
ConsoleHelper.writeMessage("Error!");
}
}
}
private void notifyUsers(Connection connection, String userName) throws IOException {
for (String name : connectionMap.keySet()
) {
Message message = new Message(MessageType.USER_ADDED,name);
if(!name.equals(userName)) connection.send(message);
}
}
private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException {
Message zapros = new Message(MessageType.NAME_REQUEST);
Message otvet = null;
String userName = null;
do
{
connection.send(zapros);
otvet = connection.receive();
userName = otvet.getData();
}
while((otvet.getType() != MessageType.USER_NAME)||userName.isEmpty()||connectionMap.containsKey(userName));
connectionMap.put(userName, connection);
connection.send(new Message(MessageType.NAME_ACCEPTED, "Ваше имя принято!"));
return userName;
}
public Handler(Socket socket) {
this.socket = socket;
}
}
}