程序包 net.oschina.j2cache.redis

类 RedisPubSubClusterPolicy

java.lang.Object
redis.clients.jedis.JedisPubSub
net.oschina.j2cache.redis.RedisPubSubClusterPolicy
所有已实现的接口:
ClusterPolicy
public class RedisPubSubClusterPolicy extends redis.clients.jedis.JedisPubSub implements ClusterPolicy
使用 Redis 的订阅和发布进行集群中的节点通知 该策略器使用 j2cache.properties 中的 redis 配置自行保持两个到 redis 的连接用于发布和订阅消息（并在失败时自动重连）
作者:
Winter Lau(javayou@gmail.com)

  • 构造器详细资料

    • RedisPubSubClusterPolicy

      public RedisPubSubClusterPolicy(String channel, Properties props)

  • 方法详细资料

    • isLocalCommand

      public boolean isLocalCommand(Command cmd)
      从接口复制的说明: ClusterPolicy
      判断是否本地实例的命令
      指定者:
      isLocalCommand 在接口中 ClusterPolicy
      参数:
      cmd - 命令信息
      返回:
      true if the cmd sent by self

    • evict

      public void evict(String region, String... keys)
      删除本地某个缓存条目
      指定者:
      evict 在接口中 ClusterPolicy
      参数:
      region - 区域名称
      keys - 缓存键值

    • clear

      public void clear(String region)
      清除本地整个缓存区域
      指定者:
      clear 在接口中 ClusterPolicy
      参数:
      region - 区域名称

    • connect

      public void connect(Properties props, CacheProviderHolder holder)
      加入 Redis 的发布订阅频道
      指定者:
      connect 在接口中 ClusterPolicy
      参数:
      props - j2cache 配置信息
      holder - Cache Provider Instance

    • disconnect

      public void disconnect()
      退出 Redis 发布订阅频道
      指定者:
      disconnect 在接口中 ClusterPolicy

    • publish

      public void publish(Command cmd)
      从接口复制的说明: ClusterPolicy
      发送消息
      指定者:
      publish 在接口中 ClusterPolicy
      参数:
      cmd - command to send

    • onMessage

      public void onMessage(String channel, String message)
      当接收到订阅频道获得的消息时触发此方法
      覆盖:
      onMessage 在类中 redis.clients.jedis.JedisPubSub
      参数:
      channel - 频道名称
      message - 消息体

    • unsubscribe

      public void unsubscribe()
      覆盖:
      unsubscribe 在类中 redis.clients.jedis.JedisPubSub