Создайте кластерную службу с помощью Конфигурации Admin и Apache Karaf Cellar.

Эти команды работают как основные, но вы всегда должны указывать группу.

Вы должны увидеть, что эта функция установлена ​​в обоих экземплярах Karaf (проверьте, например, с помощью: list | grep -i camunda). Теперь нам нужна база данных.

Настройка базы данных

Должен признаться, это были мои первые проблемы. Начиная от смешного и заканчивая тем, что немного раздражен. Моей первой проблемой было то, что я пытался использовать версию H2 в памяти. Это не будет работать, потому что, по логике, каждый экземпляр Karaf работает в своей собственной JVM. Итак, из-за нескольких приложений я запустил h2 в режиме сервера (см.  Здесь  для получения дополнительной информации).

java -cp h2*.jar org.h2.tools.Server jdbc:h2:tcp://localhost/~/test

Следующая проблема заключалась в том, что из-за некоторых исключений ProcessEngines запускались и останавливались в казалось бы случайных порядках. Имея databaseSchemaUpdate набор свойств для создания-уронить вызывали проблемы с таблицами не присутствует из — за случайного падения / создания. Я рекомендую создавать таблицы самостоятельно ( вот  sqls).

Это не решило все мои проблемы с базой данных. Я подозревал, что H2 не способен обрабатывать вход одного и того же пользователя дважды (на что он способен, насколько я знаю сейчас). После этого я перешел на MySQL.

Настройка MySQL в Карафе

MySQL немного сложнее настроить, чем H2, потому что мы должны создать правильный источник данных. Для начала нам нужно установить  Apache Karaf DataSources :

feature:install jdbc

Затем создайте источник данных

jdbc:create -u sa -p sa -url jdbc:mysql://localhost:3306/test -t MySQL test

Команда создания источника данных должна быть выполнена на обоих Karafs, потому что источник данных — *. Xml, который будет создан в каталоге развертывания, не будет скопирован. Чтобы ProcessEngine мог найти источник данных MySQL, ему нужно имя JNDI. Чтобы дать источнику данных имя JNDI, нам нужен  Apache Karaf Naming .

feature:install jndi

Теперь источник данных автоматически получит имя JNDI (проверьте с помощью jndi:names). Если вы не видите  jndi:* команд, вам придется установить эту функцию вручную на втором Karaf.

Наконец, нам нужен коннектор MySQL. Мы можем найти это  здесь . Просто поместите банку в каталог развертывания.

До сих пор база данных MySQL работает нормально. Давайте посмотрим на файл конфигурации.

Файл конфигурации

Когда я начинал этот «эксперимент», я думал, что использование директории etc / в Karaf было бы хорошей идеей, но теперь я должен сказать: пожалуйста, не пытайтесь делать этот файл на основе. Я перепробовал много комбинаций, и это не сработало. Самым близким, что я получил, была конфигурация, прибывающая на оба Карафа, но только один создаваемый двигатель. Жан-Батист  и  Ахим  действительно пытались помочь мне в списке рассылки. Тем не менее, я не мог заставить его работать. Вы можете попробовать.

Караф просматривает каталог etc / для файлов конфигурации. Чтобы развернуть один для ManagedProcessEngineFactroy, вам нужно будет назвать его  org.camunda.bpm.extension.osgi.configadmin.ManagedProcessEngineFactory-1.cfg.

Я переключился на комплект, который содержит конфигурацию.

Пакет конфигурации

Как упоминалось ранее, для ManagedServiceFactory для создания службы требуется одна или несколько конфигураций. Мы будем использовать простую версию конфигурации:

databaseSchemaUpdate=false
jobExecutorActivate=true
processEngineName=TestEngine
databaseType=mysql
dataSourceJndiName=osgi:service/jdbc/test

databaseSchemaUpdate=false
jdbcUrl=jdbc:h2:tcp://localhost/~/test
jobExecutorActivate=true
processEngineName=TestEngine
jdbcUsername=sa
jdbcPassword=sa

public class Activator implements BundleActivator {

    public void start(BundleContext context) throws Exception {
        ServiceReference ref = context.getServiceReference(ConfigurationAdmin.class.getName());
        ConfigurationAdmin admin = (ConfigurationAdmin) context.getService(ref);
        String pid = "org.camunda.bpm.extension.osgi.configadmin.ManagedProcessEngineFactory";
        Configuration configuration = admin.createFactoryConfiguration(pid, null);
        Hashtable properties = new Hashtable();
        properties.put("databaseSchemaUpdate","false");
        properties.put("jobExecutorActivate","true");
        properties.put("processEngineName","TestEngine");
        properties.put("databaseType","mysql");
        properties.put("dataSourceJndiName", "osgi:service/jdbc/test");
        configuration.update(properties);
    }