Блог

Я создаю программу чата, в которой хосты подключаются через сокеты и общаются друг с другом, используя потоки ObjectInput и ObjectOutput. Хост создает строку из ввода с клавиатуры и отправляет ее другим хостам вместе с массивом целых чисел.

После того, как хост успешно прочитал сообщение через readObject() , цикл while(true) продолжается, и этот хост зависает при следующем вызове readObject() . Я могу только предположить, что это связано с тем, что indata.available() возвращает true даже после чтения того, что в нем было, и когда он пытается снова прочитать, прежде чем что-то еще было отправлено, он блокируется (ожидает).

Фрагмент соответствующего кода приведен ниже. Я провел некоторое исследование и обнаружил, что не могу очистить или очистить входной поток. Я также не могу закрыть его — из-за характера постоянно работающей программы чата он должен оставаться открытым, чтобы продолжить чтение.

Кроме того, я понимаю, что я проверяю indata.available(), а затем считываю с помощью inputs.readObject() . Я думал, что это правильный способ сделать это, но поправьте меня, если я ошибаюсь.

Я не уверен, что с этим делать! Мне нужно, чтобы indata.available() возвращал 0, если я не записал объект в поток.

     private InputStream[] indata;                
    private ObjectInputStream[] inputs;          
    private ObjectOutputStream[] outputs;        
    private int[] stamps;   

    // Establish connections via sockets between 3 hosts, serverless                     

    while (true) {
        // Build a message
        for (all hosts that aren't myself) {
            if ( i != rank ) {
                outputs[i].writeObject( message );
                outputs[i].writeObject( stamps );
                outputs[i].flush( ); 
                outputs[i].reset( );
            }
        }

        // Read a message in from a host that sent one
        for (all hosts that aren't myself) {
            if (indata[j].available() > 0) {
                String message = (String)inputs[j].readObject();
                int[] senderStamps = (int[])inputs[j].readObject();
            }
        }
    }
  

Некоторая дополнительная информация для пояснения:

Я использую available(), потому что инструктор использовал его в своем коде, и мне не разрешено его изменять. Кроме того, вызов available () работал как задумано, когда отправлялся только один объект (строка) — единственным кодом, который был на стороне отправки, были «writeObject» и «flush». Моей задачей было добавить код для отправки массива, и когда я это делаю, мне также нужно добавить код для сброса () ObjectOutputStream (или я получаю другие проблемы — когда массив отправляется, изменяется, а затем отправляется снова без вызова reset() между отправками,вместо недавно измененной отправляется исходная, неизмененная версия).

Я не могу просто заблокировать чтение, поскольку процесс, заблокированный при чтении, не может выполнять запись на другие хосты, и мне нужно иметь возможность записывать, даже если хосту нечего читать.

Кроме того, нам не разрешено использовать несколько потоков.