public class MineRedis
extends java.lang.Object
构造器和说明 |
---|
MineRedis() |
限定符和类型 | 方法和说明 |
---|---|
static io.lettuce.core.api.async.RedisAsyncCommands<java.lang.String,java.lang.String> |
async()
准备以异步方式操作RedisCommands。
|
static @NotNull RedisManager |
create(@NotNull io.lettuce.core.RedisURI url) |
static @NotNull RedisManager |
create(@NotNull io.lettuce.core.RedisURI url,
@NotNull io.lettuce.core.ClientOptions options) |
static @NotNull RedisManager |
create(@NotNull io.lettuce.core.RedisURI url,
@NotNull io.lettuce.core.resource.ClientResources resources,
@NotNull io.lettuce.core.ClientOptions options) |
static @NotNull java.util.logging.Logger |
getLogger() |
static @NotNull RedisManager |
getManager() |
static @NotNull java.lang.String |
getServerID() |
protected static void |
initializeAPI(IMineRedis api) |
static long |
publish(@NotNull java.lang.String channel,
@NotNull com.google.common.io.ByteArrayDataOutput byteOutput) |
static long |
publish(@NotNull java.lang.String channel,
@NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput) |
static long |
publish(@NotNull java.lang.String channel,
java.lang.Object... values) |
static io.lettuce.core.RedisFuture<java.lang.Long> |
publishAsync(@NotNull java.lang.String channel,
@NotNull com.google.common.io.ByteArrayDataOutput byteOutput) |
static io.lettuce.core.RedisFuture<java.lang.Long> |
publishAsync(@NotNull java.lang.String channel,
@NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput) |
static io.lettuce.core.RedisFuture<java.lang.Long> |
publishAsync(@NotNull java.lang.String channel,
java.lang.Object... values) |
static void |
registerChannel(@NotNull RedisChannel channel) |
static void |
registerChannelListener(@NotNull RedisMessageListener listener,
@NotNull java.lang.String channel,
java.lang.String... moreChannels) |
static void |
registerChannels(@NotNull java.lang.Class<?> channelClazz) |
static void |
registerGlobalListener(@NotNull RedisMessageListener listener,
RedisMessageListener... moreListeners) |
static void |
registerPatternListener(@NotNull RedisMessageListener listener,
@NotNull java.lang.String channelPattern,
java.lang.String... morePatterns) |
static PreparedRedisRequest |
request(@NotNull java.lang.String channel,
@NotNull com.google.common.io.ByteArrayDataOutput byteOutput) |
static PreparedRedisRequest |
request(@NotNull java.lang.String channel,
@NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput) |
static PreparedRedisRequest |
request(@NotNull java.lang.String channel,
java.lang.Object... values) |
static void |
shutdown(RedisManager manager)
终止并关闭一个 RedisManager 实例。
|
static void |
subscribe(@NotNull java.lang.String channel,
java.lang.String... moreChannels) |
static void |
subscribePattern(@NotNull java.lang.String channelPattern,
java.lang.String... morePatterns) |
static void |
supplyServerID(@Nullable java.util.function.Supplier<java.lang.String> idProvider) |
static io.lettuce.core.api.sync.RedisCommands<java.lang.String,java.lang.String> |
sync()
准备以同步方式操作RedisCommands。
|
static void |
unregisterChannels(@NotNull java.lang.Class<?> channelClazz) |
static void |
unregisterListener(@NotNull RedisMessageListener listener) |
static void |
unsubscribe(@NotNull java.lang.String channel,
java.lang.String... moreChannels) |
static void |
unsubscribePattern(@NotNull java.lang.String channelPattern,
java.lang.String... morePatterns) |
protected static void initializeAPI(IMineRedis api)
@NotNull public static @NotNull java.util.logging.Logger getLogger()
@NotNull public static @NotNull java.lang.String getServerID()
public static void supplyServerID(@Nullable @Nullable java.util.function.Supplier<java.lang.String> idProvider)
@NotNull public static @NotNull RedisManager getManager()
@NotNull public static @NotNull RedisManager create(@NotNull @NotNull io.lettuce.core.RedisURI url, @NotNull @NotNull io.lettuce.core.resource.ClientResources resources, @NotNull @NotNull io.lettuce.core.ClientOptions options)
@NotNull public static @NotNull RedisManager create(@NotNull @NotNull io.lettuce.core.RedisURI url, @NotNull @NotNull io.lettuce.core.ClientOptions options)
@NotNull public static @NotNull RedisManager create(@NotNull @NotNull io.lettuce.core.RedisURI url)
public static void shutdown(RedisManager manager)
manager
- RedisManager实例public static io.lettuce.core.api.sync.RedisCommands<java.lang.String,java.lang.String> sync()
RedisCommands
public static io.lettuce.core.api.async.RedisAsyncCommands<java.lang.String,java.lang.String> async()
RedisAsyncCommands
public static void subscribe(@NotNull @NotNull java.lang.String channel, @NotNull java.lang.String... moreChannels)
public static void unsubscribe(@NotNull @NotNull java.lang.String channel, @NotNull java.lang.String... moreChannels)
public static void subscribePattern(@NotNull @NotNull java.lang.String channelPattern, @NotNull java.lang.String... morePatterns)
public static void unsubscribePattern(@NotNull @NotNull java.lang.String channelPattern, @NotNull java.lang.String... morePatterns)
public static long publish(@NotNull @NotNull java.lang.String channel, @NotNull @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)
public static long publish(@NotNull @NotNull java.lang.String channel, @NotNull @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)
public static long publish(@NotNull @NotNull java.lang.String channel, @NotNull java.lang.Object... values)
public static io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull @NotNull java.lang.String channel, @NotNull @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)
public static io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull @NotNull java.lang.String channel, @NotNull @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)
public static io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull @NotNull java.lang.String channel, @NotNull java.lang.Object... values)
public static PreparedRedisRequest request(@NotNull @NotNull java.lang.String channel, @NotNull @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)
public static PreparedRedisRequest request(@NotNull @NotNull java.lang.String channel, @NotNull @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)
public static PreparedRedisRequest request(@NotNull @NotNull java.lang.String channel, @NotNull java.lang.Object... values)
public static void registerGlobalListener(@NotNull @NotNull RedisMessageListener listener, @NotNull RedisMessageListener... moreListeners)
public static void registerChannelListener(@NotNull @NotNull RedisMessageListener listener, @NotNull @NotNull java.lang.String channel, @NotNull java.lang.String... moreChannels)
public static void registerPatternListener(@NotNull @NotNull RedisMessageListener listener, @NotNull @NotNull java.lang.String channelPattern, @NotNull java.lang.String... morePatterns)
public static void registerChannels(@NotNull @NotNull java.lang.Class<?> channelClazz)
public static void unregisterChannels(@NotNull @NotNull java.lang.Class<?> channelClazz)
public static void registerChannel(@NotNull @NotNull RedisChannel channel)
public static void unregisterListener(@NotNull @NotNull RedisMessageListener listener)
Copyright © 2025. All rights reserved.