Проблема с шаблоном Java Observer?

Question

У меня есть следующий наблюдатель:

public class Fisc implements Observer {
double value1;
double value2;
private static HashMap<String, Deposit> accounts=new HashMap<String,Deposit>();
public Fisc(String cnp,Deposit deposit) {

    System.out.println("\n*******Observer*******Watching account:"+id);
    accounts.put(id, deposit);

}

public void update(Observable obj, Object arg) {
    if (arg instanceof Deposit) {
        value1 =((Deposit) arg).getvalue1();
        value2=((Deposit) arg).getvalue2();
        System.out.println("\n*******Observer*******value1 current value:"+value1);
        System.out.println("*******Observer*******value2 current value:"+value2);
    } else {
        System.out.println("Observable error!");
    }
}
}

и наблюдаемое:

import java.util.HashMap;
import java.util.Observable;


public class obs extends Observable {

    private static HashMap<String, Deposit> accounts;

    private static obs instance;

    private obs(HashMap<String,Deposit> accounts){
        obs.accounts=accounts;
    }

    public static obs getInstance(){
        if (instance==null){
            return new obs(new HashMap<String,Deposit>());
        }
        else return instance;
    }

        // ... some unimportant other stuff

    public void depositvalue1(String id,double value1){
        Deposit deposit=accounts.get(id);
        deposit.addvalue1(value1);

        if(deposit.isWatchedByFisc()){
            notifyFisc(deposit);
        }
        System.out.println("obs:Deposited "+value1+ " value1 to account:"+id+"!");
        System.out.println("obs:Current value1 in account:"+deposit.getvalue1());
    }

    public void depositvalue2(String id,double value2){
        Deposit deposit=accounts.get(id);
        deposit.addvalue2(value2);

        if(deposit.isWatchedByFisc()){
            notifyFisc(deposit);
        }

        System.out.println("obs:Deposited "+value2+" value2 to account:"+id+"!");
        System.out.println("obs:Current value1 in account:"+deposit.getvalue2());
    }

    public void depositValues(String id,double value1,double value2){
        Deposit deposit=accounts.get(id);
        deposit.addvalue1(value1);
        deposit.addvalue2(value2);

        if(deposit.isWatchedByFisc()){
            notifyFisc(deposit);
        }

        System.out.println("obs:Deposited "+value1+ " value1 and "+value2+" value2 to account"+id+"!");
        System.out.println("obs:Current value1 in account:"+deposit.getvalue1());
    }

    public void watchAccount(String id){
        Deposit deposit=accounts.get(id);
        deposit.setWatchedByFisc(true);
        addObserver(new Fisc(id,deposit));
    }

    public void stopWatchAccount(String id){
        accounts.get(id).setWatchedByFisc(false);
        System.out.println("obs:Account "+id+" is no longer watched by Fisc!");
    }

    public void notifyFisc(Deposit deposit){
        setChanged();
        notifyObservers(deposit);
    }

}

Все работает так, как предполагалось, за исключением следующего: Если я использую методы depositValue(1,2,s) вместо того, чтобы получать сообщение один раз, я получаю одно и то же сообщение, сколько раз я зарегистрировал депозиты для просмотра. Как я могу это исправить?

Надеюсь, это имеет смысл. Спасибо заранее и извините, если это глупый вопрос, это первый раз, когда используется Observer Pattern.

Возможно, эта строка может быть (несколько раз?): addObserver(new Fisc(id,deposit));

Answer 1

Каждый наблюдатель (экземпляр Fisc) получает уведомление при каждом изменении Deposit экземпляра. Таким образом, с вашим кодом каждый Fisc должен смотреть на уведомление и проверять, составляет ли он свой депозит.

Если вы не хотите этого, то вы должны сделать Deposit наблюдаемым (вместо того, чтобы наблюдать весь банк ). Затем вы можете зарегистрировать слушателей на отдельные депозиты.

Answer 2

Вы объединили все учетные записи в один и тот же объект Observable, и поэтому вы получаете уведомление один раз для каждой учетной записи.

Лучшей моделью, вероятно, было бы введение класса Account и создание этого Observable.
Я предлагаю что-то вроде:

public class Account extends Observable {

    private String id;    
    private BigDecimal balance = new BigDecimal("0.0");

    public Account(String id) {
      this.id = id;
    }

    public BigDecimal getBalance() {
        return balance;
    }

    public void deposit(BigDecimal amount) {
        balance = balance.add(amount);
        notifyObservers();
    }

    public void withdraw(BigDecimal amount) {
        balance = balance.subtract(amount);
        notifyObservers();
    }
}

Ваш класс obs будет содержать список Account s:

private Map<String, Account> accounts = new HashMap<String, Account>();

Обратите внимание, что этот класс используетBigDecimal для представления баланса, поскольку не рекомендуется использовать для него числа с плавающей запятой .