Развертывание драйвера Cassandra с использованием опции развертывания клиента Hazelcast выдает следующую ошибку

ProgramBox

Развертывание драйвера Cassandra с использованием опции развертывания клиента Hazelcast выдает следующую ошибку

Post author:admin
Запись опубликована:1 марта, 2023
Post category:Вопросы по программированию

#java #cassandra #hazelcast

Вопрос:

Я пытаюсь использовать MapStore, поддерживаемый Cassandra. Для этого необходимо передать эти реализации MapStore и MapLoader участнику Hazelcast, используя ClientUserCodeDeploymentConfig следующим образом

 public class CassandraMapStoreFactory implements MapStoreFactory<String, Long> {

    @Override
    public MapLoader<String, Long> newMapStore(String mapName, Properties properties) {
        return new CassandraPersistence(buildSession());
    }

    private Session buildSession() {
        try {
            ConsistencyLevel consistencyLevel = ConsistencyLevel.LOCAL_QUORUM;

            PoolingOptions poolingOptions = new PoolingOptions()
                    .setMaxRequestsPerConnection(HostDistance.LOCAL, 1024)
                    .setMaxRequestsPerConnection(HostDistance.REMOTE, 256);

            Cluster cluster = Cluster.builder()
                    .addContactPoints("15.207.180.45")
                    .withQueryOptions(new QueryOptions().setConsistencyLevel(consistencyLevel))
                    .withSocketOptions(new SocketOptions().setReadTimeoutMillis(12000))
                    .withPoolingOptions(poolingOptions)
                    .withSpeculativeExecutionPolicy(new ConstantSpeculativeExecutionPolicy(10000, 2))
                    .build();
            return cluster.connect("sample");
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

}

И ниже приведен код для отправки клиентского кода участнику / серверу Hazelcast

 public static void main(String[] args) {
        ClientConfig config = new ClientConfig();
        ClientUserCodeDeploymentConfig codeDeploymentConfig = new ClientUserCodeDeploymentConfig().setEnabled(true)
                .addClass(CounterEntryProcessor.class).addClass(CassandraMapStoreFactory.class).addClass(CassandraPersistence.class).addJar("cassandra-driver-core-3.1.2.jar");
        config.setUserCodeDeploymentConfig(codeDeploymentConfig);
        config.setClassLoader(MapIdGeneratorWithClient.class.getClassLoader());

        HazelcastInstance hazelcastInstance = HazelcastClient.newHazelcastClient(config);

        // map processing logic
        
        hazelcastInstance.shutdown();
    }

Я вижу следующую проблему при инициализации CassandraMapStoreFactory. Кажется, проблема с функциями модулей Java 9, и я использую Java 11. Пожалуйста, подскажите мне, что нужно сделать, чтобы использовать драйвер Cassandra в хранилище карт Hazelcast при подходе к развертыванию клиент / сервер

 Caused by: java.lang.IllegalAccessError: class com.datastax.driver.core.AbstractAddressableByIndexData cannot access its abstract superclass com.datastax.driver.core.AbstractGettableByIndexData (com.datastax.driver.core.AbstractAddressableByIndexData is in unnamed module of loader com.hazelcast.internal.usercodedeployment.impl.ClassSource @3614246c; com.datastax.driver.core.AbstractGettableByIndexData is in unnamed module of loader com.hazelcast.internal.usercodedeployment.impl.ClassSource @4890c0d0)

1. Зачем вам нужно развертывание пользовательского кода? Почему вы не можете сделать банки доступными для участников статически во время запуска?

2. @nicholas Хорошо, я здесь новичок, и я вижу, что это нужно сделать таким образом. Можете ли вы указать мне, как я мог это сделать? Вы хотите, чтобы cassandra jar была частью пути к классу-члену или моей пользовательской реализации как jar вместе с cassandra jar?

3. Я напишу это как ответ

Ответ №1:

Если вам абсолютно не нужно быть динамичным, я бы не советовал использовать развертывание пользовательского кода. Номинальный путь — фактически запустить элемент с необходимыми классами в его пути к классу.

Добавить JAR так же просто, как установить переменную CLASSPATH среды. Он будет работать как с дистрибутивом ZIP, так и с образом Docker.

Вот выдержка из docker-compose.yaml файла, который демонстрирует его:

 version: '3'
services:
  server:
    container_name: hz
    image: hazelcast/hazelcast:4.0
    ports:
      - 5701:5701
    volumes:
      - /Users/nico/.m2/repository:/opt/hazelcast/classpath
    environment:
      - CLASSPATH=/opt/hazelcast/classpath/org/json/json/20200518/json-20200518.jar:/opt/hazelcast/classpath/org/jetbrains/kotlin/kotlin-stdlib/1.3.72/kotlin-stdlib-1.3.72.jar:/opt/hazelcast/classpath/com/github/kittinunf/fuel/fuel/2.2.3/fuel-2.2.3.jar:/opt/hazelcast/classpath/com/github/kittinunf/result/result/3.0.1/result-3.0.1.jar