个人中心
gpt4 book ai didi

java使用观察者模式异步短信/邮箱提醒用户群

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章java使用观察者模式异步短信/邮箱提醒用户群由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

需求 。

用户中有人设置了账户余额达到阈值时，短信/邮箱进行提醒的服务。我们将需要在他账户余额阈值达到指定数值的时候进行短信/邮箱消息通知，允许账户余额阈值出现偏差的时候通知，如果某个用户48小时内已经短信/邮箱进行过通知了，那么将不再进行通知.

剖析 。

  • 存在两个主题：短信通知和邮箱通知
  • 存在两种观察者：设置了短信通知且账户余额到达阈值的用户，设置了邮箱通知且账户余额到达阈值的用户。
  • 用spring的定时器，每10分钟去数据库获取某个主题已经达到阈值且开始了该主题的提醒功能的用户
  • 用spring的@asycn注解异步短信通知，邮箱通知的相关方法
  • 用redis设置用户短信/邮箱为键名，设置过期时间为48小时。如果获取不到该键值对，说明其在观察者行列

代码 。

观察者父类 。

  。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
/**
  * 订阅观察者
  * @author administrator
  *
  */
@component
//标志为多例
@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
   }
 
 
}

主题 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
/**
  * email提醒主题
  * @author administrator
  *
  */
@component
public class emailalertsubject extends observable{
 
   public void alert(){
      this .setchanged();
      //如果用拉的方式，这么调用
      this .notifyobservers();
   }
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
/**
  * 短信提醒主题
  * @author administrator
  *
  */
@component
public class phonealertsubject extends observable{
 
   public void alert(){
      this .setchanged();
      //如果用拉的方式，这么调用
      this .notifyobservers();
   }
}

定时器 。

  。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
/**
  * 定时给订阅了短信提醒和email提醒的用户服务
  * @author administrator
  *
  */
@component
public 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:" ;
 
   /**
    * 定时获取需要email提醒的用户,每10分钟调用一次
    */
   @scheduled (fixeddelay = 1000 * 60 * 10 )
   public void alertemailtask() {
     // 1.获取数据库中达到了阈值的用户
     list<user> emails = commonuserservice.getuseralertemailandname();
     // 2.查看redis中是否有达到阈值，且48小时已经通知的用户，将其排除在观察者行列,最终得出观察者队伍
     list<subscriberobserver> informemail = getinformobserver(emails);
     // 3.创建主题，添加观察者
     addobservers(emailsubject, informemail);
     // 4.通知
     emailsubject.alert();
 
     // 5.将已经通知的观察者信息存储到reids内，设置过期时间为一天
     setrediscache(emails);
     // 6.将观察者从主题中移除
     deleteobservers(emailsubject, informemail);
   }
 
   /**
    * 定时获取需要短信提醒的用户,每10分钟调用一次
    *
    */
   @scheduled (fixeddelay = 1000 * 60 * 10 )
   public void alertphonetask() {
     // 1.获取数据库中达到了阈值的用户
     list<user> phones = commonuserservice.getuseralertphoneandname();
     // 2.查看redis中是否有达到阈值，且今天已经通知的用户，将其排除在观察者行列,最终得出观察者队伍
     list<subscriberobserver> informphones = getinformobserver(phones);
 
     // 3.创建主题，添加观察者
     addobservers(phonesubject, informphones);
     // 4.通知
     phonesubject.alert();
     // 5.将已经通知的观察者信息存储到reids内，设置过期时间为一天
     setrediscache(phones);
     // 6.将观察者从主题中移除
     deleteobservers(phonesubject, informphones);
   }
 
   /**
    * ------------------------------------------------------------------------
    * -----------------------------------------------------
    **/
   /**
    * 过滤掉今天已经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,过期时间为48小时
    *
    * @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 );
       }
     }
   }
}

总结 。

代码是不全面的，只是个示例而已。关于短信通知和邮箱通知的服务类和工具类并没有给出，因为里面涉及到一些隐私参数。所以关于异步通知示例代码没有，但使用spring管理的@async注解和在spring进行一定的配置即可，可以在我的另外一篇博客找到关于异步通知的示例代码.

事实上根据需求，可以使用redis的发布订阅，或者消息队列mq来实现类似的功能。但为了加深对设计模式的理解，所以写了一个不是很纯正的观察者模式来模仿发布订阅的操作.

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.

原文链接：https://blog.csdn.net/qq_32020035/article/details/81204374 。

最后此篇关于java使用观察者模式异步短信/邮箱提醒用户群的文章就讲到这里了,如果你想了解更多关于java使用观察者模式异步短信/邮箱提醒用户群的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： java用类加载器的5种方式读取.properties文件
文章推荐： Harmony应用开发必掌握内容整理—架构到开发到发布
文章推荐： 剖析Npm、Yarn 与 Pnpm 依赖管理逻辑
文章推荐： 如何在 Fedora Linux 上安装 Brave 浏览器
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com