Is this broken

Question about the task

Chat (part 14)

Java Multithreading, Level 6, Lesson 15

Resolved

Have no idea what is going on.

Let's start writing the main functionality of the Client class.

1) Add a public void run() method. It should create a helper SocketThread, wait until it establishes a connection with the server, and then in a loop, read messages from the console and send them to the server. The loop will terminate either when the client shuts down or the user enters the 'exit' command'.
To inform the main thread that the connection is established on the helper thread, use the Client object's wait() and notify() methods.

The implementation should:
a) Create a new socket thread using the getSocketThread() method.
b) Mark the created thread as a daemon. This is necessary so that the helper thread is automatically interrupted when the program exits.
c) Start the helper thread.
d) Make the current thread wait until it receives a notification from another thread.
Hint: use wait() and object level synchronization. If an exception occurs while waiting, notify the user and exit the program.
d) Once the thread receives a notification, check the value of clientConnected. If it is true, display "Connection established. To exit, enter 'exit'.". If it is false, display "An error occurred while working with the client.".
e) Read messages from the console until the client is connected. If 'exit' is entered, then exit the loop.
g) After each string is read, if the shouldSendTextFromConsole() method returns true, send the text using the sendTextMessage() method.

2) Add the public static void main(String[] args) method. It must create a new Client object and call its run() method.

Requirements:

The main() method should create a new Client object and call its run() method.
The run() method should create and start a new thread that is obtained using the getSocketThread() method.
The thread created using the getSocketThread() method should be marked as a daemon (setDaemon(true)).
After starting the new socketThread, the run() method should wait until it is awakened.
As long as the clientConnected flag is true, messages should be read from the console using the ConsoleHelper.readString() method.
If the "exit" command is entered, you should interrupt the message-reading loop.
If the shouldSentTextFromConsole() method returns true, the sendTextMessage() method should be called with the input text used as an argument.

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[]) throws Exception { ServerSocket temp = null; temp = new ServerSocket(ConsoleHelper.readInt()); System.out.println("server is running"); try { while (true) { Socket newSocket = temp.accept(); Handler newConnection = new Handler(newSocket); newConnection.start(); continue; } } catch (Exception e) { } System.out.println("Server not implemented"); temp.close(); } public static void sendBroadcastMessage(Message message) { for (Connection x : connectionMap.values()) { try { x.send(message); } catch (Exception e) { e.printStackTrace(); } } } private static class Handler extends Thread { private Socket socket; public void run() { String userName = null; Connection myConnect = null; for (int i = 0; i < 1; i++) { try { System.out.println("Connection established: " + socket.getRemoteSocketAddress()); myConnect = new Connection(socket); } catch (Exception ig) { break; } try { userName = serverHandshake(myConnect); } catch (Exception ig) { try { myConnect.close(); } catch (IOException e) { e.printStackTrace(); } break; } try { sendBroadcastMessage(new Message(MessageType.USER_ADDED, userName)); notifyUsers(myConnect, userName); serverMainLoop(myConnect, userName); } catch (Exception e) { } finally { connectionMap.remove(userName); sendBroadcastMessage(new Message(MessageType.USER_REMOVED, userName)); try { myConnect.close(); } catch (IOException e1) { e1.printStackTrace(); } } } System.out.println("Connection closed: "+socket.getRemoteSocketAddress()); } public Handler(Socket socket) { this.socket = socket; } private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException{ Message response = null; connection.send(new Message(MessageType.NAME_REQUEST)); while(true) { response = connection.receive(); if(response.getType() != MessageType.USER_NAME){ connection.send(new Message(MessageType.NAME_REQUEST)); continue; } String data = response.getData(); if(data.length() == 0 || response == null){ connection.send(new Message(MessageType.NAME_REQUEST)); continue; } if(connectionMap.containsKey(data)){ connection.send(new Message(MessageType.NAME_REQUEST)); continue; } 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> user : connectionMap.entrySet()){ if(userName.equals(user.getKey())) continue; connection.send(new Message(MessageType.USER_ADDED, user.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(MessageType.TEXT, String.format("%s: %s", userName, received.getData()))); else ConsoleHelper.writeMessage("Error, text not available"); } } } }

Comments (28)

Popular
New
Old

You must be signed in to leave a comment