Начало работы с Couchbase и Spring Data Couchbase

VAGRANT_NODES=2 vagrant up

Вам нужно будет администрировать и настраивать Couchbase при первоначальной настройке. Направьте ваш браузер на правильный IP для каждого узла. Правила определения этого IP  хорошо описаны в  README. Интерфейс администратора, в моем случае, был доступен на  192.168.105.101:8091 и 192.168.105.102:8091. Для получения дополнительной информации об этом процессе, я рекомендую вам следовать указаниям здесь  для деталей.

Вот как я это сделал. Я ударил интерфейс администратора  на первом узле  и создал новый кластер. Я использовал admin для имени пользователя и  password для пароля. На всех последующих страницах управления я просто присоединился к существующему кластеру, указав узлы  192.168.105.101 и используя вышеупомянутые  admin учетные данные. Как только вы объединили все узлы, найдите Rebalance кнопку на   панели « Узлы сервера» и запустите перебалансировку кластера.

Если вы закончили работу со своим кластером Vagrant, вы можете использовать  vagrant halt команду для его полного отключения. Также очень удобно  vagrant suspend, что будет сохранять состояние узлов, а не завершать их полностью.

Если вы хотите управлять кластером Couchbase из командной строки, это удобно couchbase-cli. Вы можете просто использовать  vagrant ssh команду , чтобы попасть в каждый из узлов (их узлов названий:  node1,  node2и т.д ..). Оказавшись там, вы можете запустить команды конфигурации кластера. Например,  server-list команда будет перечислять узлы кластера.

/opt/couchbase/bin/couchbase-cli server-list -c 192.168.56.101-u admin -p password

Легко вызвать  ребаланс,  используя:

/opt/couchbase/bin/couchbase-cli rebalance -c 192.168.56.101-u admin -p password

Couchbase In the Cloud и Cloud Foundry

Couchbase пригодна для использования в облаке. Он масштабируется по горизонтали (как Gemfire или Cassandra) в том смысле, что нет единой точки отказа. Он не использует ведущий-ведомый или активную / пассивную систему. Есть несколько способов запустить его там, где работают ваши приложения. Если вы используете установку Cloud Foundry, то вы можете установить  Cumulogic Service Broker,  который позволит вашей установке Cloud Foundry общаться с платформой Cumulogic, которая сама может управлять экземплярами Couchbase. Сервисные брокеры — это фрагмент кода интеграции, который учит Cloud Foundry, как предоставлять, уничтожать и вообще взаимодействовать с управляемым сервисом, таким как Couchbase, в данном случае.

Использование Spring Data Couchbase для хранения мест Facebook

Давайте рассмотрим простой пример, который читает данные (в данном случае из API Facebook Places с использованием API Spring Social Facebook  FacebookTemplate ), а затем загружает их на сервер Couchbase.

Получить токен доступа Facebook

Вам также понадобится токен доступа Facebook. Самый простой способ сделать это — зайти  на Портал разработчиков Facebook  и создать новое приложение, а затем получить идентификатор приложения и секретный ключ приложения. Возьмите эти два значения и объедините их с помощью символа pike ( |). Таким образом, вы будете иметь что — то в виде:  appID|appSecret. В примере приложения Environment для разрешения facebook.accessToken ключа используется механизм  Spring  . Вы можете указать для него значение в  src/main/resources/application.properties файле или с помощью любого из других поддерживаемых механизмов разрешения свойств Spring Boot. Вы можете даже предоставить значение в качестве  -D аргумента: -Dfacebook.accessToken=...|...

Рассказывая Spring Data Couchbase о нашем кластере

Данные в Couchbase хранятся в  контейнерах . Логически это то же самое, что и  база данных  в СУБД SQL. Обычно он реплицируется между узлами и имеет собственную конфигурацию. Мы будем использовать контейнер по  умолчанию , но совсем просто создать больше контейнеров.

Давайте рассмотрим базовую конфигурацию, необходимую для использования Spring Data Couchbase (в данном случае, с точки зрения приложения Spring Boot):

@SpringBootApplication
@EnableScheduling
@EnableCaching
public class Application {

  @EnableCouchbaseRepositories
@Configuration
static class CouchbaseConfiguration extends AbstractCouchbaseConfiguration {

@Value("${couchbase.cluster.bucket}")
private String bucketName;

@Value("${couchbase.cluster.password}")
private String password;

@Value("${couchbase.cluster.ip}")
private String ip;

@Override
protected List<String> bootstrapHosts() {
return Arrays.asList(this.ip);
}

@Override
protected String getBucketName() {
return this.bucketName;
}

@Override
protected String getBucketPassword() {
return this.password;
}
}

  // more beans

}

Хранилище данных Spring Couchbase

Spring Data предоставляет понятие репозиториев — объектов, которые обрабатывают типичную логику доступа к данным и предоставляют основанные на соглашениях запросы. Их можно использовать для сопоставления POJO с данными в резервном хранилище данных.

В нашем примере просто хранится информация о предприятиях, которую он читает из API Places Facebook. Для этого мы создали простую  Place сущность, которую репозитории Spring Data Couchbase будут знать, как сохранить:

@Document(expiry = 0)
class Place {

@Id
private String id;

@Field
private Location location;

@Field
@NotNull
private String name;

@Field
private String affilitation, category, description, about;

@Field
private Date insertionDate;
  // .. getters, constructors, toString, etc
}

Place Объект ссылается на другой объект,  Location, который является в основном то же самое.

Query query = new Query();
query.setKey("Philz Coffee");
Collection<Place> places = placeRepository.findByName(query);
places.forEach(System.out::println);