cc.carm.plugin.mineredis.api

接口 RedisMessageManager

所有已知子接口:

RedisManager

public interface RedisMessageManager

发布与订阅(Pub/Sub)管理器。

从以下版本开始:

1.1.0

方法概要

限定符和类型	方法和说明
PreparedRedisRequest	callback(@NotNull java.lang.String channel, @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)
PreparedRedisRequest	callback(@NotNull java.lang.String channel, @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)
default PreparedRedisRequest	callback(@NotNull java.lang.String channel, java.lang.Object... values)
long	publish(@NotNull java.lang.String channel, @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)
long	publish(@NotNull java.lang.String channel, @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)
default long	publish(@NotNull java.lang.String channel, java.lang.Object... values)
io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(@NotNull java.lang.String channel, @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)
io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(@NotNull java.lang.String channel, @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)
default io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(@NotNull java.lang.String channel, java.lang.Object... values)
default void	registerChannel(@NotNull RedisCallback<?,?,?> callback)
default void	registerChannel(@NotNull RedisChannel channel)
default void	registerChannel(@NotNull RedisRequest<?> request)
void	registerChannelListener(@NotNull RedisMessageListener listener, @NotNull java.lang.String channel, java.lang.String... moreChannels)
void	registerChannels(@NotNull java.lang.Class<?> channelClazz)
void	registerGlobalListener(@NotNull RedisMessageListener listener, RedisMessageListener... moreListeners)
void	registerPatternListener(@NotNull RedisMessageListener listener, @NotNull java.lang.String channelPattern, java.lang.String... morePatterns)
void	subscribe(@NotNull java.lang.String channel, java.lang.String... moreChannels) 订阅某些指定频道。
void	subscribePattern(@NotNull java.lang.String channelPattern, java.lang.String... morePatterns) 以模式匹配的方式订阅频道，支持使用“*”“?”
void	unregisterChannels(@NotNull java.lang.Class<?> channelClazz)
void	unregisterListener(@NotNull RedisMessageListener listener)
void	unsubscribe(@NotNull java.lang.String channel, java.lang.String... moreChannels) 取消订阅某些指定频道。
void	unsubscribePattern(@NotNull java.lang.String channelPattern, java.lang.String... morePatterns) 取消以模式匹配的方式订阅频道，支持使用“*”“?”
static void	writeParam(com.google.common.io.ByteArrayDataOutput data, java.lang.Object value)
static void	writeParams(com.google.common.io.ByteArrayDataOutput data, java.util.List<java.lang.Object> params)

方法详细资料

subscribe

void subscribe(@NotNull
               @NotNull java.lang.String channel,
               @NotNull
               java.lang.String... moreChannels)

订阅某些指定频道。
订阅后，本端将接收该频道中的消息，并触发对应的Handler。

参数:

channel - 频道名

moreChannels - 频道名

unsubscribe

void unsubscribe(@NotNull
                 @NotNull java.lang.String channel,
                 @NotNull
                 java.lang.String... moreChannels)

取消订阅某些指定频道。
取消订阅后，本端将不再接收该频道中的消息。

参数:

channel - 频道名

moreChannels - 频道名

subscribePattern

void subscribePattern(@NotNull
                      @NotNull java.lang.String channelPattern,
                      @NotNull
                      java.lang.String... morePatterns)

以模式匹配的方式订阅频道，支持使用“*”“?”等符号。
订阅后，本端将接收相关频道中的消息，并触发对应的Handler。

参数:

channelPattern - 频道条件

morePatterns - 频道条件

unsubscribePattern

void unsubscribePattern(@NotNull
                        @NotNull java.lang.String channelPattern,
                        @NotNull
                        java.lang.String... morePatterns)

取消以模式匹配的方式订阅频道，支持使用“*”“?”等符号。
取消订阅后，本端将不再接收相关频道中的消息。

参数:

channelPattern - 频道条件

morePatterns - 频道条件

publish

long publish(@NotNull
             @NotNull java.lang.String channel,
             @NotNull
             @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)

publish

long publish(@NotNull
             @NotNull java.lang.String channel,
             @NotNull
             @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)

publish

default long publish(@NotNull
                     @NotNull java.lang.String channel,
                     @NotNull
                     java.lang.Object... values)

publishAsync

io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull
                                                         @NotNull java.lang.String channel,
                                                         @NotNull
                                                         @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)

publishAsync

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)

publishAsync

default io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull
                                                                 @NotNull java.lang.String channel,
                                                                 @NotNull
                                                                 java.lang.Object... values)

callback

PreparedRedisRequest callback(@NotNull
                              @NotNull java.lang.String channel,
                              @NotNull
                              @NotNull com.google.common.io.ByteArrayDataOutput byteOutput)

callback

PreparedRedisRequest callback(@NotNull
                              @NotNull java.lang.String channel,
                              @NotNull
                              @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> byteOutput)

callback

default PreparedRedisRequest callback(@NotNull
                                      @NotNull java.lang.String channel,
                                      @NotNull
                                      java.lang.Object... values)

registerGlobalListener

void registerGlobalListener(@NotNull
                            @NotNull RedisMessageListener listener,
                            @NotNull
                            RedisMessageListener... moreListeners)

registerChannelListener

void registerChannelListener(@NotNull
                             @NotNull RedisMessageListener listener,
                             @NotNull
                             @NotNull java.lang.String channel,
                             @NotNull
                             java.lang.String... moreChannels)

registerPatternListener

void registerPatternListener(@NotNull
                             @NotNull RedisMessageListener listener,
                             @NotNull
                             @NotNull java.lang.String channelPattern,
                             @NotNull
                             java.lang.String... morePatterns)

unregisterListener

void unregisterListener(@NotNull
                        @NotNull RedisMessageListener listener)

registerChannels

void registerChannels(@NotNull
                      @NotNull java.lang.Class<?> channelClazz)

unregisterChannels

void unregisterChannels(@NotNull
                        @NotNull java.lang.Class<?> channelClazz)

registerChannel

default void registerChannel(@NotNull
                             @NotNull RedisChannel channel)

registerChannel

default void registerChannel(@NotNull
                             @NotNull RedisRequest<?> request)

registerChannel

default void registerChannel(@NotNull
                             @NotNull RedisCallback<?,?,?> callback)

writeParams

static void writeParams(com.google.common.io.ByteArrayDataOutput data,
                        java.util.List<java.lang.Object> params)

writeParam

static void writeParam(com.google.common.io.ByteArrayDataOutput data,
                       java.lang.Object value)