Can't get a < break; >

Question about the task

Resolved

Take a look at the bottom of the Client class. I've tried both switch block and if-else block and the results are the same. I'm wracking my brain to think of why the exception wouldn't be thrown correctly. I tried putting the exception test just after receive(), but it REALLY didn't like that. Also why does it think the clientMainLoop() won't continue?

Now everything is ready for us to add the necessary methods to the SocketThread class.

1) Add a protected clientHandshake() throws IOException, ClassNotFoundException method. This method will represent the client to the server.
It must:
a) In a loop, use the connection field to receive messages.
b) If a received message is a NAME_REQUEST (the server has requested a name), use the getUserName method to ask the user to enter a username, create a new message that is a MessageType.USER_NAME and contains the entered name, and send the message to the server.
c) If a received message is a MessageType.NAME_ACCEPTED (the server has accepted the name), it means the server has accepted the client name, and you need to inform the main thread, which is eagerly waiting for this news. Do this by passing true to the notifyConnectionStatusChanged() method. Then exit the method.
d) If there is a message of any other type, throw an IOException("Unexpected MessageType").

2) Add a protected void clientMainLoop() throws IOException, ClassNotFoundException method. This method will implement the server's main message-processing loop. Inside the method:
a) Use the connection field to receive a message from the server.
b) If it is a text message (MessageType.TEXT), process it using the processIncomingMessage() method.
c) If the message is a MessageType.USER_ADDED, process it using the informAboutAddingNewUser() method.
d) If the message is a MessageType.USER_REMOVED, process it using the informAboutDeletingNewUser() method.
e) If the client receives a message of some other type, throw an IOException("Unexpected MessageType").
f) Put the code from the previous steps in an infinite loop. The loop will terminate automatically if an error (exception) occurs or the thread on which the loop is running is interrupted.

Requirements:

The clientHandshake() method should use the connection field to send a new message (MessageType.USER_NAME, getUserName()) if the received message is a MessageType.NAME_REQUEST.
The clientHandshake() method should call notifyConnectionStatusChanged(true) and terminate if the received message is a MessageType.NAME_ACCEPTED.
The clientHandshake() method should throw an IOException if the received message is not a MessageType.NAME_ACCEPTED or a MessageType.NAME_REQUEST.
The clientHandshake() method should receive messages from the server as long as the message type is MessageType.NAME_REQUEST.
The clientMainLoop() method should receive messages from the server as long as the message type is MessageType.TEXT, MessageType.USER_REMOVED, or MessageType.USER_ADDED.
The clientMainLoop() method must process the received message using the processIncomingMessage() method if the received message is a MessageType.TEXT.
The clientMainLoop() method must process the received messages using the informAboutAddingNewUser() method if the received message is a MessageType.USER_ADDED.
The clientMainLoop() method must process the received messages using the informAboutDeletingNewUser() method if the received message is a MessageType.USER_REMOVED.
The clientMainLoop() method should throw an IOException if the received message is not a MessageType.TEXT, MessageType.USER_REMOVED, or MessageType.USER_ADDED.

package com.codegym.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) { try (ServerSocket serverSocket = new ServerSocket(ConsoleHelper.readInt())) { ConsoleHelper.writeMessage("Server is running"); while (true) { try (Socket socket = serverSocket.accept()) { new Handler(socket).start(); } catch (Exception e) { System.out.println(e.getMessage()); } } } catch (Exception e) { e.getMessage(); } } public static void sendBroadcastMessage (Message message) { try { for (Map.Entry<String, Connection> entry : connectionMap.entrySet()) { Connection connection = entry.getValue(); connection.send(message); } } catch (IOException e) { ConsoleHelper.writeMessage("Message couldn't be sent."); } } private static class Handler extends Thread { private Socket socket; public Handler (Socket socket) { this.socket = socket; } @Override public void run() { String userName = null; ConsoleHelper.writeMessage("A connection has been established with " + socket.getRemoteSocketAddress()); try (Connection connection = new Connection(socket)) { userName = serverHandshake(connection); sendBroadcastMessage(new Message(MessageType.USER_ADDED, userName)); notifyUsers(connection, userName); serverMainLoop(connection, userName); } catch (Exception e) { ConsoleHelper.writeMessage("An error occurred while communicating with the remote address."); } finally { if (userName != null) connectionMap.remove(userName); sendBroadcastMessage(new Message(MessageType.USER_REMOVED, userName)); } ConsoleHelper.writeMessage("Connection with " + socket.getRemoteSocketAddress() + " closed."); } private String serverHandshake (Connection connection) throws IOException, ClassNotFoundException { Message nameRequest = new Message(MessageType.NAME_REQUEST); Message response; connection.send(nameRequest); while(true) { response = connection.receive(); if(response.getType() != MessageType.USER_NAME || response.getData().isEmpty() || response == null || connectionMap.containsKey(response.getData())) { connection.send(nameRequest); continue; } connectionMap.put(response.getData(),connection); connection.send(new Message (MessageType.NAME_ACCEPTED)); return response.getData(); } // Message nameRequest = new Message(MessageType.NAME_REQUEST); // Message response; // // do { // connection.send(nameRequest); // response = connection.receive(); // } while (response == null || // response.getType() != MessageType.USER_NAME || // response.getData() == null || // response.getData().isEmpty() || // connectionMap.containsKey(response.getData())); // // connectionMap.put(response.getData(), connection); // connection.send(new Message (MessageType.NAME_ACCEPTED)); // // return response.getData(); } private void notifyUsers (Connection connection, String userName) throws IOException { for (Map.Entry<String, Connection> entry : connectionMap.entrySet()) { if (!entry.getKey().equals(userName)) { connection.send(new Message(MessageType.USER_ADDED, entry.getKey())); } } } private void serverMainLoop (Connection connection, String userName) throws IOException, ClassNotFoundException { while (true) { Message received = connection.receive(); if (received.getType() == MessageType.TEXT) { sendBroadcastMessage(new Message (received.getType(), userName + ": " + received.getData())); } else { ConsoleHelper.writeMessage("Error. Message type is not \"TEXT\"."); } } } } }