Доброго времени суток!
Столкнулся со следующей проблемой при написании своего
"прокси сервера", в задачи которого входит приём соединения от клиента, написанного мною же и соединение с удалённым сервером некоторой базы данных. По сути, на прокси сервер пока
не возлогается больше никаких функций.
Так же необходимо обеспечить возможность подключения нескольких клиентов одновременно.
Поэтому, было принято решение реализовать его следующим образом:
при подключении нового клиента, устанавливается новое соединение как с ним так и с
сервером, для нового клиента сервер БД выделяет новый порт; и создается два потока
(threads) один постоянно читает с сервера и передаёт всё, что прочитал клиенту, а второй
так же передаёт данные от клиента к серверу. Возникла следующая проблема: не всегда
получается прочитать то, что приходит с удалённого сервера БД, хотя запрос всегда остаётся
неизменным, а данные от сервера приходят на машину с прокси, если верить SnifMon'у.
Получается так: может придти, а может и нет.
Запускал на машине друга --- работает всегда. Возможно нужна какая то синхронизация? Но
где, если оба потока читают и записывают в разные места?
Приведу код классов, реализующих потоки:

Код

class DataTransferThread extends Thread{         private final Socket socket;         private final Socket neighbor;         private final InputStream inStream;         private final OutputStream outStream;         private final byte[] buffer = new byte[256 << 10];           DataTransferThread(String name, Socket socket,                            OutputStream outStream,                            Long rwTime, Socket neighbor)                 throws IOException{             super(name);             this.socket = socket;             inStream = socket.getInputStream();             this.outStream = outStream;             this.neighbor = neighbor;         }           public void run(){             while(!socket.isClosed()){                 try{                     int read;                     read = inStream.read(buffer, 0, buffer.length);                     if(read != 0){                         outStream.write(buffer, 0, read);                         outStream.flush();                     }                 } catch(IOException e){                     ....                 }             }         }     }

Подскажите, пожалуйста, возможные варианты решения проблемы!

Заранее благодарен.

Проверь может файрволл рубит или антивирус( в версии java 1.5 и выше у меня лично возникали проблемы с Nod32 при использовании сокетов)

насколько могу судить по вашему коду, вы пытаетесь запустить два экземпляра одного и того же класса "навстречу друг-другу".
если это так, то вы напарываетесь на неготовность одного из стримов к моменту, когда он понадобится (т.е. если удалось соединиться - дальше все работает нормально, но соединиться удается не всегда ).

тогда кроме пары симметричных "встречных" прокси-нитей нужна "клиентская" нить, которая создаст все 4 стрима - а потом можно либо запускать пару прокси-нитей и ждать их завершения, либо (что правильнее) запустить одну нить-"перекладывалку из сокета в сокет", а навстречу перекладывать в методе Run самой клиентской нити.

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

В данном случае БД весьма активна. Она полностью управляет процессом запущенным у клиента.
БД --- Cache post-relational database

Схему с двумя встречными потоками информации сложно контролировать, если данные передаются через интернет. Мы отказались от нее в пользу "запрос - ответ". Так легче определить, какая порция данных уже получена клиентом в случае обрыва соединения. Кроме того, это единственная схема передачи информации , если клиент вынужден соединяться по http.