org.redisson.config.Config类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(11.6k)|赞(0)|评价(0)|浏览(847)

本文整理了Java中org.redisson.config.Config类的一些代码示例，展示了Config类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Config类的具体详情如下：
包路径：org.redisson.config.Config
类名称：Config

Config介绍

[英]Redisson configuration
[中]Redisson配置

代码示例

代码示例来源：origin: redisson/redisson

/**
 * Create Reactive Redisson instance with default config
 *
 * @return Redisson instance
 */
public static RedissonReactiveClient createReactive() {
  Config config = new Config();
  config.useSingleServer().setAddress("redis://127.0.0.1:6379");
  return createReactive(config);
}

代码示例来源：origin: redisson/redisson

protected RedissonClient buildClient() throws LifecycleException {
  Config config = null;
  try {
    config = Config.fromJSON(new File(configPath), getClass().getClassLoader());
  } catch (IOException e) {
    // trying next format
    try {
      config = Config.fromYAML(new File(configPath), getClass().getClassLoader());
    } catch (IOException e1) {
      log.error("Can't parse json config " + configPath, e);
      throw new LifecycleException("Can't parse yaml config " + configPath, e1);
    }
  }
  
  try {
    try {
    Config c = new Config(config);
    Codec codec = c.getCodec().getClass().getConstructor(ClassLoader.class)
            .newInstance(Thread.currentThread().getContextClassLoader());
    config.setCodec(codec);
    } catch (Exception e) {
      throw new IllegalStateException("Unable to initialize codec with ClassLoader parameter", e);
    }
    
    return Redisson.create(config);
  } catch (Exception e) {
    throw new LifecycleException(e);
  }
}

代码示例来源：origin: redisson/redisson

/**
 * Init cluster servers configuration
 *
 * @return config
 */
public ClusterServersConfig useClusterServers() {
  return useClusterServers(new ClusterServersConfig());
}

代码示例来源：origin: redisson/redisson

private Config loadConfig(String configPath) {
  try {
    return Config.fromJSON(new File(configPath));
  } catch (IOException e) {
    // trying next format
    try {
      return Config.fromYAML(new File(configPath));
    } catch (IOException e1) {
      throw new CacheException("Can't parse default yaml config", e1);
    }
  }
}

代码示例来源：origin: redisson/redisson

public Config(Config oldConf) {
  setExecutor(oldConf.getExecutor());
  if (oldConf.getCodec() == null) {
    oldConf.setCodec(new FstCodec());
  setUseScriptCache(oldConf.isUseScriptCache());
  setKeepPubSubOrder(oldConf.isKeepPubSubOrder());
  setLockWatchdogTimeout(oldConf.getLockWatchdogTimeout());
  setNettyThreads(oldConf.getNettyThreads());
  setThreads(oldConf.getThreads());
  setCodec(oldConf.getCodec());
  setReferenceEnabled(oldConf.isReferenceEnabled());
  setEventLoopGroup(oldConf.getEventLoopGroup());
  setTransportMode(oldConf.getTransportMode());
  setAddressResolverGroupFactory(oldConf.getAddressResolverGroupFactory());
  if (oldConf.getSingleServerConfig() != null) {
    setSingleServerConfig(new SingleServerConfig(oldConf.getSingleServerConfig()));
  if (oldConf.getMasterSlaveServersConfig() != null) {
    setMasterSlaveServersConfig(new MasterSlaveServersConfig(oldConf.getMasterSlaveServersConfig()));
  if (oldConf.getSentinelServersConfig() != null) {
    setSentinelServersConfig(new SentinelServersConfig(oldConf.getSentinelServersConfig()));
  if (oldConf.getClusterServersConfig() != null) {
    setClusterServersConfig(new ClusterServersConfig(oldConf.getClusterServersConfig()));

代码示例来源：origin: redisson/redisson

try {
    InputStream is = getConfigStream();
    config = Config.fromJSON(is);
  } catch (IOException e) {
      config = Config.fromYAML(is);
    } catch (IOException e1) {
      throw new IllegalArgumentException("Can't parse config", e1);
  config = new Config();
  config.useSentinelServers()
    .setMasterName(redisProperties.getSentinel().getMaster())
    .addSentinelAddress(nodes)
  config = new Config();
  config.useClusterServers()
    .addNodeAddress(nodes)
    .setConnectTimeout(timeout)
    .setPassword(redisProperties.getPassword());
} else {
  config = new Config();
  String prefix = "redis://";
  Method method = ReflectionUtils.findMethod(RedisProperties.class, "isSsl");
  config.useSingleServer()
    .setAddress(prefix + redisProperties.getHost() + ":" + redisProperties.getPort())
    .setConnectTimeout(timeout)

代码示例来源：origin: linux-china/spring-boot-starter-redisson

@Bean
  public RedissonClient redissonClient() {
    Config config = new Config();
    //sentinel
    if (redisProperties.getSentinel() != null) {
      SentinelServersConfig sentinelServersConfig = config.useSentinelServers();
      sentinelServersConfig.setMasterName(redisProperties.getSentinel().getMaster());
      redisProperties.getSentinel().getNodes();
      sentinelServersConfig.addSentinelAddress(redisProperties.getSentinel().getNodes().split(","));
      sentinelServersConfig.setDatabase(redisProperties.getDatabase());
      if (redisProperties.getPassword() != null) {
        sentinelServersConfig.setPassword(redisProperties.getPassword());
      }
    } else { //single server
      SingleServerConfig singleServerConfig = config.useSingleServer();
      // format as redis://127.0.0.1:7181 or rediss://127.0.0.1:7181 for SSL
      String schema = redisProperties.isSsl() ? "rediss://" : "redis://";
      singleServerConfig.setAddress(schema + redisProperties.getHost() + ":" + redisProperties.getPort());
      singleServerConfig.setDatabase(redisProperties.getDatabase());
      if (redisProperties.getPassword() != null) {
        singleServerConfig.setPassword(redisProperties.getPassword());
      }
    }
    return Redisson.create(config);
  }
}

代码示例来源：origin: huangjian888/jeeweb-mybatis-springboot

public RedissonClient getRedissonClient() {
  Config config = new Config();
  if (StringUtils.isNotBlank(address)) {
    SingleServerConfig serverConfig = config.useSingleServer().setAddress(address);
    if (StringUtils.isNotBlank(password)) {
      serverConfig.setPassword(password);
    }
    serverConfig.setTimeout(timeout);
  } else if (!nodeAddresses.isEmpty()) {
    ClusterServersConfig serverConfig = config.useClusterServers()
        .addNodeAddress(nodeAddresses.toArray(new String[] {}));
    if (StringUtils.isNotBlank(password)) {
      serverConfig.setPassword(password);
    }
    serverConfig.setTimeout(timeout);
  } else if (masterAddress != null && !slaveAddresses.isEmpty()) {
    MasterSlaveServersConfig serverConfig = config.useMasterSlaveServers().setMasterAddress(masterAddress)
        .addSlaveAddress(slaveAddresses.toArray(new String[] {}));
    if (StringUtils.isNotBlank(password)) {
      serverConfig.setPassword(password);
    }
    serverConfig.setTimeout(timeout);
  }
  return Redisson.create(config);
}

代码示例来源：origin: killbill/killbill

@Override
  public RedissonClient get() {
    // JDK serialization codec for now, but we can do better in speed and space
    final Codec codec = new SerializationCodec();

    final Config redissonCfg = new Config();
    redissonCfg.setCodec(codec)
          .useSingleServer()
          .setAddress(address)
          .setConnectionMinimumIdleSize(connectionMinimumIdleSize);
    return Redisson.create(redissonCfg);
  }
}

代码示例来源：origin: TaXueWWL/redis-distributed-lock

@Override
  public Config createRedissonConfig(String address) {
    Config config = new Config();
    try {
      String[] addrTokens = address.split(",");
      /**设置cluster节点的服务IP和端口*/
      for (int i = 0; i < addrTokens.length; i++) {
        config.useClusterServers()
            .addNodeAddress(GlobalConstant.REDIS_CONNECTION_PREFIX.getConstant_value() + addrTokens[i]);
      }
      LOGGER.info("初始化[cluster]方式Config,redisAddress:" + address);
    } catch (Exception e) {
      LOGGER.error("cluster Redisson init error", e);
      e.printStackTrace();
    }
    return config;
  }
}

代码示例来源：origin: zhegexiaohuozi/SeimiCrawler

public SeimiConfig() {
  this.redissonConfig = new Config();
}

代码示例来源：origin: kekingcn/spring-boot-klock-starter

@Bean(destroyMethod = "shutdown")
@ConditionalOnMissingBean
RedissonClient redisson() throws Exception {
  Config config = new Config();
  if(klockConfig.getClusterServer()!=null){
    config.useClusterServers().setPassword(klockConfig.getPassword())
        .addNodeAddress(klockConfig.getClusterServer().getNodeAddresses());
  }else {
    config.useSingleServer().setAddress(klockConfig.getAddress())
        .setDatabase(klockConfig.getDatabase())
        .setPassword(klockConfig.getPassword());
  }
  Codec codec=(Codec) ClassUtils.forName(klockConfig.getCodec(),ClassUtils.getDefaultClassLoader()).newInstance();
  config.setCodec(codec);
  config.setEventLoopGroup(new NioEventLoopGroup());
  return Redisson.create(config);
}

代码示例来源：origin: jsimone/webapp-runner

Config config = new Config();
SingleServerConfig serverConfig = config.useSingleServer()
  .setAddress(redisUriString)
  .setConnectionPoolSize(commandLineParams.sessionStorePoolSize)
  .setConnectionMinimumIdleSize(commandLineParams.sessionStorePoolSize)
  .setTimeout(commandLineParams.sessionStoreOperationTimout);
config.setCodec(new FstCodec());
 File configFile = File.createTempFile("redisson", ".json");
 try (BufferedWriter bw = new BufferedWriter(new FileWriter(configFile));) {
  bw.write(config.toJSON());
  RedissonSessionManager redisManager = new RedissonSessionManager();
  redisManager.setConfigPath(configFile.getAbsolutePath());

代码示例来源：origin: heibaiying/spring-samples-for-all

@Bean
public RedissonClient redissonClient() {
  Config config = new Config();
  config.setTransportMode(TransportMode.NIO);
  config.useSingleServer().setAddress("redis://127.0.0.1:6379");
  return Redisson.create(config);
}

代码示例来源：origin: TaXueWWL/redis-distributed-lock

@Override
  public Config createRedissonConfig(String address) {
    Config config = new Config();
    try {
      String[] addrTokens = address.split(",");
      String sentinelAliasName = addrTokens[0];
      /**设置redis配置文件sentinel.conf配置的sentinel别名*/
      config.useSentinelServers()
          .setMasterName(sentinelAliasName);
      /**设置sentinel节点的服务IP和端口*/
      for (int i = 1; i < addrTokens.length; i++) {
        config.useSentinelServers().addSentinelAddress(GlobalConstant.REDIS_CONNECTION_PREFIX.getConstant_value() + addrTokens[i]);
      }
      LOGGER.info("初始化[sentinel]方式Config,redisAddress:" + address);
    } catch (Exception e) {
      LOGGER.error("sentinel Redisson init error", e);
      e.printStackTrace();
    }
    return config;
  }
}

代码示例来源：origin: jzyong/game-server

/**
 * 连接服务器
 * 
 * @author JiangZhiYong
 * @QQ 359135103 2017年9月15日 下午3:36:06
 * @param configPath
 */
public static void connectRedis(String configPath) {
  if (redisson != null) {
    LOGGER.warn("Redisson客户端已经连接");
  }
  redissonClusterConfig = FileUtil.getConfigXML(configPath, "redissonClusterConfig.xml",
      RedissonClusterConfig.class);
  if (redissonClusterConfig == null) {
    LOGGER.warn("{}/redissonClusterConfig.xml文件不存在", configPath);
    System.exit(0);
  }
  Config config = new Config();
  config.setCodec(new FastJsonCodec());
  ClusterServersConfig clusterServersConfig = config.useClusterServers();
  clusterServersConfig.setScanInterval(redissonClusterConfig.getScanInterval()); // 集群状态扫描间隔时间，单位是毫秒
  // 可以用"rediss://"来启用SSL连接
  redissonClusterConfig.getNodes().forEach(url -> clusterServersConfig.addNodeAddress(url));
  clusterServersConfig.setReadMode(redissonClusterConfig.getReadMode());
  clusterServersConfig.setSubscriptionMode(redissonClusterConfig.getSubscriptionMode());
  redisson = Redisson.create(config);
}

代码示例来源：origin: redisson/redisson

/**
 * Init single server configuration.
 *
 * @return SingleServerConfig
 */
public SingleServerConfig useSingleServer() {
  return useSingleServer(new SingleServerConfig());
}

代码示例来源：origin: chexagon/redis-session-manager

@Override
protected final RedisSessionClient buildClient() throws ClassNotFoundException, InstantiationException, IllegalAccessException {
  Config config = new Config()
    .setCodec(new ContextClassloaderSerializationCodec(getContainerClassLoader()))
    .setTransportMode(isEpollSupported() ? TransportMode.EPOLL : TransportMode.NIO);
  return new RedissonSessionClient(configure(config));
}

代码示例来源：origin: debop/hibernate-redis

@PostConstruct
public void initialize() {
 Config config = new Config();
 ElasticacheServersConfig clusterConfig = config.useElasticacheServers();
 clusterConfig.setScanInterval(2000);
 clusterConfig.addNodeAddress(StringUtils.tokenizeToStringArray(redisNodes, ",", true, true));
 config.setCodec(new SnappyCodec());
 redisClient = Redisson.create(config);
}

代码示例来源：origin: debop/hibernate-redis

public static RedisClient createRedisClient(@NonNull final Config config) {
 try {
  if (config.getCodec() == null) {
   config.setCodec(new SnappyCodec());
  }
  log.debug("Set Redisson Codec = {}", config.getCodec().getClass().getName());
  RedissonClient redisson = Redisson.create(config);
  return new RedisClient(redisson);
 } catch (Exception e) {
  log.error("Fail to create RedisClient.", e);
  throw new RuntimeException(e);
 }
}

内容来源于网络，如有侵权，请联系作者删除！

Config

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Config类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com