Java: переподключение на сокете иногда дает ошибку - PullRequest
Новая
       18

Java: переподключение на сокете иногда дает ошибку

0 голосов
/ 23 марта 2009

Я делаю прототип клиента и сервера, чтобы понять, как обрабатывать повторные подключения. Сервер должен создать серверный сокет и слушать вечно. Клиент может подключиться, отправить свои данные и закрыть свой сокет, но он не отправит на сервер сообщение типа «Я закончил и закрываю». По этой причине сервер получает EOFException, когда он делает readByte(), так как удаленный клиент закрыт. В обработчике ошибок для EOFException он закроет сокет и откроет новый.

Вот проблема: клиент иногда получает SocketWriteError, когда он делает вызов outputStream.write() даже после того, как он успешно открывает сокет / inputtream / outpustream. Это может быть связано с частотой, с которой я открываю и закрываю эти гнезда. Одна интересная вещь заключается в том, что клиент выполняет произвольное количество операций записи / закрытия / повторного соединения перед тем, как его отключить. При первом переподключении он иногда дерьмово, в других случаях потребуется 50 повторных подключений, прежде чем вы увидите SocketWriteError.

Вот ошибка на стороне клиента: 

java.net.SocketException: Connection reset by peer: socket write error
       at java.net.SocketOutputStream.socketWrite0(Native Method)
       at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
       at java.net.SocketOutputStream.write(SocketOutputStream.java:115)
       at bytebuffertest.Client.main(Client.java:37)

Вот некоторые фрагменты кода:

SERVER: 

public static void main(String[] args)
{
    Server x = new Server();
    x.initialize();
}

private void initialize()
{
    ServerSocket s;
    InputStream is;
    DataInputStream dis;
    while (true) //ADDED THIS!!!!!!!!!!!!!!!!!!!!!!
    {
        try
        {
            s = new ServerSocket(4448);
            s.setSoTimeout(0);
            s.setReuseAddress(true);
            is = s.accept().getInputStream();
            System.out.println("accepted client");
            dis = new DataInputStream(is);
            try
            {

                byte input = dis.readByte();
                System.out.println("read: " + input);
            } catch (Exception ex)
            {
                System.out.println("Exception");
                dis.close();
                is.close();
                s.close();
            }
        } catch (IOException ex)
        {
            System.out.println("ioexception");
        }
    }
}

КЛИЕНТ: 

public static void main(String[] args)
{
    Socket s;
    OutputStream os;
    try
    {
        s = new Socket("localhost", 4448);
        s.setKeepAlive(true);
        s.setReuseAddress(true);
        os = s.getOutputStream();
        int counter = 0;
        while (true)
        {
            try
            {
                os.write((byte) counter++);
                os.flush();

                os.close();
                s.close();

                s = new Socket("localhost", 4448);
                s.setKeepAlive(true);
                s.setReuseAddress(true);
                os = s.getOutputStream();
            } catch (Exception e)
            {
                e.printStackTrace();
                System.err.println("ERROR: reconnecting...");
            }
        }
    } catch (Exception ex)
    {
        ex.printStackTrace();
        System.err.println("ERROR: could not connect");
    }
}

Кто-нибудь знает, как правильно восстановить соединение?

1 Ответ

3 голосов
/ 23 марта 2009

Не закрывайте ServerSocket при ошибке, просто .accept () новое соединение.

Что я обычно делаю, так это каждый раз, когда ServerSocket.accept () возвращает Socket, я порождаю поток для обработки отправки и получения из этого Socket. Таким образом, вы готовы начать принимать новое соединение, как только кто-то захочет подключиться к вам.

...