| | |
|---|
| | | consumer.accept(msg); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 发布消息到指定的频道 |
|---|
| | | * |
|---|
| | | * @param channelKey 通道key |
|---|
| | | * @param msg 发送数据 |
|---|
| | | */ |
|---|
| | | public static <T> void publish(String channelKey, T msg) { |
|---|
| | | RTopic topic = CLIENT.getTopic(channelKey); |
|---|
| | | topic.publish(msg); |
|---|
| | |
|---|
| | | bucket.setAndKeepTTL(value); |
|---|
| | | } catch (Exception e) { |
|---|
| | | long timeToLive = bucket.remainTimeToLive(); |
|---|
| | | setCacheObject(key, value, Duration.ofMillis(timeToLive)); |
|---|
| | | if (timeToLive == -1) { |
|---|
| | | setCacheObject(key, value); |
|---|
| | | } else { |
|---|
| | | setCacheObject(key, value, Duration.ofMillis(timeToLive)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | bucket.set(value); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获得缓存的基本对象列表 |
|---|
| | | * 获得缓存的基本对象列表(全局匹配忽略租户 自行拼接租户id) |
|---|
| | | * |
|---|
| | | * @param pattern 字符串前缀 |
|---|
| | | * @return 对象列表 |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 删除缓存的基本对象列表 |
|---|
| | | * 删除缓存的基本对象列表(全局匹配忽略租户 自行拼接租户id) |
|---|
| | | * |
|---|
| | | * @param pattern 字符串前缀 |
|---|
| | | */ |
|---|
