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

Код

public class NetworkGenerator implements  Runnable {
    private Socket socket;
    private InputStream inputStream;
    private Thread th;
    private boolean active = true;
    private ServerForGenerator newServerForGenerator;


    public NetworkGenerator(int port, Dimension size) {
        newServerForGenerator = new ServerForGenerator(port, size);// Создает сервер для генератора

        try {// Открывает сокетное соединение
            socket = new Socket("localhost", port);
            inputStream = socket.getInputStream();
        } catch (Exception e) {
            System.out.println("" + e);
        }

        th = new Thread(this);// Создаем поток
        th.setDaemon(true);
        th.start();// Стартуем поток
    }

    public void run() {
        while (active) {
            try {
                int x = inputStream.read(), // Поочереди принимает два некоторых сгенерированных значения                y = inputStream.read();


            } catch (IOException e) {
                System.out.println("" + e);
            }
        }
    }

    public void stop() {
        active = false;
        newServerForGenerator.stop();
        newServerForGenerator = null;

    }

}


class ServerForGenerator implements Runnable {
    ServerSocket serverSocket;
    Socket socket;
    Thread threadForListen;
    OutputStream outputStream;
    Dimension size;
    Timer timer;


    public ServerForGenerator(int port, Dimension size) {

        this.size = size;

        try {
            serverSocket = new ServerSocket(port);// создаем серверный сокет
        } catch (IOException e) {
            System.out.println("" + e);
        }
        threadForListen = new Thread(this);// запускаем поток, КОТОрый слушает соединения
        threadForListen.setDaemon(true);
        threadForListen.start();
    }

    public void run() {
        try {
            socket = serverSocket.accept();// если есть запрос на соединение, ТО соединяемся
            outputStream = socket.getOutputStream();
        } catch (IOException e) {
            System.out.println("" + e);
        }
        // что-то тут сделать например:
        timer = new Timer("some timer");
                                if (outputStream != null) {
            try {// на событие таймера пересылаем два некоторых числа клиенту. Посылаем по порядку
                outputStream.write((int) (Math.random() * 100000 % size.width));
                outputStream.write((int) (Math.random() * 100000 % size.width));
            } catch (IOException ex) {
                System.out.println("" + ex);
            }
            } else {

        }
    }

    public void stop() {
        try {
            socket.close();// если стоп, то закрываем сокет.
            serverSocket.close();
            outputStream.close();

            serverSocket = null;
            socket = null;
            outputStream = null;
            timer = null;

        } catch (Exception e) {
            System.out.println("" + e);
        }
    }
}