JavaRush/Помощь по Java задачам/Не пойму почему не запускается бот. Прошу подсказки.

28 уровень

22.09.2019
600просмотров
17комментариев

Не пойму почему не запускается бот. Прошу подсказки.

Вопрос по задаче

Java Multithreading, 6 уровень, 15 лекция

Решен

Добрый день! Не пойму почему не запускается бот 1. Запускаю Server. Ввожу номер порта. 2. Запускаю ClientGuiController. Ввожу localhost и номер порта из п.1, ввожу имя пользователя. Чат запущен и работает. Вижу введенное имя и могу написать сообщение. Но вот тут загвоздка 3. Запускаю консольного клиента Client. 4. Запускаю бота BotClient. В GUI версии чата отображается только имя пользователя из п.2

public class BotClient extends Client {

    @Override
    protected String getUserName() {
        int random = (int) (Math.random() * 100);
        String botName = "date_bot_" + random;
        return botName;
    }

    @Override
    protected boolean shouldSendTextFromConsole() {
        return false;
    }

    @Override
    protected SocketThread getSocketThread() {
        return new BotSocketThread();
    }

    public class BotSocketThread extends SocketThread {
        @Override
        protected void clientMainLoop() throws IOException, ClassNotFoundException {
            sendTextMessage( "Привет чатику. Я бот. Понимаю команды: дата, день, месяц, год, время, час, минуты, секунды." );
            super.clientMainLoop();
        }

        @Override
        protected void processIncomingMessage(String message) {
            ConsoleHelper.writeMessage( message );

            if (message.contains( ":" )) {
                String[] msg = message.split( ": " );

                SimpleDateFormat dateFormat;
                switch (msg[1]) {
                    case "дата":
                        dateFormat = new SimpleDateFormat( "d.MM.YYYY" );
                        break;
                    case "день":
                        dateFormat = new SimpleDateFormat( "d" );
                        break;
                    case "месяц":
                        dateFormat = new SimpleDateFormat( "MMMM" );
                        break;
                    case "год":
                        dateFormat = new SimpleDateFormat( "YYYY" );
                        break;
                    case "время":
                        dateFormat = new SimpleDateFormat( "H:mm:ss" );
                        break;
                    case "час":
                        dateFormat = new SimpleDateFormat( "H" );
                        break;
                    case "минуты":
                        dateFormat = new SimpleDateFormat( "m" );
                        break;
                    case "секунды":
                        dateFormat = new SimpleDateFormat( "s" );
                        break;
                    default:
                        dateFormat = null;
                        break;
                }

                if (dateFormat != null) {
                    Calendar calendar = Calendar.getInstance();
                    Date currentDate = calendar.getTime();
                    String result = "Информация для " + msg[0] + ": ";
                    result += dateFormat.format( currentDate );
                    sendTextMessage( result );
                }
            }
        }
    }

    public static void main(String[] args) {
        BotClient botClient = new BotClient();
        botClient.run();
    }
}

Комментарии (17)

популярные
новые
старые

Для того, чтобы оставить комментарий Вы должны авторизоваться

Roman K

Уровень 31

23 сентября 2019, 04:55

нужен полный код проекта, с тем, что вы скинули, все в порядке

Анатолий

Уровень 28

23 сентября 2019, 09:40

Частями только получится выложить 😬 class Client

public class Client {
    protected Connection connection;
    private volatile boolean clientConnected;

    protected String getServerAddress() {
        String serverAddress = ConsoleHelper.readString();
        return serverAddress;
    }

    protected int getServerPort() {
        int serverPort = ConsoleHelper.readInt();
        return serverPort;
    }

    protected String getUserName() {
        String userName = ConsoleHelper.readString();
        return userName;
    }

    protected boolean shouldSendTextFromConsole() {
        return true;
    }

    protected SocketThread getSocketThread() {
        return new SocketThread();
    }

    protected void sendTextMessage(String text) {
        try {
            connection.send( new Message( MessageType.TEXT, text ) );
        } catch (IOException e) {
            clientConnected = false;
            e.printStackTrace();
        }
    }

    public void run() {
        SocketThread socketThread = getSocketThread();
        socketThread.setDaemon( true );
        socketThread.start();
        try {
            synchronized (this) {
                this.wait();
            }
        } catch (InterruptedException e) {
            System.out.println( "Произошла ошибка." );
            e.printStackTrace();
        }
        if (clientConnected == true) {
            System.out.println( "Соединение установлено.\nДля выхода наберите команду 'exit'." );
        } else System.out.println( "Произошла ошибка во время работы клиента." );

        while (clientConnected == true) {
            String textFromConsole = ConsoleHelper.readString();

            if (textFromConsole.equals( "exit" )) {
                break;
            } else if (shouldSendTextFromConsole() == true) {
                sendTextMessage( textFromConsole );
            }
        }
    }

Анатолий

Уровень 28

23 сентября 2019, 09:41

продолжение class Client - вложенный class SocketThread

public class SocketThread extends Thread {

       protected void processIncomingMessage(String message) {
           ConsoleHelper.writeMessage( message );
       }

       protected void informAboutAddingNewUser(String userName) {
           ConsoleHelper.writeMessage( userName + " подключился к чату." );
       }

       protected void informAboutDeletingNewUser(String userName) {
           ConsoleHelper.writeMessage( userName + " покинул чат." );
       }

       protected void notifyConnectionStatusChanged(boolean clientConnected) {
           Client.this.clientConnected = clientConnected;
           synchronized (Client.this) {
               Client.this.notify();
           }
       }

       protected void clientHandshake() throws IOException, ClassNotFoundException {
           while (true) {
               Message msg = connection.receive();
               if (msg.getType() == MessageType.NAME_REQUEST) {
                   Message message = new Message( MessageType.USER_NAME, getUserName() );
                   connection.send( message );
               } else if (msg.getType() == MessageType.NAME_ACCEPTED) {
                   notifyConnectionStatusChanged( true );
                   break;
               } else throw new IOException( "Unexpected MessageType" );
           }
       }

Анатолий

Уровень 28

23 сентября 2019, 09:41

продолжение class Client

protected void clientMainLoop() throws IOException, ClassNotFoundException {
            while (true) {
                Message msg = connection.receive();
                if (msg.getType() == MessageType.TEXT) {
                    processIncomingMessage( msg.getData() );
                } else if (msg.getType() == MessageType.USER_ADDED) {
                    informAboutAddingNewUser( msg.getData() );
                } else if (msg.getType() == MessageType.USER_REMOVED) {
                    informAboutDeletingNewUser( msg.getData() );
                } else throw new IOException( "Unexpected MessageType" );
            }
        }

        @Override
        public void run() {
            try {
                String serverAddress = getServerAddress();
                int serverPort = getServerPort();
                Socket socket = new Socket( serverAddress, serverPort );
                connection = new Connection( socket );
                clientHandshake();
                clientMainLoop();
            } catch (IOException e) {
                notifyConnectionStatusChanged( false );
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
                notifyConnectionStatusChanged( false );
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        Client client = new Client();
        client.run();
    }
}

Анатолий

Уровень 28

23 сентября 2019, 09:43

class ClientGuiController

public class ClientGuiController extends Client {
    private ClientGuiModel model = new ClientGuiModel();
    private ClientGuiView view = new ClientGuiView( this );

    @Override
    protected String getServerAddress() {
        return view.getServerAddress();
    }

    @Override
    protected int getServerPort() {
        return view.getServerPort();
    }

    @Override
    protected String getUserName() {
        return view.getUserName();
    }

    @Override
    protected SocketThread getSocketThread() {
        return new GuiSocketThread();
    }

    @Override
    public void run() {
        SocketThread socketThread = getSocketThread();
        socketThread.run();
    }

    public ClientGuiModel getModel() {
        return model;
    }


    public class GuiSocketThread extends SocketThread {
        @Override
        protected void processIncomingMessage(String message) {
            model.setNewMessage( message );
            view.refreshMessages();
        }

        @Override
        protected void informAboutAddingNewUser(String userName) {
            model.addUser( userName );
            view.refreshUsers();
        }

        @Override
        protected void informAboutDeletingNewUser(String userName) {
            model.deleteUser( userName );
            view.refreshUsers();
        }

        @Override
        protected void notifyConnectionStatusChanged(boolean clientConnected) {
            super.notifyConnectionStatusChanged( clientConnected );
            view.notifyConnectionStatusChanged( clientConnected );
        }
    }

    public static void main(String[] args) {
        ClientGuiController clientGuiController = new ClientGuiController(  );
        clientGuiController.run();
    }
}

Анатолий

Уровень 28

23 сентября 2019, 09:46

class ClientGuiModel

public class ClientGuiModel {
    private final Set<String> allUserNames = new HashSet<>();
    private String newMessage;

    public Set<String> getAllUserNames() {
        return Collections.unmodifiableSet( allUserNames );
    }

    public String getNewMessage() {
        return newMessage;
    }

    public void setNewMessage(String newMessage) {
        this.newMessage = newMessage;
    }

    public void addUser(String newUserName){
        allUserNames.add( newUserName );
    }
    public void deleteUser(String userName){
        allUserNames.remove( userName );
    }
}

Анатолий

Уровень 28

23 сентября 2019, 09:49

В public class ClientGuiView я ничего не изменял, он написан JavaRush. Я его не стал тут вставлять, но если нужно могу вставить его код тоже

Анатолий

Уровень 28

23 сентября 2019, 09:50

public class Connection

public class Connection implements Closeable {
    private final Socket socket;
    private final ObjectOutputStream out;
    private final ObjectInputStream in;

    public Connection(Socket socket) throws IOException {
        this.socket = socket;
        this.out = new ObjectOutputStream( socket.getOutputStream() );
        this.in = new ObjectInputStream( socket.getInputStream() );
    }

    public void send(Message message) throws IOException {
        synchronized (out) {
            out.writeObject( message );
        }
    }

    public Message receive() throws IOException, ClassNotFoundException {
        synchronized (in) {
            Message message = (Message) in.readObject();
            return message;
        }
    }

    public SocketAddress getRemoteSocketAddress() {
        return socket.getRemoteSocketAddress();
    }

    public void close() throws IOException {
        out.close();
        in.close();
        socket.close();
    }
}

Анатолий

Уровень 28

23 сентября 2019, 09:51

public class ConsoleHelper

public class ConsoleHelper {
    private static BufferedReader bufferedReader = new BufferedReader( new InputStreamReader( System.in ) );


    public static void writeMessage(String message) {
        System.out.println( message );

    }

    public static String readString() {
        String text = "";
        while (bufferedReader != null) {
            try {
                text = bufferedReader.readLine();
                break;
            } catch (IOException e) {
                System.out.println( "Произошла ошибка при попытке ввода текста. Попробуйте еще раз." );
                continue;
            }
        }
        return text;
    }

    public static int readInt() {
        try {
            return Integer.parseInt( readString() );
        } catch (NumberFormatException e) {
            System.out.println( "Произошла ошибка при попытке ввода числа. Попробуйте еще раз." );
            return readInt();
        }
    }
}

Анатолий

Уровень 28

23 сентября 2019, 09:51

public class Message

public class Message implements Serializable {
    private final MessageType type;
    private final String data;

    public Message(MessageType type) {
        this.type = type;
        this.data = null;
    }

    public Message(MessageType type, String data) {
        this.type = type;
        this.data = data;
    }

    public MessageType getType() {
        return type;
    }

    public String getData() {
        return data;
    }
}

Анатолий

Уровень 28

23 сентября 2019, 09:51

public enum MessageType {
    NAME_REQUEST,
    USER_NAME,
    NAME_ACCEPTED,
    TEXT,
    USER_ADDED,
    USER_REMOVED
}

Анатолий

Уровень 28

23 сентября 2019, 09:52

public class Server

public class Server {
    private static Map<String, Connection> connectionMap = new ConcurrentHashMap<>();

    public static void sendBroadcastMessage(Message message) {
        try {
            for (String key : connectionMap.keySet()) {
                connectionMap.get( key ).send( message );
            }
        } catch (IOException e) {
            System.out.println( "Сообщение не доставлено." );
        }
    }

    public static void main(String[] args) throws IOException {

        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket( ConsoleHelper.readInt() );
        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println( "Сервер запущен." );

        try {
            while (true) {
                Socket socket = serverSocket.accept();
                Handler handler = new Handler( socket );
                handler.start();

            }
        } catch (IOException e) {
            System.out.println( "Произошла ошибка." );
            serverSocket.close();
        }
    }

    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 sendNameRequest = new Message( MessageType.NAME_REQUEST );
            connection.send( sendNameRequest );
            Message received = connection.receive();

Анатолий

Уровень 28

23 сентября 2019, 09:53

продолжение public class Server

if (received.getType() == MessageType.USER_NAME
             && received.getData() != null && !received.getData().equals( "" )
             && !connectionMap.containsKey( received.getData() )) {
         connectionMap.put( received.getData(), connection );
         Message acceptedUserName = new Message( MessageType.NAME_ACCEPTED );
         connection.send( acceptedUserName );
         return received.getData();
     } else return serverHandshake( connection );
 }

 private void notifyUsers(Connection connection, String userName) throws IOException {
     for (String key : connectionMap.keySet()) {
         Message clientName = new Message( MessageType.USER_ADDED, key );
         if (!key.equals( userName )) {
             connection.send( clientName );
         }
     }
 }

 private void serverMainLoop(Connection connection, String userName) throws IOException, ClassNotFoundException {
     while (true) {
         Message received = connection.receive();

         if (received != null && received.getType() == (MessageType.TEXT)) {
             Message message = new Message( MessageType.TEXT, userName + ": " + received.getData() );
             sendBroadcastMessage( message );
         } else ConsoleHelper.writeMessage( "Ошибка." );
     }
 }

Анатолий

Уровень 28

23 сентября 2019, 09:53

продолжение public class Server

@Override
        public void run() {
            String userName = "";
            try {
                SocketAddress remoteSocketAddress = socket.getRemoteSocketAddress();
                System.out.println( "Установлено новое соединение с " + remoteSocketAddress + "." );
                Connection connection = new Connection( socket );
                userName = serverHandshake( connection );
                sendBroadcastMessage( new Message( MessageType.USER_ADDED, userName ) );
                notifyUsers( connection, userName );
                serverMainLoop( connection, userName );

            } catch (IOException e) {
                e.printStackTrace();
            } catch (ClassNotFoundException f) {
                f.printStackTrace();
            }

            if (userName != null) {
                connectionMap.remove( userName );
                sendBroadcastMessage( new Message( MessageType.USER_REMOVED, userName ) );
            }
            ConsoleHelper.writeMessage( "Соединение закрыто." );

        }
    }
}

Roman K

Уровень 31

24 сентября 2019, 05:24

Попробуйте нажать вот это. Тогда у вас весь проект и валидация на него подгрузятся. Что весьма облегчит боль вам и помощнику

Анатолий

Уровень 28

24 сентября 2019, 07:53

Спасибо за уделенное время. Эта кнопка ведет на страницу "помощь" на которой сейчас я и нахожусь, то есть это лишь возможность задать вопрос (но я и так уже этим воспользовался). Буду двигаться дальше. Еще раз спасибо, что откликнулись :)

Roman K

Уровень 31

24 сентября 2019, 17:03

решение

Дело в том, что нажимая эту кнопку плагин подтягивает все дерево классов и проблемы, связанные с валидатором. Наверняка вы видели вопросы, задаваемые другими пользователями, в которых все несколько яснее) А вообще, сегодня пытался запускать ваш проект несколько раз. В GUI все норм отображается