Java 类redis.clients.jedis.exceptions.InvalidURIException 实例源码

项目：JRediClients 文件：JedisFactory.java

public JedisFactory(final URI uri, final int connectionTimeout, final int soTimeout, final String clientName,
        final boolean ssl, final SSLSocketFactory sslSocketFactory, final SSLParameters sslParameters,
        final HostnameVerifier hostnameVerifier) {
    if (!JedisURIHelper.isValid(uri)) {
        throw new InvalidURIException(
                String.format("Cannot open Redis connection due invalid URI. %s", uri.toString()));
    }

    this.hostAndPort.set(new HostAndPort(uri.getHost(), uri.getPort()));
    this.connectionTimeout = connectionTimeout;
    this.soTimeout = soTimeout;
    this.password = JedisURIHelper.getPassword(uri);
    this.database = JedisURIHelper.getDBIndex(uri);
    this.clientName = clientName;
    this.ssl = ssl;
    this.sslSocketFactory = sslSocketFactory;
    this.sslParameters = sslParameters;
    this.hostnameVerifier = hostnameVerifier;
}

项目：JRediClients 文件：JedisShardInfo.java

public JedisShardInfo(URI uri, SSLSocketFactory sslSocketFactory, SSLParameters sslParameters,
        HostnameVerifier hostnameVerifier) {
    super(Sharded.DEFAULT_WEIGHT);
    if (!JedisURIHelper.isValid(uri)) {
        throw new InvalidURIException(
                String.format("Cannot open Redis connection due invalid URI. %s", uri.toString()));
    }

    this.host = uri.getHost();
    this.port = uri.getPort();
    this.password = JedisURIHelper.getPassword(uri);
    this.db = JedisURIHelper.getDBIndex(uri);
    this.ssl = uri.getScheme().equals("rediss");
    this.sslSocketFactory = sslSocketFactory;
    this.sslParameters = sslParameters;
    this.hostnameVerifier = hostnameVerifier;
}

项目：x7 文件：BinaryJedis.java

private void initializeClientFromURI(URI uri) {
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  client = new Client(uri.getHost(), uri.getPort());

  String password = JedisURIHelper.getPassword(uri);
  if (password != null) {
    client.auth(password);
    client.getStatusCodeReply();
  }

  int dbIndex = JedisURIHelper.getDBIndex(uri);
  if (dbIndex > 0) {
    client.select(dbIndex);
    client.getStatusCodeReply();
    client.setDb(dbIndex);
  }
}

项目：cachecloud 文件：BinaryJedis.java

private void initializeClientFromURI(URI uri) {
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  client = new Client(uri.getHost(), uri.getPort());

  String password = JedisURIHelper.getPassword(uri);
  if (password != null) {
    client.auth(password);
    client.getStatusCodeReply();
  }

  int dbIndex = JedisURIHelper.getDBIndex(uri);
  if (dbIndex > 0) {
    client.select(dbIndex);
    client.getStatusCodeReply();
    client.setDb(dbIndex);
  }
}

项目：Jedis 文件：BinaryJedis.java

private void initializeClientFromURI(URI uri) {
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  client = new Client(uri.getHost(), uri.getPort());

  String password = JedisURIHelper.getPassword(uri);
  if (password != null) {
    client.auth(password);
    client.getStatusCodeReply();
  }

  int dbIndex = JedisURIHelper.getDBIndex(uri);
  if (dbIndex > 0) {
    client.select(dbIndex);
    client.getStatusCodeReply();
    client.setDb(dbIndex);
  }
}

项目：nighthawk 文件：JaRedisFactory.java

public JaRedisFactory(final URI uri, final int connectionTimeout, final int soTimeout,
                      final String clientName) {
    if (!JedisURIHelper.isValid(uri)) {
        throw new InvalidURIException(String.format(
                "Cannot open Redis connection due invalid URI. %s", uri.toString()));
    }
    this.hostAndPort.set(new HostAndPort(uri.getHost(), uri.getPort()));
    this.connectionTimeout = connectionTimeout;
    this.soTimeout = soTimeout;
    this.password = JedisURIHelper.getPassword(uri);
    this.database = JedisURIHelper.getDBIndex(uri);
    this.clientName = clientName;
}

项目：JRediClients 文件：JedisShardInfo.java

public JedisShardInfo(URI uri) {
    super(Sharded.DEFAULT_WEIGHT);
    if (!JedisURIHelper.isValid(uri)) {
        throw new InvalidURIException(
                String.format("Cannot open Redis connection due invalid URI. %s", uri.toString()));
    }

    this.host = uri.getHost();
    this.port = uri.getPort();
    this.password = JedisURIHelper.getPassword(uri);
    this.db = JedisURIHelper.getDBIndex(uri);
    this.ssl = uri.getScheme().equals("rediss");
}

项目：x7 文件：JedisFactory.java

public JedisFactory(final URI uri, final int connectionTimeout, final int soTimeout,
    final String clientName) {
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  this.hostAndPort.set(new HostAndPort(uri.getHost(), uri.getPort()));
  this.connectionTimeout = connectionTimeout;
  this.soTimeout = soTimeout;
  this.password = JedisURIHelper.getPassword(uri);
  this.database = JedisURIHelper.getDBIndex(uri);
  this.clientName = clientName;
}

项目：x7 文件：JedisShardInfo.java

public JedisShardInfo(URI uri) {
  super(Sharded.DEFAULT_WEIGHT);
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  this.host = uri.getHost();
  this.port = uri.getPort();
  this.password = JedisURIHelper.getPassword(uri);
  this.db = JedisURIHelper.getDBIndex(uri);
}

项目：cachecloud 文件：JedisFactory.java

public JedisFactory(final URI uri, final int connectionTimeout, final int soTimeout,
    final String clientName) {
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  this.hostAndPort.set(new HostAndPort(uri.getHost(), uri.getPort()));
  this.connectionTimeout = connectionTimeout;
  this.soTimeout = soTimeout;
  this.password = JedisURIHelper.getPassword(uri);
  this.database = JedisURIHelper.getDBIndex(uri);
  this.clientName = clientName;
}

项目：cachecloud 文件：JedisShardInfo.java

public JedisShardInfo(URI uri) {
  super(Sharded.DEFAULT_WEIGHT);
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  this.host = uri.getHost();
  this.port = uri.getPort();
  this.password = JedisURIHelper.getPassword(uri);
  this.db = JedisURIHelper.getDBIndex(uri);
}

项目：jahhan 文件：JedisFactory.java

public JedisFactory(final URI uri, final int connectionTimeout, final String clientName) {
    if (!JedisURIHelper.isValid(uri)) {
        throw new InvalidURIException(
                String.format("Cannot open Redis connection due invalid URI. %s", uri.toString()));
    }

    this.hostAndPort.set(new HostAndPort(uri.getHost(), uri.getPort()));
    this.connectionTimeout = connectionTimeout;
    this.password = JedisURIHelper.getPassword(uri);
    this.database = JedisURIHelper.getDBIndex(uri);
    this.clientName = clientName;
}

项目：Jedis 文件：JedisFactory.java

public JedisFactory(final URI uri, final int connectionTimeout, final int soTimeout,
    final String clientName) {
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  this.hostAndPort.set(new HostAndPort(uri.getHost(), uri.getPort()));
  this.connectionTimeout = connectionTimeout;
  this.soTimeout = soTimeout;
  this.password = JedisURIHelper.getPassword(uri);
  this.database = JedisURIHelper.getDBIndex(uri);
  this.clientName = clientName;
}

项目：Jedis 文件：JedisShardInfo.java

public JedisShardInfo(URI uri) {
  super(Sharded.DEFAULT_WEIGHT);
  if (!JedisURIHelper.isValid(uri)) {
    throw new InvalidURIException(String.format(
      "Cannot open Redis connection due invalid URI. %s", uri.toString()));
  }

  this.host = uri.getHost();
  this.port = uri.getPort();
  this.password = JedisURIHelper.getPassword(uri);
  this.db = JedisURIHelper.getDBIndex(uri);
}

项目：JRediClients 文件：JedisPoolTest.java

@Test(expected = InvalidURIException.class)
public void shouldThrowInvalidURIExceptionForInvalidURI() throws URISyntaxException {
  JedisPool pool = new JedisPool(new URI("localhost:6380"));
}

项目：JRediClients 文件：JedisTest.java

@Test(expected = InvalidURIException.class)
public void shouldThrowInvalidURIExceptionForInvalidURI() throws URISyntaxException {
  Jedis j = new Jedis(new URI("localhost:6380"));
  j.ping();
}

项目：cachecloud 文件：JedisPoolTest.java

@Test(expected = InvalidURIException.class)
public void shouldThrowInvalidURIExceptionForInvalidURI() throws URISyntaxException {
  JedisPool pool = new JedisPool(new URI("localhost:6380"));
}

项目：cachecloud 文件：JedisTest.java

@Test(expected = InvalidURIException.class)
public void shouldThrowInvalidURIExceptionForInvalidURI() throws URISyntaxException {
  Jedis j = new Jedis(new URI("localhost:6380"));
  j.ping();
}

项目：Jedis 文件：JedisPoolTest.java

@Test(expected = InvalidURIException.class)
public void shouldThrowInvalidURIExceptionForInvalidURI() throws URISyntaxException {
  JedisPool pool = new JedisPool(new URI("localhost:6380"));
}

项目：Jedis 文件：JedisTest.java

@Test(expected = InvalidURIException.class)
public void shouldThrowInvalidURIExceptionForInvalidURI() throws URISyntaxException {
  Jedis j = new Jedis(new URI("localhost:6380"));
  j.ping();
}