Вопрос

Я пишу сетевой сервер в Java, и у меня есть крошечная проблема с ней. Пусть код сделает разговор:

import java.io.IOException;
import java.net.ServerSocket;
/**
* Another flavor of the server module.
* According to GOD (also known as Joshua Bloch) this is the proper
* implementation of a singleton (Note: serialization).
* 
* @author estol
*/
public enum EnumSingletonServer implements ServerInterface, Runnable
{
    SERVER;
    private ServerSocket serverSocket = null;
    private boolean Listening         = true;

    @Override
    public void bind() {
        this.bind(DEFAULTPORT);
    }

    @Override
    public void bind(int Port) {
        try {
            this.serverSocket = new ServerSocket(Port);
        } catch (IOException ioe) {
            System.err.printf("Cannot bind to port %d\nAdditional information:\n%s\nExiting\n", Port, ioe.getMessage());
            System.exit(1);
        }
    }

    /**
    * Not that elegant, but does not work with flipping the switch, because
    * the loop (in public void run()) is only running when there is an incoming connection(?).
    * 
    * 
    * FIXME
    */
    @Override
    public void shutdown() {
        // this.Listening = !this.Listening; // FIXME
        System.exit(0);

    }
    /**
    * Accepting connections on the port, we are bound to.
    * The main loop of the server is a bit broken. Does not exit,
    * if we flip the value of this.Listening, but exit on the next incoming
    * connection. This is a problem.
    * 
    * FIXME
    */
    @Override
    public void run() {
        try {
            System.out.printf("Listening on %d\n", this.serverSocket.getLocalPort());
            Thread.currentThread().setName("ServerThread");
            // FIXME
            do {
                new Thread(new ServerWorkerThreads(this.serverSocket.accept(), 3)).start();
            } while (this.Listening);

            this.serverSocket.close();
            System.exit(0);
        } catch (IOException ioe) {
            System.err.printf("Cannot accept on, or close port %d\nAdditional information:\n%s\nExiting\n", this.serverSocket.getLocalPort(), ioe.getMessage());
            System.exit(1);
        }
    }
}
.

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

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

вся помощь будет оценена.

Это было полезно?

Решение

В вашем методе выключения просто закройте сокет вместо настройки переменной:

this.serverSocket.close()
.

Это поднимет socketexception на цикле приема, и цикл остановится.

Лицензировано под: CC-BY-SA с атрибуция
Не связан с StackOverflow
scroll top