Форум программистов [Powered by Invision Power Board]

Цитата(Norb @ 28.2.2008, 22:59)

Но как раз в этом месте программа виснет и не подаёт признаков жизни. Что делать не знаю, ведь на сервере реализация ожидания сообщений аналогичная и работает превосходно.

Код


public class Connector extends Thread {

    private Socket socket;
    private InputStreamReader isr;
    private BufferedReader br;
    private OutputStreamWriter osw;
    private PrintWriter pw;
    private ArrayList<String> out = new ArrayList<String>();
    private boolean stop = false;
    private final int TIMEOUT = 200;

    /** Logger. */
    private Logger logger = Logger.getLogger("Connector");
    private boolean toSend;

    public Connector(Socket socket) {
        this.socket = socket;

        try {
            this.socket.setSoTimeout(TIMEOUT);

            isr = new InputStreamReader(socket.getInputStream());
            br = new BufferedReader(isr);

            osw = new OutputStreamWriter(socket.getOutputStream());
            pw = new PrintWriter(osw, true);

            logger.info("Socket streams initialized");
        } catch (IOException e) {
            logger.warning("Socket failed " + e.getMessage());
        }
    }

    @Override
    public void run() {
        try {
            while (!stop) {
                try {
                    String result;

                    result = br.readLine();
                    logger.info("Received message " + ": " + result);

                    if (result != null || !result.trim().isEmpty()) {
                        // do something;
                    }
                } catch (SocketTimeoutException e) {
                    // do nothing
                }

                if (toSend) {
                    send();
                }
            }
        } catch (IOException e) {
            JOptionPane.showMessageDialog(null, "Network failed", "Network failed",
                    JOptionPane.WARNING_MESSAGE);
            logger.severe("Socket failed " + e.getMessage());
        }
    }

    /**
     * Sends the data
     */
    private void send() {
        synchronized (out) {
            for (String s : out) {
                pw.println(s);
                pw.flush();
                logger.info("Message is sent: [" + s + "]");
            }
            out.clear();
            // set flag for sending
            toSend = false;
        }
    }

    public void addMessageOut(String msg) {
        synchronized (out) {
            out.add(msg);
        }
        toSend = true;
        logger.info("outgoing message added: " + msg);
    }
}