Im confused, 3 requirements. (ClientGuiController)

Question about the task

Under discussion

I honestly don't know why it doesnt work. 'this' passed to ClientGuiView constructor is wrong? What about getModel method? And also getServerAddress, getServerPort and getUserName seems right to me.

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<>(); private static class Handler extends Thread { private Socket socket; public Handler(Socket socket) { this.socket = socket; } private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException { Message messageReceived = new Message(MessageType.TEXT); String userName = null; do { do { connection.send(new Message(MessageType.NAME_REQUEST)); messageReceived = connection.receive(); } while (messageReceived.getType() != MessageType.USER_NAME); userName = messageReceived.getData(); } while(userName.equals("") || connectionMap.containsKey(userName)); 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> 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 messageReceived = connection.receive(); if( messageReceived.getType() == MessageType.TEXT ) { Message m = new Message(MessageType.TEXT, userName + ": " + messageReceived.getData()); sendBroadcastMessage(m); } else { ConsoleHelper.writeMessage("Wrong message type."); } } } public void run() { ConsoleHelper.writeMessage("Connection established: " + socket.getRemoteSocketAddress()); String name=""; Connection connection = null; try { connection = new Connection(socket); name = serverHandshake(connection); sendBroadcastMessage(new Message(MessageType.USER_ADDED,name)); notifyUsers(connection,name); serverMainLoop(connection,name); connectionMap.remove(name); sendBroadcastMessage(new Message(MessageType.USER_REMOVED,name)); } catch (IOException e) { ConsoleHelper.writeMessage("Error occured while connecting with: " + socket.getRemoteSocketAddress()); if(!name.equals("")) { connectionMap.remove(name); sendBroadcastMessage(new Message(MessageType.USER_REMOVED, name)); } } catch (ClassNotFoundException e) { ConsoleHelper.writeMessage("Error occured while connecting with: " + socket.getRemoteSocketAddress()); if(!name.equals("")) { connectionMap.remove(name); sendBroadcastMessage(new Message(MessageType.USER_REMOVED, name)); } } ConsoleHelper.writeMessage("Connection with address has been closed: " + socket.getRemoteSocketAddress()); } } public static void sendBroadcastMessage(Message message) { for(Map.Entry<String, Connection> entry : connectionMap.entrySet()) { try { entry.getValue().send(message); } catch (IOException e) { System.out.println("Dear " + entry.getValue() + ", your message couldn't have been send:("); } } } public static void main(String[] args) throws IOException { int port = ConsoleHelper.readInt(); ServerSocket serverSocket=null; try { serverSocket = new ServerSocket(port); System.out.println("Server is running"); while(true) { Socket socket = serverSocket.accept(); Handler handler = new Handler(socket); handler.start(); continue; } } catch (IOException e) { e.printStackTrace(); } finally { serverSocket.close(); } } }

Comments (1)

Popular
New
Old

You must be signed in to leave a comment

Roman

Level 41

30 October 2019, 13:04

Your field names are incorrect! From the condition: 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.