/** * 訂閱觀察者 * @author Administrator * */@Component//標(biāo)志為多例@Scope(value=ConfigurableBeanFactory.SCOPE_PROTOTYPE)public class SubscriberObserver implements Observer{  private String email;  private String phone;  private String username;  @Autowired  UserFunctionService UserFunctionService;  @Override  public void update(Observable o, Object arg) {    if(o instanceof EmailAlertSubject){      UserFunctionService.alertUserEmail(email,username);    }    if(o instanceof PhoneAlertSubject){      UserFunctionService.alertUserPhone(phone,username);    }  }  public String getEmail() {    return email;  }  public void setEmail(String email) {    this.email = email;  }  public String getPhone() {    return phone;  }  public void setPhone(String phone) {    this.phone = phone;  }  public String getUsername() {    return username;  }  public void setUsername(String username) {    this.username = username;  }  public SubscriberObserver() {    super();    // TODO Auto-generated constructor stub  }}

/** * email提醒主題 * @author Administrator * */@Componentpublic class EmailAlertSubject extends Observable{  public void alert(){     this.setChanged();     //如果用拉的方式，這么調(diào)用     this.notifyObservers();  }}

/** * 短信提醒主題 * @author Administrator * */@Componentpublic class PhoneAlertSubject extends Observable{  public void alert(){     this.setChanged();     //如果用拉的方式，這么調(diào)用     this.notifyObservers();  }}

/** * 定時(shí)給訂閱了短信提醒和email提醒的用戶服務(wù) * @author Administrator * */@Componentpublic class TimeAlertTaskUtil {  @Autowired  CommonUserService commonUserService;  @Autowired  JedisConnectionFactory factory;  @Autowired  EmailAlertSubject emailSubject;  @Autowired  PhoneAlertSubject phoneSubject;  private static final String emailKeyName = "emailAlert:";  private static final String phoneKeyName = "phoneAlert:";  /**   * 定時(shí)獲取需要email提醒的用戶,每10分鐘調(diào)用一次   */  @Scheduled(fixedDelay = 1000 * 60 * 10)  public void alertEmailTask() {    // 1.獲取數(shù)據(jù)庫(kù)中達(dá)到了閾值的用戶    List<User> emails = commonUserService.getUserAlertEmailAndName();    // 2.查看redis中是否有達(dá)到閾值，且48小時(shí)已經(jīng)通知的用戶，將其排除在觀察者行列,最終得出觀察者隊(duì)伍    List<SubscriberObserver> informEmail = getInformObserver(emails);    // 3.創(chuàng)建主題，添加觀察者    addObservers(emailSubject, informEmail);    // 4.通知    emailSubject.alert();    // 5.將已經(jīng)通知的觀察者信息存儲(chǔ)到reids內(nèi)，設(shè)置過(guò)期時(shí)間為一天    setRedisCache(emails);    // 6.將觀察者從主題中移除    deleteObservers(emailSubject, informEmail);  }  /**   * 定時(shí)獲取需要短信提醒的用戶,每10分鐘調(diào)用一次   *    */  @Scheduled(fixedDelay = 1000 * 60 * 10)  public void alertPhoneTask() {    // 1.獲取數(shù)據(jù)庫(kù)中達(dá)到了閾值的用戶    List<User> phones = commonUserService.getUserAlertPhoneAndName();    // 2.查看redis中是否有達(dá)到閾值，且今天已經(jīng)通知的用戶，將其排除在觀察者行列,最終得出觀察者隊(duì)伍    List<SubscriberObserver> informPhones = getInformObserver(phones);    // 3.創(chuàng)建主題，添加觀察者    addObservers(phoneSubject, informPhones);    // 4.通知    phoneSubject.alert();    // 5.將已經(jīng)通知的觀察者信息存儲(chǔ)到reids內(nèi)，設(shè)置過(guò)期時(shí)間為一天    setRedisCache(phones);    // 6.將觀察者從主題中移除    deleteObservers(phoneSubject, informPhones);  }  /**   * ------------------------------------------------------------------------   * -----------------------------------------------------   **/  /**   * 過(guò)濾掉今天已經(jīng)email提醒的用戶，返回真正需要提醒的觀察者列表   *    * @param emails   * @return   */  private List<SubscriberObserver> getInformObserver(      List<User> users) {    List<SubscriberObserver> obs = new ArrayList<SubscriberObserver>();    Jedis jedis = factory.getConnection().getNativeConnection();    for (User user : users) {      String value;      SubscriberObserver observer = (SubscriberObserver) SpringConfigTool          .getBean("subscriberObserver");      if (user.getEmail()!=null) {        value = jedis.get(emailKeyName + user.getEmail());        if (value == null || !value.equals("success")) {          observer.setEmail(user.getEmail());          observer.setUsername(user.getName());          obs.add(observer);        }      } else {        value = jedis.get(phoneKeyName + user.getPhone());        if (value == null || !value.equals("success")) {          observer.setPhone(user.getPhone());          observer.setUsername(user.getName());          obs.add(observer);        }      }    }    return obs;  }  /**   * 將指定的觀察者列表添加到指定的主題   *    * @param subject   * @param list   */  private void addObservers(Observable subject, List<SubscriberObserver> list) {    for (SubscriberObserver obs : list) {      subject.addObserver(obs);    }  }  private void deleteObservers(Observable subject,      List<SubscriberObserver> list) {    for (SubscriberObserver obs : list) {      subject.deleteObserver(obs);    }  }  /**   * 將列表的值作為鍵，存入redis,過(guò)期時(shí)間為48小時(shí)   *    * @param list   */  private void setRedisCache(List<User> users) {    Jedis jedis = factory.getConnection().getNativeConnection();    for (User user : users) {      if (user.getEmail()!=null) {        jedis.set(emailKeyName + user.getEmail(), "success", "NX", "EX",            60 * 60 * 24 * 2);      } else {        jedis.set(phoneKeyName + user.getPhone(), "success", "NX", "EX",            60 * 60 * 24 * 2);      }    }  }}