[java] Ehcache와 Apache Cassandra의 연동 방법에 대해 설명해주세요.

30 Nov 2023

java

Apache Cassandra는 분산 환경에서 대용량의 데이터를 관리하기 위한 분산형 NoSQL 데이터베이스 시스템입니다. Ehcache는 자바 기반의 오픈소스 인메모리 캐싱 프레임워크로, 캐시를 통해 데이터 성능을 향상시킬 수 있습니다. 이번 블로그에서는 Ehcache와 Apache Cassandra를 연동하는 방법에 대해 설명하겠습니다.

1. Maven 의존성 추가하기

Ehcache를 사용하기 위해 다음과 같이 Maven 의존성을 추가해야 합니다.

<dependency>
    <groupId>org.ehcache</groupId>
    <artifactId>ehcache</artifactId>
    <version>3.9.0</version>
</dependency>

Cassandra에 연결하기 위해 Cassandra 자체의 드라이버도 추가해야 합니다.

<dependency>
    <groupId>com.datastax.oss</groupId>
    <artifactId>java-driver-core</artifactId>
    <version>4.13.0</version>
</dependency>

2. Ehcache 설정하기

Ehcache를 설정하기 위해 ehcache.xml 파일을 작성합니다. 예를 들어, 다음과 같은 설정을 가진 ehcache.xml 파일을 생성할 수 있습니다.

<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns="http://www.ehcache.org/v3"
        xmlns:ehcache="http://www.ehcache.org/v3"
        xmlns:jsr107="http://www.ehcache.org/v3/jsr107"
        xsi:schemaLocation="http://www.ehcache.org/v3 http://www.ehcache.org/schema/ehcache-core-3.0.xsd
  	                  http://www.ehcache.org/v3/jsr107 http://www.ehcache.org/schema/ehcache-107-ext-3.0.xsd">

  <ehcache:cache alias="sampleCache">
    <ehcache:resources>
      <ehcache:heap unit="entries">100</ehcache:heap>
      <ehcache:offheap unit="MB">10</ehcache:offheap>
      <ehcache:disk unit="MB">100</ehcache:disk>
    </ehcache:resources>
  </ehcache:cache>

</config>

3. Cassandra 연결 설정하기

Cassandra와 연결하기 위해 다음과 같은 설정을 가진 cassandra.yaml 파일을 작성합니다.

datastax-java-driver:
  basic.contact-points: localhost:9042
  basic.load-balancing-policy:
    class: DefaultLoadBalancingPolicy

4. 연동 코드 작성하기

아래는 Cassandra와 Ehcache를 연동하는 예제 코드입니다.

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.CqlSessionBuilder;
import org.ehcache.Cache;
import org.ehcache.CacheManager;
import org.ehcache.config.builders.CacheConfigurationBuilder;
import org.ehcache.config.builders.CacheManagerBuilder;
import org.ehcache.config.builders.ResourcePoolsBuilder;
import org.ehcache.config.units.EntryUnit;
import org.ehcache.config.units.MemoryUnit;

public class CassandraEhcacheIntegrationExample {

    public static void main(String[] args) {
        CqlSession session = CqlSession.builder()
                .withConfigLoader(driverConfigLoader)
                .build();

        // Cassandra cluster 정보 설정
        Cluster cluster = Cluster.builder()
                .addContactPoint("localhost")
                .build();

        Session casSession = cluster.connect();

        // Ehcache 캐시 매니저 생성
        CacheManager cacheManager = CacheManagerBuilder.newCacheManagerBuilder()
                .withCache("sampleCache",
                        CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class,
                                ResourcePoolsBuilder.newResourcePoolsBuilder()
                                        .heap(100, EntryUnit.ENTRIES)
                                        .offheap(10, MemoryUnit.MB)
                                        .disk(100, MemoryUnit.MB, true)))
                .build();

        cacheManager.init();

        // 캐시에 데이터 저장
        Cache<Long, String> cache = cacheManager.getCache("sampleCache", Long.class, String.class);
        cache.put(1L, "Data");

        // 캐시에서 데이터 조회
        String dataFromCache = cache.get(1L);
        System.out.println("Data read from cache: " + dataFromCache);

        // Cassandra와 연동하여 데이터 저장 및 조회
        casSession.execute("INSERT INTO example_keyspace.example_table (key, value) VALUES (1, 'Data')");
        ResultSet resultSet = casSession.execute("SELECT value FROM example_keyspace.example_table WHERE key = 1");
        Row row = resultSet.one();
        String dataFromCassandra = row.getString("value");
        System.out.println("Data read from Cassandra: " + dataFromCassandra);

        // 연결 해제
        casSession.close();
        cluster.close();
        cacheManager.close();
    }
}

위의 예제 코드에서는 Cassandra에 데이터를 저장하고 조회하면서 동시에 Ehcache를 사용하여 데이터를 캐싱하고있습니다.

이상으로 Ehcache와 Apache Cassandra의 연동 방법에 대해 알아보았습니다. 이를 통해 고성능의 데이터 관리 시스템을 구축할 수 있고, 데이터 엑세스 성능을 향상시킬 수 있습니다.

더 자세한 내용은 아래의 참고 자료를 확인해주세요.