wiki.xsx.core.handler

Class PubSubHandler

java.lang.Object

wiki.xsx.core.handler.PubSubHandler

All Implemented Interfaces:

RedisHandler

public final class PubSubHandler
extends Object
implements RedisHandler

发布与订阅助手

Since:

1.8

Author:

xsx

Method Summary

Modifier and Type	Method and Description
void	addPSubChannels(String... patterns) 添加给定模式字符串订阅频道
void	addSubChannels(String... channels) 添加字符串订阅频道
<T> T	deserialize(byte[] bytes) 反序列化
<T> T	deserialize(Class<T> type, byte[] bytes) 反序列化
List<String>	getChannels() 获取订阅频道
List<String>	getPatterns() 获取订阅模式
org.springframework.data.redis.core.RedisTemplate<String,Object>	getRedisTemplate() 获取spring redis模板
void	pSubscribe(org.springframework.data.redis.connection.MessageListener listener, String... patterns) 订阅给定模式的频道
void	publish(String channel, Object message) 发布消息
void	pUnsubscribe(String... patterns) 退订给定模式频道
void	subscribe(org.springframework.data.redis.connection.MessageListener listener, String... channels) 订阅频道
void	unsubscribe(String... channels) 退订频道

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

publish

public void publish(String channel,
                    Object message)

发布消息

Parameters:

channel - 频道

message - 消息

Since:

redis 2.0.0

See Also:

Redis Documentation: PUBLISH

subscribe

public void subscribe(org.springframework.data.redis.connection.MessageListener listener,
                      String... channels)

订阅频道

Parameters:

listener - 监听器

channels - 频道

Since:

redis 2.0.0

See Also:

Redis Documentation: SUBSCRIBE

pSubscribe

public void pSubscribe(org.springframework.data.redis.connection.MessageListener listener,
                       String... patterns)

订阅给定模式的频道

Parameters:

listener - 监听器

patterns - 模式

Since:

redis 2.0.0

See Also:

Redis Documentation: PSUBSCRIBE

addSubChannels

public void addSubChannels(String... channels)

添加字符串订阅频道

Parameters:

channels - 频道

Since:

redis 2.0.0

addPSubChannels

public void addPSubChannels(String... patterns)

添加给定模式字符串订阅频道

Parameters:

patterns - 模式

Since:

redis 2.0.0

unsubscribe

public void unsubscribe(String... channels)

退订频道

Parameters:

channels - 频道

Since:

redis 2.0.0

See Also:

Redis Documentation: UNSUBSCRIBE

pUnsubscribe

public void pUnsubscribe(String... patterns)

退订给定模式频道

Parameters:

patterns - 模式

Since:

redis 2.0.0

See Also:

Redis Documentation: PUNSUBSCRIBE

getChannels

public List<String> getChannels()

获取订阅频道

Returns:

返回频道列表

Since:

redis 2.0.0

getPatterns

public List<String> getPatterns()

获取订阅模式

Returns:

返回模式列表

Since:

redis 2.0.0

deserialize

public <T> T deserialize(byte[] bytes)

反序列化

Type Parameters:

T - 返回类型

Parameters:

bytes - 字节数组

Returns:

返回对象

deserialize

public <T> T deserialize(Class<T> type,
                         byte[] bytes)

反序列化

Type Parameters:

T - 返回类型

Parameters:

type - 返回值类型

bytes - 字节数组

Returns:

返回对象

getRedisTemplate

public org.springframework.data.redis.core.RedisTemplate<String,Object> getRedisTemplate()

获取spring redis模板

Returns:

返回对象模板