Cassandra Java驱动在Android与其他系统的异常问题排查

问题背景 #

使用com.datastax.oss:java-driver-core:4.17.0在Android中连接Cassandra Cloud时，抛出DriverExecutionException，根因是java.security.KeyStoreException: JKS not found，但本地单元测试可正常运行。旧版本驱动同样存在该问题，核心矛盾是Android与标准JVM的密钥库支持差异。

问题原因 #

标准JVM默认支持JKS格式密钥库，但Android的Security Provider未包含JKS实现，仅支持BKS、PKCS12等格式。Datastax的Cloud Secure Connect Bundle默认使用JKS密钥库，因此在Android上加载时会触发NoSuchAlgorithmException。

解决方案 #

需要手动替换密钥库格式，并自定义SSLContext传入Driver，绕过Driver默认的JKS加载逻辑。

步骤1：转换Secure Connect Bundle中的JKS为PKCS12 #

1. 解压Cassandra Cloud提供的secure-connect-<cluster>.zip文件，找到其中的keystore.jks和truststore.jks。
2. 使用keytool命令将JKS转换为PKCS12格式：

# 转换keystore
keytool -importkeystore -srckeystore keystore.jks -destkeystore keystore.p12 -srcstoretype JKS -deststoretype PKCS12 -srcstorepass <JKS密码> -deststorepass <新PKCS12密码>

# 转换truststore
keytool -importkeystore -srckeystore truststore.jks -destkeystore truststore.p12 -srcstoretype JKS -deststoretype PKCS12 -srcstorepass <JKS密码> -deststorepass <新PKCS12密码>

注：JKS密码可从解压后的config.json文件中获取（keystore_password和truststore_password字段）

步骤2：在Android项目中配置并加载PKCS12密钥库 #

将转换后的keystore.p12和truststore.p12放入Android项目的assets目录，然后手动创建SSLContext：

private SSLContext createAndroidSslContext() throws Exception {
    // 从assets读取密钥库文件
    InputStream keystoreStream = getAssets().open("keystore.p12");
    InputStream truststoreStream = getAssets().open("truststore.p12");
    
    // 加载PKCS12格式密钥库
    KeyStore keyStore = KeyStore.getInstance("PKCS12");
    keyStore.load(keystoreStream, "<PKCS12密钥库密码>".toCharArray());
    
    KeyStore trustStore = KeyStore.getInstance("PKCS12");
    trustStore.load(truststoreStream, "<PKCS12信任库密码>".toCharArray());
    
    // 创建KeyManagerFactory和TrustManagerFactory
    KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
    keyManagerFactory.init(keyStore, "<PKCS12密钥库密码>".toCharArray());
    
    TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
    trustManagerFactory.init(trustStore);
    
    // 初始化SSLContext
    SSLContext sslContext = SSLContext.getInstance("TLS");
    sslContext.init(keyManagerFactory.getKeyManagers(), trustManagerFactory.getTrustManagers(), null);
    
    return sslContext;
}

步骤3：修改Cassandra Session创建代码 #

不再使用withCloudSecureConnectBundle，而是手动配置连接参数并传入自定义SSLContext：

try {
    // 创建自定义SSLContext
    SSLContext sslContext = createAndroidSslContext();
    
    // 从config.json中获取联系点、端口等信息
    String contactPoint = "<Cassandra Cloud联系点>";
    int port = 9042;
    
    CqlSession session = CqlSession.builder()
            .addContactPoint(new InetSocketAddress(contactPoint, port))
            .withSslContext(sslContext)
            .withAuthCredentials(
                CryptoChain.byteArrayToString(CryptoChain.encryptBlockwise(Datastax.class.getName().getBytes(), ush)),
                CryptoChain.byteArrayToString(CryptoChain.encryptBlockwise(Datastax.class.getName().getBytes(), pwh))
            )
            .withLocalDatacenter("<本地数据中心名称>") // 从config.json中获取
            .build();
    return session;
} catch (final Exception e) {
    throw new RuntimeException(e);
}

关键说明 #

• 若不想手动转换格式，也可引入第三方Security Provider（如BouncyCastle）来支持JKS，但会增加包体积，推荐使用PKCS12方案。
• 所有配置参数（联系点、数据中心名称、密钥库密码）均可从原Secure Connect Bundle的config.json中提取。

内容的提问来源于stack exchange，提问作者BeatEngine