本文整理汇总了Java中io.lettuce.core.RedisClient类的典型用法代码示例。如果您正苦于以下问题:Java RedisClient类的具体用法?Java RedisClient怎么用?Java RedisClient使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RedisClient类属于io.lettuce.core包,在下文中一共展示了RedisClient类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: Database
import io.lettuce.core.RedisClient; //导入依赖的package包/类
public Database(String serverID, String hostname, String password, int port, int dbnumber) {
this.serverID = serverID;
RedisURI redisURI = RedisURI.builder()
.withHost(hostname)
.withPassword(password)
.withPort(port)
.withDatabase(dbnumber)
.withClientName("rmanager-" + serverID)
.build();
redisClient = RedisClient.create(redisURI);
syncCommands = redisClient.connect().sync();
new RedisMessenger(serverID, redisURI);
}
开发者ID:RedEpicness,项目名称:RManager,代码行数:18,代码来源:Database.java
示例2: sync
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void sync() {
RedisClient client = RedisClient.create("redis://localhost");
StatefulRedisConnection<String, String> connection =
new TracingStatefulRedisConnection<>(client.connect(), mockTracer, false);
RedisCommands<String, String> commands = connection.sync();
assertEquals("OK", commands.set("key", "value"));
assertEquals("value", commands.get("key"));
connection.close();
client.shutdown();
List<MockSpan> spans = mockTracer.finishedSpans();
assertEquals(2, spans.size());
}
开发者ID:opentracing-contrib,项目名称:java-redis-client,代码行数:19,代码来源:TracingLettuceTest.java
示例3: start
import io.lettuce.core.RedisClient; //导入依赖的package包/类
private void start() {
DefaultClientResources clientResources = DefaultClientResources.builder() //
.dnsResolver( new DirContextDnsResolver() ) // Does not cache DNS lookups (needed for ElasticCache)
.build();
redisClient = RedisClient.create( clientResources, server );
connection = redisClient.connect();
asyncCommands = connection.async();
reactiveCommands = connection.reactive();
/*
* Run the global clean up scheduler,
* which cleans expired keys from all regions in the Redis instance in background
*/
runGlobalCleanupScheduler();
if ( cfEngine.thisPlatform != null )
cfEngine.log( getName() + " server: " + server + "; WaitTimeSeconds: " + waitTimeSeconds );
}
开发者ID:OpenBD,项目名称:openbd-core,代码行数:20,代码来源:RedisCacheImpl.java
示例4: connection
import io.lettuce.core.RedisClient; //导入依赖的package包/类
public StatefulConnection connection(AbstractRedisClient redisClient) {
LettuceObjects lo = getLettuceObjectsFromMap(redisClient);
if (lo.connection == null) {
if (redisClient instanceof RedisClient) {
lo.connection = ((RedisClient) redisClient).connect(new JetCacheCodec());
} else if (redisClient instanceof RedisClusterClient) {
lo.connection = ((RedisClusterClient) redisClient).connect(new JetCacheCodec());
} else {
throw new CacheConfigException("type " + redisClient.getClass() + " is not supported");
}
}
return lo.connection;
}
开发者ID:alibaba,项目名称:jetcache,代码行数:14,代码来源:LettuceConnectionManager.java
示例5: test
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void test() {
RedisClient client = RedisClient.create("redis://127.0.0.1");
LettuceConnectionManager m = LettuceConnectionManager.defaultManager();
Assert.assertSame(m.commands(client), m.commands(client));
Assert.assertSame(m.asyncCommands(client), m.asyncCommands(client));
Assert.assertSame(m.reactiveCommands(client), m.reactiveCommands(client));
m.removeAndClose(client);
}
开发者ID:alibaba,项目名称:jetcache,代码行数:10,代码来源:LettuceConnectionManagerTest.java
示例6: testSentinel
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void testSentinel() throws Exception {
RedisURI redisUri = RedisURI.Builder
.sentinel("127.0.0.1", 26379, "mymaster")
.withSentinel("127.0.0.1", 26380)
.withSentinel("127.0.0.1", 26381)
.build();
RedisClient client = RedisClient.create(redisUri);
test(client);
}
开发者ID:alibaba,项目名称:jetcache,代码行数:11,代码来源:RedisLettuceCacheTest.java
示例7: testWithMultiLevelCache
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void testWithMultiLevelCache() throws Exception {
Cache l1Cache = CaffeineCacheBuilder.createCaffeineCacheBuilder()
.limit(10)
.expireAfterWrite(500, TimeUnit.MILLISECONDS)
.keyConvertor(FastjsonKeyConvertor.INSTANCE)
.buildCache();
RedisClient client = RedisClient.create("redis://127.0.0.1");
Cache l2Cache = RedisLettuceCacheBuilder.createRedisLettuceCacheBuilder()
.redisClient(client)
.keyConvertor(FastjsonKeyConvertor.INSTANCE)
.valueEncoder(JavaValueEncoder.INSTANCE)
.valueDecoder(JavaValueDecoder.INSTANCE)
.keyPrefix(new Random().nextInt() + "")
.expireAfterWrite(500, TimeUnit.MILLISECONDS)
.buildCache();
cache = MultiLevelCacheBuilder.createMultiLevelCacheBuilder()
.expireAfterWrite(500, TimeUnit.MILLISECONDS)
.addCache(l1Cache, l2Cache)
.buildCache();
baseTest();
expireAfterWriteTest(500);
LoadingCacheTest.loadingCacheTest(MultiLevelCacheBuilder.createMultiLevelCacheBuilder()
.expireAfterWrite(5000, TimeUnit.MILLISECONDS)
.addCache(l1Cache, l2Cache), 50);
}
开发者ID:alibaba,项目名称:jetcache,代码行数:28,代码来源:RedisLettuceCacheTest.java
示例8: testUnwrap
import io.lettuce.core.RedisClient; //导入依赖的package包/类
private void testUnwrap(AbstractRedisClient client) {
Assert.assertTrue(cache.unwrap(AbstractRedisClient.class) instanceof AbstractRedisClient);
if (client instanceof RedisClient) {
Assert.assertTrue(cache.unwrap(RedisClient.class) instanceof RedisClient);
Assert.assertTrue(cache.unwrap(RedisCommands.class) instanceof RedisCommands);
Assert.assertTrue(cache.unwrap(RedisAsyncCommands.class) instanceof RedisAsyncCommands);
Assert.assertTrue(cache.unwrap(RedisReactiveCommands.class) instanceof RedisReactiveCommands);
} else {
Assert.assertTrue(cache.unwrap(RedisClusterClient.class) instanceof RedisClusterClient);
Assert.assertTrue(cache.unwrap(RedisClusterCommands.class) instanceof RedisClusterCommands);
Assert.assertTrue(cache.unwrap(RedisClusterAsyncCommands.class) instanceof RedisClusterAsyncCommands);
Assert.assertTrue(cache.unwrap(RedisClusterReactiveCommands.class) instanceof RedisClusterReactiveCommands);
}
}
开发者ID:alibaba,项目名称:jetcache,代码行数:15,代码来源:RedisLettuceCacheTest.java
示例9: tests
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void tests() throws Exception {
if (RedisLettuceCacheTest.checkOS()) {
System.setProperty("spring.profiles.active", "redislettuce-cluster");
} else {
System.setProperty("spring.profiles.active", "redislettuce");
}
context = SpringApplication.run(RedisLettuceStarterTest.class);
doTest();
A bean = context.getBean(A.class);
bean.test();
RedisClient t1 = (RedisClient) context.getBean("defaultClient");
RedisClient t2 = (RedisClient) context.getBean("a1Client");
Assert.assertNotNull(t1);
Assert.assertNotNull(t2);
Assert.assertNotSame(t1, t2);
AutoConfigureBeans acb = context.getBean(AutoConfigureBeans.class);
String key = "remote.A1";
Assert.assertTrue(new LettuceFactory(acb, key, StatefulRedisConnection.class).getObject() instanceof StatefulRedisConnection);
Assert.assertTrue(new LettuceFactory(acb, key, RedisCommands.class).getObject() instanceof RedisCommands);
Assert.assertTrue(new LettuceFactory(acb, key, RedisAsyncCommands.class).getObject() instanceof RedisAsyncCommands);
Assert.assertTrue(new LettuceFactory(acb, key, RedisReactiveCommands.class).getObject() instanceof RedisReactiveCommands);
if (RedisLettuceCacheTest.checkOS()) {
key = "remote.A2";
Assert.assertTrue(new LettuceFactory(acb, key , RedisClusterClient.class).getObject() instanceof RedisClusterClient);
Assert.assertTrue(new LettuceFactory(acb, key , RedisClusterCommands.class).getObject() instanceof RedisClusterCommands);
Assert.assertTrue(new LettuceFactory(acb, key , RedisClusterAsyncCommands.class).getObject() instanceof RedisClusterAsyncCommands);
Assert.assertTrue(new LettuceFactory(acb, key , RedisClusterReactiveCommands.class).getObject() instanceof RedisClusterReactiveCommands);
}
}
开发者ID:alibaba,项目名称:jetcache,代码行数:35,代码来源:RedisLettuceStarterTest.java
示例10: initCache
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Override
protected CacheBuilder initCache(ConfigTree ct, String cacheAreaWithPrefix) {
Map<String, Object> map = ct.subTree("uri"/*there is no dot*/).getProperties();
AbstractRedisClient client = null;
if (map == null || map.size() == 0) {
throw new CacheConfigException("uri is required");
} else if (map.size() == 1) {
String uri = (String) map.values().iterator().next();
client = RedisClient.create(uri);
} else {
List<RedisURI> list = map.values().stream().map((k) -> RedisURI.create(URI.create(k.toString())))
.collect(Collectors.toList());
client = RedisClusterClient.create(list);
}
ExternalCacheBuilder externalCacheBuilder = RedisLettuceCacheBuilder.createRedisLettuceCacheBuilder()
.redisClient(client);
parseGeneralConfig(externalCacheBuilder, ct);
// eg: "remote.default.client"
autoConfigureBeans.getCustomContainer().put(cacheAreaWithPrefix + ".client", client);
LettuceConnectionManager m = LettuceConnectionManager.defaultManager();
autoConfigureBeans.getCustomContainer().put(cacheAreaWithPrefix + ".connection", m.connection(client));
autoConfigureBeans.getCustomContainer().put(cacheAreaWithPrefix + ".commands", m.commands(client));
autoConfigureBeans.getCustomContainer().put(cacheAreaWithPrefix + ".asyncCommands", m.asyncCommands(client));
autoConfigureBeans.getCustomContainer().put(cacheAreaWithPrefix + ".reactiveCommands", m.reactiveCommands(client));
return externalCacheBuilder;
}
开发者ID:alibaba,项目名称:jetcache,代码行数:29,代码来源:RedisLettuceAutoConfiguration.java
示例11: initialize
import io.lettuce.core.RedisClient; //导入依赖的package包/类
public void initialize(Bootstrap<Configuration> bootstrap) {
redisClient = RedisClient.create("redis://localhost");
RequestRateLimiterFactory factory = new RedisRateLimiterFactory(redisClient);
//RequestRateLimiterFactory factory = new InMemoryRateLimiterFactory();
bootstrap.addBundle(new RateLimitBundle(factory));
}
开发者ID:mokies,项目名称:ratelimitj,代码行数:9,代码来源:RateLimitApplication.java
示例12: testSimple
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void testSimple() throws Exception {
RedisClient client = RedisClient.create("redis://127.0.0.1");
test(client);
}
开发者ID:alibaba,项目名称:jetcache,代码行数:6,代码来源:RedisLettuceCacheTest.java
示例13: test
import io.lettuce.core.RedisClient; //导入依赖的package包/类
public void test() {
Assert.assertNotNull(c1.unwrap(RedisClient.class));
RedisLettuceCacheConfig cc1 = (RedisLettuceCacheConfig) c1.config();
Assert.assertEquals(20000, cc1.getExpireAfterWriteInMillis());
Assert.assertSame(FastjsonKeyConvertor.INSTANCE, cc1.getKeyConvertor());
}
开发者ID:alibaba,项目名称:jetcache,代码行数:7,代码来源:RedisLettuceStarterTest.java
示例14: defaultClient
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Bean(name = "defaultClient")
@DependsOn(RedisLettuceAutoConfiguration.AUTO_INIT_BEAN_NAME)
public LettuceFactory defaultClient() {
return new LettuceFactory("remote.default", RedisClient.class);
}
开发者ID:alibaba,项目名称:jetcache,代码行数:6,代码来源:RedisLettuceStarterTest.java
示例15: a1Client
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Bean(name = "a1Client")
@DependsOn(RedisLettuceAutoConfiguration.AUTO_INIT_BEAN_NAME)
public LettuceFactory a1Client() {
return new LettuceFactory("remote.A1", RedisClient.class);
}
开发者ID:alibaba,项目名称:jetcache,代码行数:6,代码来源:RedisLettuceStarterTest.java
示例16: async
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@Test
public void async() throws Exception {
RedisClient client = RedisClient.create("redis://localhost");
StatefulRedisConnection<String, String> connection =
new TracingStatefulRedisConnection<>(client.connect(), mockTracer, false);
RedisAsyncCommands<String, String> commands = connection.async();
assertEquals("OK", commands.set("key2", "value2").get(15, TimeUnit.SECONDS));
assertEquals("value2", commands.get("key2").get(15, TimeUnit.SECONDS));
connection.close();
client.shutdown();
List<MockSpan> spans = mockTracer.finishedSpans();
assertEquals(2, spans.size());
}
开发者ID:opentracing-contrib,项目名称:java-redis-client,代码行数:21,代码来源:TracingLettuceTest.java
示例17: RedisRateLimiterFactory
import io.lettuce.core.RedisClient; //导入依赖的package包/类
public RedisRateLimiterFactory(RedisClient client) {
this.client = requireNonNull(client);
}
开发者ID:mokies,项目名称:ratelimitj,代码行数:4,代码来源:RedisRateLimiterFactory.java
示例18: beforeAll
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@BeforeAll
static void beforeAll() {
client = RedisClient.create("redis://localhost");
connection = client.connect();
}
开发者ID:mokies,项目名称:ratelimitj,代码行数:6,代码来源:RedisScriptLoaderTest.java
示例19: beforeAll
import io.lettuce.core.RedisClient; //导入依赖的package包/类
@BeforeAll
static void beforeAll() {
client = RedisClient.create("redis://localhost");
connect = client.connect();
}
开发者ID:mokies,项目名称:ratelimitj,代码行数:6,代码来源:RedisSlidingWindowSyncRequestRateLimiterTest.java
示例20: SessionStorageRedisCacheImpl
import io.lettuce.core.RedisClient; //导入依赖的package包/类
public SessionStorageRedisCacheImpl( String appName, String _connectionUri ) throws Exception {
super( "session:" + appName + ":" );
this.uri = _connectionUri;
DefaultClientResources clientResources = DefaultClientResources.builder() //
.dnsResolver( new DirContextDnsResolver() ) // Does not cache DNS lookups (needed for ElasticCache)
.build();
rediscache = RedisClient.create( clientResources, _connectionUri );
connection = rediscache.connect();
asyncCommands = connection.async();
cfEngine.log( "SessionStorageRedisCache: Created " + _connectionUri );
}
开发者ID:OpenBD,项目名称:openbd-core,代码行数:17,代码来源:SessionStorageRedisCacheImpl.java
注:本文中的io.lettuce.core.RedisClient类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论