Dubbo的异步回调服务端实现

public interface CallbackService{
  void addListener(String key,CallbackListener listener);
}

public interface CallbackListener{
  void changed(String msg);
}

public class CallbackServiceImpl implements CallbackService{
  private final Map listeners = new ConcurrentHashMap();

  public void addListener(String key,CallbackListener listener){
    listeners.put(key,listener);
  }

  public CallbackServiceImpl(){
    Thread t = new Thread(
      new Runnable(){
        public void run(){
          while(true){
            try{
              for(Map.Entry entry: listeners.entrySer()){
    try{
      entry.getValue().changed(getChanged(entry.getKey()));
    }catch(Throwable t){listeners.remove()}


              }
       
            }catch(Throwable e){listeners.remove(entry.getKey())}
          }

        }

      }

    );
   
  }



}