Как я могу использовать шаблон наблюдателя для мониторинга файлов с потоками?

Я пытаюсь реализовать шаблон наблюдателя в игре, которую я сделал. Когда злодей создается в файле зоны битвы с использованием потоков, я хотел бы использовать шаблон наблюдателя, чтобы создать героя с помощью потоков и добавить его в тот же файл. Злодеи и герои создаются с использованием шаблона фабричного метода. Я не уверен, куда идти, чтобы связать мой класс HeroCreationMain с классами шаблонов наблюдателя.

Злодейское Творение

public class VillianCreationMain {

private static Villian villian;

public static void main(String[] args, int userInput) throws IOException {

    String fileName = null;

    Random randomVillian = new Random();

    int amountOfVillians = userInput;

    if (amountOfVillians < 7) {

        for (int x = 0; x < amountOfVillians; x++) {

            int randomGenerator = randomVillian.nextInt(6);

                for (int i = 0; i < 5; i++) {

                    if (randomGenerator == 0 ) {

                        setVillian(new FlyingVillian());

                    }

                    else if (randomGenerator == 1) {

                        setVillian(new StrongVillian());

                    }

                    else if (randomGenerator == 2) {

                        setVillian(new FastVillian());

                    }

                    else if (randomGenerator == 3) {

                        setVillian(new SmartVillian());

                    }

                    else if (randomGenerator == 4) {

                        setVillian(new FireVillian());

                    }

                    else if (randomGenerator == 5) {

                        setVillian(new IceVillian());

                    }

                        try {

                            writeToFile(getVillian(), i, fileName);
                        }
                        catch (IOException e) {

                            System.out.println(e.getMessage());
                        }

                    }

                VillianThreads t1 = new VillianThreads(VillianCreationMain.getVillian());

                t1.start();

                }

            }

    else {

            System.out.println("Please enter a value of less than 7");
    }
}

public static void writeToFile(Villian villian, int amountOfVillians, String fileName) throws IOException {

    for(int x = 0; x < amountOfVillians; x++) {

    //  String parsedInt = Integer.toString(x);

        fileName = "battle-zone.ser";

        FileOutputStream file = new FileOutputStream(fileName);
        ObjectOutputStream oos = new ObjectOutputStream(file);

        oos.writeObject(villian);

        file.close();
        oos.close();
    }
}

public static Villian getVillian() {
    return villian;
}

public static void setVillian(Villian villian) {
    VillianCreationMain.villian = villian;
}

}

Создание героя

public class HeroCreationMain {

private static Hero hero = null;

public static void main(String[] Hero) {

    EnemyStatus enemyStatus = new EnemyStatus();

    VillianObserver observer1 = new VillianObserver(enemyStatus);

}

public static void readFile() throws IOException, ClassNotFoundException {

    @SuppressWarnings("resource")
    ObjectInputStream ois = new ObjectInputStream (new FileInputStream("battle-zone.ser"));

    Villian targetVillian = (Villian) ois.readObject();
    System.out.println(targetVillian + " is being attacked by a hero!");
}

public static Hero getHero() {
    return hero;
}

public static void setHero(Hero hero) {
    HeroCreationMain.hero = hero;
}
}

Наблюдатель

public interface Observer {

public void update(boolean enemyPresent);

}

public interface Subject {

public void register(Observer o);
public void unregister(Observer o);
public void notifyObserver();

}

Наблюдаемый

public class VillianObserver implements Observer {

private boolean enemyPresent;
private static int heroIDTracker;
private int heroID;
private Subject villianObserver;

public VillianObserver(Subject villianObserver) {

    this.villianObserver = villianObserver;
    this.heroID = ++heroIDTracker;
    System.out.println("New Observer " + this.heroID);
    villianObserver.register(this);
}

@Override
public void update(boolean enemyPresent) {

    this.enemyPresent = enemyPresent;
    printResult();
}

public void printResult() {

    System.out.println(heroID + " " + enemyPresent);
}

}

Статус врага

import java.util.ArrayList;

public class EnemyStatus implements Subject {

private ArrayList<Observer> observers;
private boolean enemyPresent;

public EnemyStatus() {

    // Creates an ArrayList to hold all observers

    observers = new ArrayList<Observer>();

}

@Override
public void register(Observer newObserver) {

    observers.add(newObserver);

}

@Override
public void unregister(Observer deleteObserver) {

    // Get the index of the observer to delete

    int heroIndex = observers.indexOf(deleteObserver);

    // Print out message (Have to increment index to match  

    System.out.println("Observer " + (heroIndex+1) + " deleted");        

    // Removes observer from the ArrayList

    observers.remove(heroIndex);


}

@Override
public void notifyObserver() {

    for(Observer observer : observers) {

        observer.update(enemyPresent);
    }

}

public void setEnemyStatus(boolean enemyPresent) {

    this.enemyPresent = enemyPresent;
    notifyObserver();

}

}  

person Gearoid Sheehan    schedule 13.11.2019    source источник


Ответы (1)


JNotify — это библиотека Java для наблюдения за изменениями файлов в файловой системе.

Один совет: Object(Input/Output)Streams просты, когда вы только начинаете, но они ведут вас по пути разорения. Объекты так легко получают BadVersion. Объектные файлы также относительно сложно проверить с помощью текстового редактора. Я бы посоветовал вам вместо этого попробовать использовать другой формат данных (например, JSON).

person ControlAltDel    schedule 13.11.2019