接口 ClusterPolicy

所有已知实现类:
JGroupsClusterPolicy, LettuceCacheProvider, NoneClusterPolicy, RabbitMQClusterPolicy, RedisPubSubClusterPolicy, RocketMQClusterPolicy

public interface ClusterPolicy
缓存集群策略接口
作者:
Winter Lau(javayou@gmail.com)
  • 字段详细资料

    • log

      static final org.slf4j.Logger log
  • 方法详细资料

    • connect

      void connect(Properties props, CacheProviderHolder holder)
      连接到集群
      参数:
      props - j2cache 配置信息
      holder - Cache Provider Instance
    • publish

      void publish(Command cmd)
      发送消息
      参数:
      cmd - command to send
    • sendEvictCmd

      default void sendEvictCmd(String region, String... keys)
      发送清除缓存的命令
      参数:
      region - 区域名称
      keys - 缓存键值
    • sendClearCmd

      default void sendClearCmd(String region)
      发送清除整个缓存区域的命令
      参数:
      region - 区域名称
    • disconnect

      void disconnect()
      断开集群连接
    • evict

      void evict(String region, String... keys)
      删除本地某个缓存条目
      参数:
      region - 区域名称
      keys - 缓存键值
    • clear

      void clear(String region)
      清除本地整个缓存区域
      参数:
      region - 区域名称
    • isLocalCommand

      boolean isLocalCommand(Command cmd)
      判断是否本地实例的命令
      参数:
      cmd - 命令信息
      返回:
      true if the cmd sent by self
    • handleCommand

      default void handleCommand(Command cmd)
      处理缓存事件逻辑
      参数:
      cmd - the received command