В упор не понимаю, почему не принимает 2 пункта, почему
Метод clientMainLoop() должен бросать исключение IOException, если тип принятого сообщения не MessageType.TEXT, MessageType.USER_REMOVED или не MessageType.USER_ADDED. У меня, вроде же бросает.
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<>();
public static void main(String args[]){
ServerSocket serverSocket=null;
try {
serverSocket= new ServerSocket(ConsoleHelper.readInt());
System.out.println("Server is running!");
while(true){
new Handler(serverSocket.accept()).start();
}
}catch (IOException e){
try {
serverSocket.close();
}catch (IOException a){
a.printStackTrace();
}
}
}
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 message for %s",name));
}
}
}
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));
Message answer = connection.receive();
if (answer.getType() != MessageType.USER_NAME) continue;
String userName=answer.getData();
if(userName==null||userName.isEmpty()||connectionMap.containsKey(userName)) continue;
connectionMap.put(userName,connection);
connection.send(new Message(MessageType.NAME_ACCEPTED));
return userName;
}
}
private void notifyUsers(Connection connection, String userName){
for(Map.Entry<String,Connection> a:connectionMap.entrySet()){
String name=a.getKey();
if(!name.equals(userName)) {
try {
connection.send(new Message(MessageType.USER_ADDED, name));
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
private void serverMainLoop(Connection connection, String userName) throws IOException, ClassNotFoundException{
while(true) {
Message answer = connection.receive();
if (answer.getType() == MessageType.TEXT) {
Message message = new Message(MessageType.TEXT, userName+": "+answer.getData());
sendBroadcastMessage(message);
} else ConsoleHelper.writeMessage("Error!");
}
}
public void run(){
ConsoleHelper.writeMessage(socket.getRemoteSocketAddress().toString());
String userName=null;
Connection connection=null;
try {
connection=new Connection(socket);
userName=serverHandshake(connection);
Message message=new Message(MessageType.USER_ADDED,userName);
sendBroadcastMessage(message);
notifyUsers(connection,userName);
serverMainLoop(connection,userName);
}catch (IOException e){
ConsoleHelper.writeMessage("Произошла ошибка при обмене данными с удаленным адресом");
}
catch (ClassNotFoundException f){
ConsoleHelper.writeMessage("Произошла ошибка при обмене данными с удаленным адресом");
}
finally {
try {
socket.close();
}catch (IOException a){
a.printStackTrace();
}
}
if(userName!=null){
connectionMap.remove(userName);
sendBroadcastMessage(new Message(MessageType.USER_REMOVED,userName));
}
ConsoleHelper.writeMessage("Connection is closed.");
}
}
}