聊聊claudb的NotificationManager
时间:2022-07-24
本文章向大家介绍聊聊claudb的NotificationManager,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下claudb的NotificationManager
NotificationManager
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/event/NotificationManager.java
public class NotificationManager implements PatternSubscriptionSupport {
private final DBServerContext server;
private final ExecutorService executor = Executors.newSingleThreadExecutor();
public NotificationManager(DBServerContext server) {
this.server = server;
}
public void start() {
// nothing to do
}
public void stop() {
executor.shutdown();
}
public void enqueue(Event event) {
executor.execute(() -> patternPublish(server, event.getChannel(), event.getValue()));
}
}
- NotificationManager实现了PatternSubscriptionSupport接口,其构造器要求输入DBServerContext,它提供了start、stop、enqueue方法;其stop方法执行executor.shutdown();其enqueue方法使用executor异步执行patternPublish(server, event.getChannel(), event.getValue())
patternPublish
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/pubsub/PatternSubscriptionSupport.java
public interface PatternSubscriptionSupport extends BaseSubscriptionSupport {
String PSUBSCRIPTION_PREFIX = "psubscription:";
String PMESSAGE = "pmessage";
//......
default int patternPublish(DBServerContext server, String channel, SafeString message) {
int count = 0;
for (Tuple2<String, ImmutableSet<SafeString>> entry : getPatternSubscriptions(server.getAdminDatabase(), channel)) {
count += publish(server, entry.get2(), toPatternMessage(entry.get1(), channel, message));
}
return count;
}
default ImmutableSet<Tuple2<String, ImmutableSet<SafeString>>> getPatternSubscriptions(Database admin, String channel) {
return getPatternSubscriptions(admin).entries().filter(subscriptionApplyTo(channel));
}
//......
}
- patternPublish方法遍历getPatternSubscriptions(server.getAdminDatabase(), channel),挨个执行publish(server, entry.get2(), toPatternMessage(entry.get1(), channel, message)
BaseSubscriptionSupport
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/pubsub/BaseSubscriptionSupport.java
public interface BaseSubscriptionSupport
{
default void addSubscription(String suffix, Database admin, String sessionId, SafeString channel) {
admin.merge(safeKey(suffix + channel), set(safeString(sessionId)),
(oldValue, newValue) -> set(oldValue.getSet().appendAll(newValue.getSet())));
}
default void removeSubscription(String suffix, Database admin, String sessionId, SafeString channel) {
admin.merge(safeKey(suffix + channel), set(safeString(sessionId)),
(oldValue, newValue) -> set(oldValue.getSet().removeAll(newValue.getSet())));
}
default int publish(DBServerContext server, ImmutableSet<SafeString> clients, RedisToken message) {
clients.forEach(client -> server.publish(client.toString(), message));
return clients.size();
}
}
- BaseSubscriptionSupport提供了publish方法,它遍历clients,挨个执行server.publish(client.toString(), message)
publish
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/ClauDB.java
public class ClauDB extends RespServerContext implements DBServerContext {
private static final String STATE = "state";
private static final Logger LOGGER = LoggerFactory.getLogger(ClauDB.class);
private DatabaseCleaner cleaner;
private Option<PersistenceManager> persistence;
private Option<NotificationManager> notifications;
private final DBConfig config;
public ClauDB() {
this(DEFAULT_HOST, DEFAULT_PORT);
}
public ClauDB(String host, int port) {
this(host, port, DBConfig.builder().build());
}
public ClauDB(String host, int port, DBConfig config) {
super(host, port, new DBCommandSuite(), new DBSessionListener());
this.config = config;
}
//......
@Override
public void publish(String sourceKey, RedisToken message) {
Session session = getSession(sourceKey);
if (session != null) {
session.publish(message);
}
}
//......
}
- ClauDB的publish方法执行的是session.publish(message)
小结
NotificationManager实现了PatternSubscriptionSupport接口,其构造器要求输入DBServerContext,它提供了start、stop、enqueue方法;其stop方法执行executor.shutdown();其enqueue方法使用executor异步执行patternPublish(server, event.getChannel(), event.getValue())
doc
- NotificationManager
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Android之自定义实现BaseAdapter(通用适配器三)
- Android实现音乐播放器锁屏页
- android studio3.3.1代码提示忽略大小写的设置
- Ascgen2可以把图片变成文字的小工具
- 解决android studio卡顿,提升studio运行速度的方法
- Android物理键盘事件解析
- AndroidQ(10)分区存储完美适配方法
- (全局快捷键工具)Power Keys彻底提升码字效率?
- android自定义view实现钟表效果
- 教你如何用OpenVZ限制虚拟机硬盘IO速度
- Android自定义控件实现短信验证码自动填充
- android studio 3.6.1升级后如何处理 flutter问题
- Android项目迁移到AndroidX的方法步骤
- Android中layer-list基本使用详解
- Android Studio中主题样式的使用方法详解