I tried so many times but i can't pass validation (the programm ran too long error)

Question about the task

Resolved

Someone can give me some advice or golden solution? I need this to past to next task.

It's time to write the main method of the Handler class, which will call all
the helper methods we wrote earlier. Implement the void run() method in the Handler class.

It must:
1) Display a message indicating that a new connection was established with a remote
address that can be obtained using the getRemoteSocketAddress() method.
2) Create a Connection object using the socket field.
3) Call the method that implements the handshake with the client, and store the name of the new client.
4) Send the name of the new participant (USER_ADDED message) to all chat participants.
Think about which method is most suitable for this.
5) Inform the new participant about the existing participants.
6) Start the server's main message-processing loop.
7) Be sure that the connection is closed if an exception occurs.
8) If any IOExceptions or ClassNotFoundExceptions occur, catch them and display a message indicating
that an error occurred while communicating with the remote address. 9) After handling any exceptions, if step 11.3 has finished and returned a name, we need to remove
from connectionMap the entry for that name and send a USER_REMOVED message containing the name to all other participants.
10) The last thing we need to do in the run() method is display a message
indicating that the connection with the remote address is closed.

Our server is completely ready. Try running it.

Requirements:

The run() method should display a message indicating that a connection has been established with the remote address (use the getRemoteSocketAddress() method).
The run() method should create a new connection using the socket field as an argument.
The run() method should call the serverHandshake() method using the newly created connection as an argument; the return value will be the username (userName).
The run() method should call the sendBroadcastMessage() method using a new message as an argument (MessageType.USER_ADDED, userName).
The run() method should call the notifyUsers() method using connection and userName as arguments.
The run() method should call the serverMainLoop() method using connection and userName as arguments.
Before completing, the run() method must remove from connectionMap the entry that corresponds to userName, and send a message to all chat participants that the current user has been removed.
The run() method should correctly handle IOExceptions and ClassNotFoundExceptions.

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 sendBroadcastMessage(Message message) { try { for (Connection c : connectionMap.values()) { c.send(message); } } catch (Exception e) { ConsoleHelper.writeMessage("Message couldn't be sent"); } } private static class Handler extends Thread { // zajmje sie tym, by byly wymieniane wiadomosci private Socket socket; public Handler(Socket socket) { this.socket = socket; } //tzw handszake, server meets the client, zwraca imie klienta private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException { while (true) { connection.send(new Message(MessageType.NAME_REQUEST)); Message response = connection.receive(); if (response.getType().equals(MessageType.USER_NAME)) { String data = response.getData(); if (data != null && !data.equals("")) { if (!(connectionMap.containsKey(data))) { connectionMap.put(data, connection); connection.send(new Message(MessageType.NAME_ACCEPTED)); return response.getData(); } } } } } private void notifyUsers(Connection connection, String userName) throws IOException { // wysylanie info klientowi o innych uczestnikach czatu 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) { try { Message recieved = connection.receive(); if (recieved.getType().equals(MessageType.TEXT)) { String m = userName + ": " + recieved.getData(); sendBroadcastMessage(new Message(MessageType.TEXT, m)); } else { ConsoleHelper.writeMessage("This is not a text..."); } } catch (Exception e) { e.getMessage(); } } } @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."); } } public static void main(String[] args) throws IOException { ConsoleHelper.writeMessage("Input server port: "); try (ServerSocket serverSocket = new ServerSocket(ConsoleHelper.readInt())) { while (true) { new Handler(serverSocket.accept()).start(); } } catch (IOException e) { ConsoleHelper.writeMessage("Something wrong, Server socket closed."); } } }

Comments (1)

Popular
New
Old

You must be signed in to leave a comment

Arnold Cytrowski

Level 29 , Breslau, Poland

20 May 2020, 06:24

solution

ok. only i need to do was remove try-catch block from serverMainLoop method. but why? i dont know