游戏系统设计开发之观察者模式

package com.observer;

import java.util.Observable;

/**

* 抽象主题(Subject)角色

* @author youxijishu.com

*

*/

public class MyObservable extends Observable{

private static MyObservable observable = new MyObservable();

private MyObservable(){}

public static MyObservable getInstance(){

   return observable;

}

/**

* 当有事件发生时，调用这个方法，它会通知所有的观察者

* @author youxijishu.com

* @param msg

* 2016年10月16日下午9:43:34

*/

public void change(ObserverMsg msg){

   this.notifyObservers(msg);

}

}

package com.observer;

/**

* 观察模式中的消息传递类，这个类最好是不可变的，可以使用建筑模式设计这个类，我在这里简单写了。

*

* @author youxijishu.com

*

*/

public class ObserverMsg {

private long playerId;

private ObserverType type;

private int exp;

public long getPlayerId() {

   return playerId;

}

public void setPlayerId(long playerId) {

   this.playerId = playerId;

}

public ObserverType getType() {

   return type;

}

public void setType(ObserverType type) {

   this.type = type;

}

public int getExp() {

   return exp;

}

public void setExp(int exp) {

   this.exp = exp;

}

}

package com.observer;

/**

* 事件改变的类型，用于观察者根据不同的事件 处理不同的操作，这样在整个游戏系统中，我们只需要定义一个观察者模式就可以了。

* @author youxijishu.com

*

*/

public enum ObserverType {

   ADDEXP

}

package com.observer;

import java.util.Observable;

import java.util.Observer;

/**

* 角色系统

*

* @author youxijishu.com

*

*/

public class PlayerManager implements Observer {

private static PlayerManager playerManager = new PlayerManager();

   private PlayerManager() {

   //向被观察者添加注册事件，当被观察者有变化时，会收到通知。

   MyObservable.getInstance().addObserver(this);

   }

   public static PlayerManager getInstance(){

       return playerManager;

   }

@Override

public void update(Observable o, Object arg) {

   if (arg instanceof ObserverMsg) {

       ObserverMsg msg = (ObserverMsg) arg;

       if (msg.getType() == ObserverType.ADDEXP) {

       // 处理添加经验的事件

       }

   }

}

}

package com.observer;

import java.util.Observable;

import java.util.Observer;

/**

* 任务系统

* @author youxijishu.com

*

*/

public class TaskManager  implements Observer{

private static TaskManager taskManager = new TaskManager();

private TaskManager(){

   ////向被观察者添加注册事件，当被观察者有变化时，会收到通知。

   MyObservable.getInstance().addObserver(this);

}

public static TaskManager getInstance(){

   return taskManager;

}

@Override

public void update(Observable o, Object arg) {

   if(arg instanceof ObserverMsg){

       ObserverMsg msg = (ObserverMsg)arg;

       if(msg.getType() == ObserverType.ADDEXP){

       //处理添加经验的事件

       }

   }

}

}

package com.observer;

/**

* 物品系统

* @author youxijishu.com

*

*/

public class ItemManager {

public void userItem(long playerId,int itemid){

   Item item = this.getItem(playerId,itemid);

   if(item != null){

   if(item.getType == 2){

       ObserverMsg msg = new ObserverMsg();

       msg.setExp(item.getExp);

       msg.setPlayerId(playerId);

       msg.setType(ObserverType.ADDEXP);

       //发送变更的事件，通知所有观察者添加这么多经验，观察者根据自己的需要处理这个事件

       MyObservable.getInstance().change(msg);

      }

   }

}

}