• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java JdkSSLOptions类代码示例

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

本文整理汇总了Java中com.datastax.driver.core.JdkSSLOptions类的典型用法代码示例。如果您正苦于以下问题：Java JdkSSLOptions类的具体用法？Java JdkSSLOptions怎么用？Java JdkSSLOptions使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



JdkSSLOptions类属于com.datastax.driver.core包，在下文中一共展示了JdkSSLOptions类的9个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: createSSLOptions

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
private SSLOptions createSSLOptions()
     throws KeyStoreException, FileNotFoundException, IOException, NoSuchAlgorithmException,
            KeyManagementException, CertificateException, UnrecoverableKeyException {
     TrustManagerFactory tmf = null;
     KeyStore tks = KeyStore.getInstance("JKS");
     tks.load((InputStream) new FileInputStream(new File(truststorePath)),
truststorePwd.toCharArray());
     tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
     tmf.init(tks);

     KeyManagerFactory kmf = null;
     if (null != keystorePath) {
         KeyStore kks = KeyStore.getInstance("JKS");
         kks.load((InputStream) new FileInputStream(new File(keystorePath)),
    keystorePwd.toCharArray());
         kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
         kmf.init(kks, keystorePwd.toCharArray());
     }

     SSLContext sslContext = SSLContext.getInstance("TLS");
     sslContext.init(kmf != null? kmf.getKeyManagers() : null,
                     tmf != null ? tmf.getTrustManagers() : null,
                     new SecureRandom());

     return JdkSSLOptions.builder().withSSLContext(sslContext).build(); //SSLOptions.DEFAULT_SSL_CIPHER_SUITES);
 }
开发者ID:brianmhess，项目名称:cassandra-count，代码行数:27，代码来源:CqlCount.java


示例2: getClusterBuilderConfigurer

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
@Override
protected ClusterBuilderConfigurer getClusterBuilderConfigurer() {
	return new ClusterBuilderConfigurer() {

		@Override
		public Cluster.Builder configure(Cluster.Builder clusterBuilder) {
			if (CassandraConfiguration.this.cassandraProperties.isUseSsl()) {
				JdkSSLOptions.Builder optsBuilder = JdkSSLOptions.builder();
				if (CassandraConfiguration.this.cassandraProperties.isSkipSslValidation()) {
					try {
						optsBuilder.withSSLContext(TrustAllSSLContextFactory.getSslContext());
					}
					catch (NoSuchAlgorithmException | KeyManagementException e) {
						throw new RuntimeException("Unable to configure a Cassandra cluster using SSL.", e);
					}
				}
				return clusterBuilder.withSSL(optsBuilder.build());
			}
			else {
				return clusterBuilder;
			}
		}
	};
}
开发者ID:spring-cloud-stream-app-starters，项目名称:cassandra，代码行数:25，代码来源:CassandraConfiguration.java


示例3: buildSSLOptions

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
private static SSLOptions buildSSLOptions(EncryptionOptions.ClientEncryptionOptions clientEncryptionOptions)
{

    if (!clientEncryptionOptions.enabled)
        return null;

    SSLContext sslContext;
    try
    {
        sslContext = SSLFactory.createSSLContext(clientEncryptionOptions, true);
    }
    catch (IOException e)
    {
        throw new RuntimeException("Could not create SSL Context.", e);
    }

    return JdkSSLOptions.builder()
                        .withSSLContext(sslContext)
                        .withCipherSuites(clientEncryptionOptions.cipher_suites)
                        .build();
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:22，代码来源:BulkLoader.java


示例4: createSession

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
private Session createSession() {
    Cluster.Builder clusterBuilder = new Cluster.Builder();

    String nodes = System.getProperty("hawkular.metrics.cassandra.nodes", "hawkular-cassandra");
    Arrays.stream(nodes.split(",")).forEach(clusterBuilder::addContactPoint);

    if (System.getProperty("hawkular.metrics.cassandra.use-ssl") != null && !System.getProperty("hawkular.metrics.cassandra.use-ssl").equals("false")) {
        SSLOptions sslOptions = null;
        try {
            String[] defaultCipherSuites = {"TLS_RSA_WITH_AES_128_CBC_SHA", "TLS_RSA_WITH_AES_256_CBC_SHA"};
            sslOptions = JdkSSLOptions.builder().withSSLContext(SSLContext.getDefault())
                    .withCipherSuites(defaultCipherSuites).build();
            clusterBuilder.withSSL(sslOptions);
        } catch (NoSuchAlgorithmException e) {
            throw new RuntimeException("SSL support is required but is not available in the JVM.", e);
        }
    }

    Cluster cluster = clusterBuilder.build();
    cluster.init();

    Session session = cluster.connect();

    return session;
}
开发者ID:hawkular，项目名称:hawkular-metrics，代码行数:26，代码来源:NamespaceOverrideMapper.java


示例5: getSSLOptions

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
public static Optional<SSLOptions> getSSLOptions(Configuration conf)
{
    Optional<String> truststorePath = getInputNativeSSLTruststorePath(conf);
    Optional<String> keystorePath = getInputNativeSSLKeystorePath(conf);
    Optional<String> truststorePassword = getInputNativeSSLTruststorePassword(conf);
    Optional<String> keystorePassword = getInputNativeSSLKeystorePassword(conf);
    Optional<String> cipherSuites = getInputNativeSSLCipherSuites(conf);

    if (truststorePath.isPresent())
    {
        SSLContext context;
        try
        {
            context = getSSLContext(truststorePath, truststorePassword, keystorePath, keystorePassword);
        }
        catch (UnrecoverableKeyException | KeyManagementException |
                NoSuchAlgorithmException | KeyStoreException | CertificateException | IOException e)
        {
            throw new RuntimeException(e);
        }
        String[] css = null;
        if (cipherSuites.isPresent())
            css = cipherSuites.get().split(",");
        return Optional.of(JdkSSLOptions.builder()
                                        .withSSLContext(context)
                                        .withCipherSuites(css)
                                        .build());
    }
    return Optional.absent();
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:31，代码来源:CqlConfigHelper.java


示例6: returnsInstanceOfJdkSSLOptions

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
@Test
public void returnsInstanceOfJdkSSLOptions() throws Exception {
    final JDKSSLOptionsFactory factory = new JDKSSLOptionsFactory();

    final SSLOptions options = factory.build();

    assertThat(options).isInstanceOf(JdkSSLOptions.class);
}
开发者ID:composable-systems，项目名称:dropwizard-cassandra，代码行数:9，代码来源:JDKSSLOptionsFactoryTest.java


示例7: open

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
@Override
public void open() {

  final String[] addresses = getProperty(CASSANDRA_HOSTS).split(",");
  final int port = parseInt(getProperty(CASSANDRA_PORT));
  StringBuilder hosts = new StringBuilder();
  for (String address : addresses) {
    hosts.append(address).append(",");
  }

  LOGGER.info("Bootstrapping Cassandra Java Driver to connect to " + hosts.toString() +
          "on port " + port);

  Compression compression = driverConfig.getCompressionProtocol(this);

  clusterBuilder = Cluster.builder()
          .addContactPoints(addresses)
          .withPort(port)
          .withProtocolVersion(driverConfig.getProtocolVersion(this))
          .withClusterName(getProperty(CASSANDRA_CLUSTER_NAME))
          .withCompression(compression)
          .withCredentials(getProperty(CASSANDRA_CREDENTIALS_USERNAME),
                  getProperty(CASSANDRA_CREDENTIALS_PASSWORD))
          .withLoadBalancingPolicy(driverConfig.getLoadBalancingPolicy(this))
          .withRetryPolicy(driverConfig.getRetryPolicy(this))
          .withReconnectionPolicy(driverConfig.getReconnectionPolicy(this))
          .withSpeculativeExecutionPolicy(driverConfig.getSpeculativeExecutionPolicy(this))
          .withMaxSchemaAgreementWaitSeconds(
                  parseInt(getProperty(CASSANDRA_MAX_SCHEMA_AGREEMENT_WAIT_SECONDS)))
          .withPoolingOptions(driverConfig.getPoolingOptions(this))
          .withQueryOptions(driverConfig.getQueryOptions(this))
          .withSocketOptions(driverConfig.getSocketOptions(this));

  final String runWithSSL = getProperty(CASSANDRA_WITH_SSL);
  if (runWithSSL != null && runWithSSL.equals("true")) {
    LOGGER.debug("Cassandra Interpreter: Using SSL");

    try {
      final SSLContext sslContext;
      {
        final KeyStore trustStore = KeyStore.getInstance("JKS");
        final InputStream stream = Files.newInputStream(Paths.get(
                getProperty(CASSANDRA_TRUSTSTORE_PATH)));
        trustStore.load(stream, getProperty(CASSANDRA_TRUSTSTORE_PASSWORD).toCharArray());

        final TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(
                TrustManagerFactory.getDefaultAlgorithm());
        trustManagerFactory.init(trustStore);

        sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, trustManagerFactory.getTrustManagers(), null);
      }
      clusterBuilder = clusterBuilder.withSSL(JdkSSLOptions.builder()
              .withSSLContext(sslContext)
              .build());
    } catch (Exception e) {
      LOGGER.error(e.toString());
    }
  } else {
    LOGGER.debug("Cassandra Interpreter: Not using SSL");
  }

  cluster = clusterBuilder.build();
  session = cluster.connect();
  helper = new InterpreterLogic(session);
}
开发者ID:apache，项目名称:zeppelin，代码行数:67，代码来源:CassandraInterpreter.java


示例8: CQLClient

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
public CQLClient(LoaderOptions options, String keyspace)
        throws NoSuchAlgorithmException, FileNotFoundException, IOException, KeyStoreException,
        CertificateException, UnrecoverableKeyException, KeyManagementException, ConfigurationException {

    // System.setProperty("com.datastax.driver.NON_BLOCKING_EXECUTOR_SIZE",
    // "64");

    PoolingOptions poolingOptions = new PoolingOptions();

    int connections = options.connectionsPerHost;
    if (connections == 0) {
        connections = 8;
    }
    poolingOptions.setCoreConnectionsPerHost(HostDistance.LOCAL, Math.max(1, connections / 2));
    poolingOptions.setCoreConnectionsPerHost(HostDistance.REMOTE, Math.max(1, connections / 4));
    poolingOptions.setMaxConnectionsPerHost(HostDistance.LOCAL, connections);
    poolingOptions.setMaxConnectionsPerHost(HostDistance.REMOTE, Math.max(1, connections / 2));
    poolingOptions.setMaxRequestsPerConnection(HostDistance.LOCAL, 32768);
    poolingOptions.setMaxRequestsPerConnection(HostDistance.REMOTE, 2000);

    this.simulate = options.simulate;
    this.verbose = options.verbose;
    Cluster.Builder builder = builder().addContactPoints(options.hosts).withProtocolVersion(ProtocolVersion.V3)
            .withCompression(Compression.LZ4).withPoolingOptions(poolingOptions);
    if (options.user != null && options.passwd != null) {
        builder = builder.withCredentials(options.user, options.passwd);
    }
    if (options.ssl) {
        EncryptionOptions enco = options.encOptions;
        SSLContext ctx = SSLContext.getInstance(options.encOptions.protocol);

        try (FileInputStream tsf = new FileInputStream(enco.truststore);
                FileInputStream ksf = new FileInputStream(enco.keystore)) {
            KeyStore ts = KeyStore.getInstance(enco.store_type);
            ts.load(tsf, enco.truststore_password.toCharArray());
            TrustManagerFactory tmf = TrustManagerFactory
                    .getInstance(TrustManagerFactory.getDefaultAlgorithm());
            tmf.init(ts);

            KeyStore ks = KeyStore.getInstance("JKS");
            ks.load(ksf, enco.keystore_password.toCharArray());
            KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
            kmf.init(ks, enco.keystore_password.toCharArray());
            ctx.init(kmf.getKeyManagers(), tmf.getTrustManagers(), new SecureRandom());
        }
        SSLOptions sslOptions = JdkSSLOptions.builder().withSSLContext(ctx).withCipherSuites(enco.cipher_suites)
                .build();
        builder = builder.withSSL(sslOptions);
    }

    cluster = builder.build();
    session = cluster.connect(keyspace);
    metadata = cluster.getMetadata();
    keyspaceMetadata = metadata.getKeyspace(keyspace);
    org.apache.cassandra.schema.KeyspaceMetadata ksMetaData = org.apache.cassandra.schema.KeyspaceMetadata
            .create(keyspaceMetadata.getName(), KeyspaceParams.create(keyspaceMetadata.isDurableWrites(),
                    keyspaceMetadata.getReplication()));
    Schema.instance.load(ksMetaData);

    loadUserTypes(keyspaceMetadata.getUserTypes(), keyspace);

    partitioner = FBUtilities.newPartitioner(metadata.getPartitioner());
    if (options.throttle != 0) {
        rateLimiter = RateLimiter.create(options.throttle * 1000 * 1000 / 8);
    }

    this.batch = options.batch;
    this.preparedStatements = options.prepare ? new ConcurrentHashMap<>() : null;
    this.ignoreColumns = options.ignoreColumns;
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:71，代码来源:BulkLoader.java


示例9: build

import com.datastax.driver.core.JdkSSLOptions; //导入依赖的package包/类
@Override
public SSLOptions build() {
    return JdkSSLOptions.builder().build();
}
开发者ID:composable-systems，项目名称:dropwizard-cassandra，代码行数:5，代码来源:JDKSSLOptionsFactory.java



注：本文中的com.datastax.driver.core.JdkSSLOptions类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java ArcGISMap类代码示例发布时间：2022-05-23
下一篇：
Java SecurityException类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap