com.alibaba.csp.sentinel.datasource.redis

类 RedisDataSource<T>

java.lang.Object

com.alibaba.csp.sentinel.datasource.AbstractDataSource<String,T>

com.alibaba.csp.sentinel.datasource.redis.RedisDataSource<T>

所有已实现的接口:

ReadableDataSource<String,T>

public class RedisDataSource<T>
extends AbstractDataSource<String,T>

A read-only DataSource with Redis backend.

The data source first loads initial rules from a Redis String during initialization. Then the data source subscribe from specific channel. When new rules is published to the channel, the data source will observe the change in realtime and update to memory.

Note that for consistency, users should publish the value and save the value to the ruleKey simultaneously like this (using Redis transaction):

  MULTI
  SET ruleKey value
  PUBLISH channel value
  EXEC
 

作者:

tiger

字段概要

从类继承的字段 com.alibaba.csp.sentinel.datasource.AbstractDataSource

parser, property

构造器概要

构造器

构造器和说明
RedisDataSource(RedisConnectionConfig connectionConfig, String ruleKey, String channel, Converter<String,T> parser) Constructor of RedisDataSource.

方法概要

限定符和类型	方法和说明
void	close()
String	readSource()

从类继承的方法 com.alibaba.csp.sentinel.datasource.AbstractDataSource

getProperty, loadConfig, loadConfig

从类继承的方法 java.lang.Object

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

构造器详细资料

RedisDataSource

public RedisDataSource(RedisConnectionConfig connectionConfig,
                       String ruleKey,
                       String channel,
                       Converter<String,T> parser)

Constructor of RedisDataSource.

参数:

connectionConfig - Redis connection config

ruleKey - data key in Redis

channel - channel to subscribe in Redis

parser - customized data parser, cannot be empty

方法详细资料

readSource

public String readSource()

close

public void close()