Java RedisClient类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了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；未经允许，请勿转载。