What am I missing?

Question about the task

Chat (part 21)

Java Multithreading, Level 6, Lesson 15

Resolved

I have a little doubt that it is cause by this line:

ClientGuiView view = new ClientGuiView(this);

but not sure. I'm a missing something obvious?

I have great news for you. The view component is already done. I've added a ClientGuiView class. It uses the javax.swing library. You should really study every line of this class. If everything is clear, that's wonderful. If not, be sure to find answers to your questions using the debugger, documentation, or an Internet search.

We just need to write the controller component:
1) Create a ClientGuiController class that inherits Client.
2) Create and initialize a ClientGuiModel model field, which is responsible for the model.
3) Create and initialize a ClientGuiView view field, which is responsible for the view. Think about what you need to pass to the constructor when the object is initialized.
4) Add a GuiSocketThread inner class that inherits SocketThread. The GuiSocketThread class must be public. It overrides the following methods:
a) void processIncomingMessage(String message) - It should set a new message on the model and trigger an update on the view of the message.
b) void informAboutAddingNewUser(String userName) - It should add a new user to the model and trigger an update of the view of the users.
c) void informAboutDeletingNewUser(String userName) - It should remove a user from the model and trigger an update on the view of the users.
d) void notifyConnectionStatusChanged(boolean clientConnected) - It should call a similar method on the view.
5) Override the following methods in the ClientGuiController class:
a) SocketThread getSocketThread() - It should create and return a GuiSocketThread object.
b) void run() - It should get a SocketThread object via the getSocketThread() method and call its run() method. Figure out why we don't need to call the run() method on a separate thread, like we did for the console-based client.
c) getServerAddress(), getServerPort(), getUserName(). They should call the identically-named methods on the view.
6) Implement the ClientGuiModel getModel() method, which should return the model.
7) Implement the main() method, which should create a new ClientGuiController object and call its run() method.

Start a GUI-based client and several console-based clients, and make sure that everything works correctly.

Requirements:

The client package should correctly declare the ClientGuiController class and a nested GuiSocketThread class.
The ClientGuiController class must correctly declare and initialize the fields listed in the task conditions.
The processIncomingMessage() method must be implemented in the GuiSocketThread class in accordance with the task conditions.
The informAboutAddingNewUser() method must be implemented in the GuiSocketThread class in accordance with the task conditions.
The informAboutDeletingNewUser() method must be implemented in the GuiSocketThread class in accordance with the task conditions.
The notifyConnectionStatusChanged() method must be implemented in the GuiSocketThread class in accordance with the task conditions.
The ClientGuiController class's getSocketThread() method should return a new GuiSocketThread object.
The ClientGuiController class's run() method should get a SocketThread object via the getSocketThread() method and call its run() method.
The ClientGuiController class's getServerAddress(), getServerPort(), and getUserName() methods should call the appropriate methods on the view object.
The ClientGuiController class's getModel() method should return the model field.
The ClientGuiController class's main() method should create a new ClientGuiController object and call its run() method.
The ClientGuiController class must be a descendant of the Client class.

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<String, Connection>(); public static void main(String[] args){ ConsoleHelper.writeMessage("Server port:"); int serverPort = ConsoleHelper.readInt(); ServerSocket serverSocket = null; try { serverSocket = new ServerSocket(serverPort); ConsoleHelper.writeMessage("Server is running"); while(true){ Socket sSocket = serverSocket.accept(); Handler handler = new Handler(sSocket); handler.start(); } } catch(IOException e){ try { serverSocket.close(); } catch(IOException e2){ ConsoleHelper.writeMessage("IOException occur while closing!"); e2.printStackTrace(); } ConsoleHelper.writeMessage("IOException occur!"); e.printStackTrace(); } } private static class Handler extends Thread { private Socket socket; public Handler(Socket socket){ this.socket = socket; } public void run(){ Connection connection; try { ConsoleHelper.writeMessage("New connection was established with a remote address : " + socket.getRemoteSocketAddress()); connection = new Connection(socket); String userName = serverHandshake(connection); notifyUsers(connection,userName); sendBroadcastMessage(new Message(MessageType.USER_ADDED, userName)); serverMainLoop(connection, userName); connection.close(); sendBroadcastMessage(new Message(MessageType.USER_REMOVED, userName)); connectionMap.remove(userName); ConsoleHelper.writeMessage("Connection with the remote address is closed"); } catch(IOException e){ ConsoleHelper.writeMessage("An error occurred while communicating with the remote address."); }catch(ClassNotFoundException e){ ConsoleHelper.writeMessage("An error occurred while communicating with the remote address."); } } private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException { boolean isUserNameExist = false; while(true) { connection.send(new Message(MessageType.NAME_REQUEST)); Message response = connection.receive(); if(response.getType().equals(MessageType.USER_NAME)){ String userName = response.getData(); if( userName != null && userName != ""){ isUserNameExist = false; for (Map.Entry<String, Connection> x : connectionMap.entrySet()) { if(x.getKey().equals( userName)){ isUserNameExist = true; break; } } if(!isUserNameExist){ connectionMap.put(userName, connection); connection.send(new Message(MessageType.NAME_ACCEPTED)); return userName; } } } } } private void notifyUsers(Connection connection, String userName) throws IOException { for (Map.Entry<String, Connection> x : connectionMap.entrySet()) { if(! x.getKey().equals(userName)) connection.send(new Message(MessageType.USER_ADDED,x.getKey())); } } private void serverMainLoop(Connection connection, String userName) throws IOException, ClassNotFoundException{ while(true){ try { Message received = connection.receive(); if (received.getType().equals(MessageType.TEXT)) { String newMessage = userName + ": " + received.getData(); sendBroadcastMessage(new Message(MessageType.TEXT, newMessage)); } else { ConsoleHelper.writeMessage("not text error"); } } catch(Exception e){ ConsoleHelper.writeMessage(e.getMessage()); } } } } public static void sendBroadcastMessage(Message message) { for (Map.Entry<String, Connection> x : connectionMap.entrySet()) { try { x.getValue().send(message); } catch(IOException e){ e.printStackTrace(); } } } }

Comments (3)

Popular
New
Old

You must be signed in to leave a comment

Etienne Bélanger

Level 34 , Longueuil, Canada

14 April 2020, 17:35

solution

I found it! I forgot to put the proper access modifiers!

Henrique

Level 41 , São Paulo, Brazil

10 August 2020, 20:01

Which are "private final" in case someone is wondering.

Maria

Level 34 , Utrecht, Netherlands

6 November 2020, 14:21

just private :)