Статьи

Кэширование Hibernate с помощью HazelCast: базовая конфигурация

Декабрь 27, 2018

Ранее мы уже знакомились с кэшированием JPA, механизмами и тем, что предлагает hibernate.

Далее следует проект гибернации, использующий Hazelcast в качестве кэша второго уровня.

Для этой цели мы будем использовать базовый весенний загрузочный проект с JPA. Spring boot использует hibernate в качестве поставщика JPA по умолчанию.
Наша установка будет довольно близка к предыдущей.
Мы будем использовать postgresql с docker для нашей базы данных sql.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
group 'com.gkatzioura'
version '1.0-SNAPSHOT'
 
buildscript {
    repositories {
        mavenCentral()
    }
    dependencies {
        classpath("org.springframework.boot:spring-boot-gradle-plugin:1.5.1.RELEASE")
    }
}
 
apply plugin: 'java'
apply plugin: 'idea'
apply plugin: 'org.springframework.boot'
 
 
repositories {
    mavenCentral()
}
 
dependencies {
    compile("org.springframework.boot:spring-boot-starter-web")
    compile group: 'org.springframework.boot', name: 'spring-boot-starter-data-jpa'
    compile group: 'org.postgresql', name:'postgresql', version:'9.4-1206-jdbc42'
    compile group: 'org.springframework', name: 'spring-jdbc'
    compile group: 'com.zaxxer', name: 'HikariCP', version: '2.6.0'
    compile group: 'com.hazelcast', name: 'hazelcast-hibernate5', version: '1.2'
    compile group: 'com.hazelcast', name: 'hazelcast', version: '3.7.5'
    testCompile group: 'junit', name: 'junit', version: '4.11'
}

Внимательно изучив зависимости, мы увидим пул hikari, драйвер postgresql, данные весны jpa и, конечно, hazelcast.

Вместо того, чтобы создавать базу данных вручную, мы автоматизируем ее, используя функцию инициализации базы данных Spring boot.

Мы создадим файл с именем schema.sql в папке ресурсов.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
create schema spring_data_jpa_example;
  
create table spring_data_jpa_example.employee(
    id  SERIAL PRIMARY KEY,
    firstname   TEXT    NOT NULL,
    lastname    TEXT    NOT NULL,  
    email       TEXT    not null,
    age         INT     NOT NULL,
    salary         real,
    unique(email)
);
  
insert into spring_data_jpa_example.employee (firstname,lastname,email,age,salary)
values ('Test','Me','[email protected]',18,3000.23);

Чтобы упростить его и избежать дальнейших настроек, мы поместим конфигурации для источника данных, jpa и кэширования в файл application.yml.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
spring:
  datasource:
    continue-on-error: true
    type: com.zaxxer.hikari.HikariDataSource
    url: jdbc:postgresql://172.17.0.2:5432/postgres
    driver-class-name: org.postgresql.Driver
    username: postgres
    password: postgres
    hikari:
      idle-timeout: 10000
  jpa:
    properties:
      hibernate:
        cache:
          use_second_level_cache: true
          use_query_cache: true
          region:
            factory_class: com.hazelcast.hibernate.HazelcastCacheRegionFactory
    show-sql: true

Конфигурация spring.datasource.continue-on-error имеет решающее значение, поскольку после перезапуска приложения должна быть предпринята вторая попытка создания базы данных, и, следовательно, сбой неизбежен.

Любые специфические свойства гибернации находятся по пути spring.jpa.properties. Мы включили кэш второго уровня и кеш запросов.

Также мы устанавливаем для show-sql значение true. Это означает, что как только запрос попадает в базу данных, он должен регистрироваться через консоль.

Затем создайте наш сотрудник.

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package com.gkatzioura.hibernate.enitites;
 
import javax.persistence.*;
 
/**
 * Created by gkatzioura on 2/6/17.
 */
@Entity
@Table(name = "employee", schema="spring_data_jpa_example")
public class Employee {
 
    @Id
    @Column(name = "id")
    @GeneratedValue(strategy = GenerationType.SEQUENCE)
    private Long id;
 
    @Column(name = "firstname")
    private String firstName;
 
    @Column(name = "lastname")
    private String lastname;
 
    @Column(name = "email")
    private String email;
 
    @Column(name = "age")
    private Integer age;
 
    @Column(name = "salary")
    private Integer salary;
 
    public Long getId() {
        return id;
    }
 
    public void setId(Long id) {
        this.id = id;
    }
 
    public String getFirstName() {
        return firstName;
    }
 
    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }
 
    public String getLastname() {
        return lastname;
    }
 
    public void setLastname(String lastname) {
        this.lastname = lastname;
    }
 
    public String getEmail() {
        return email;
    }
 
    public void setEmail(String email) {
        this.email = email;
    }
 
    public Integer getAge() {
        return age;
    }
 
    public void setAge(Integer age) {
        this.age = age;
    }
 
    public Integer getSalary() {
        return salary;
    }
 
    public void setSalary(Integer salary) {
        this.salary = salary;
    }
}

Все настроено. Spring boot обнаружит сущность и создаст EntityManagerFactory самостоятельно. Далее следует класс репозитория для сотрудника.

01
02
03
04
05
06
07
08
09
10
11
package com.gkatzioura.hibernate.repository;
 
import com.gkatzioura.hibernate.enitites.Employee;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.repository.CrudRepository;
 
/**
 * Created by gkatzioura on 2/11/17.
 */
public interface EmployeeRepository extends JpaRepository<Employee,Long> {
}

И последний контроллер

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
package com.gkatzioura.hibernate.controller;
 
import com.gkatzioura.hibernate.enitites.Employee;
import com.gkatzioura.hibernate.repository.EmployeeRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
import java.util.List;
 
/**
 * Created by gkatzioura on 2/6/17.
 */
@RestController
public class EmployeeController {
 
    @Autowired
    private EmployeeRepository employeeRepository;
 
    @RequestMapping("/employee")
    public List<Employee> testIt() {
 
        return employeeRepository.findAll();
    }
 
    @RequestMapping("/employee/{employeeId}")
    public Employee getEmployee(@PathVariable Long employeeId) {
 
        return employeeRepository.findOne(employeeId);
    }
 
}

Как только мы выдадим запрос по адресу http: // localhost: 8080 / employee / 1

Консоль отобразит запрос, выданный в базе данных

1
Hibernate: select employee0_.id as id1_0_0_, employee0_.age as age2_0_0_, employee0_.email as email3_0_0_, employee0_.firstname as firstnam4_0_0_, employee0_.lastname as lastname5_0_0_, employee0_.salary as salary6_0_0_ from spring_data_jpa_example.employee employee0_ where employee0_.id=?

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

Вы можете скачать проект с github .

Ссылка: Кэширование Hibernate с помощью HazelCast: базовая конфигурация от нашего партнера по JCG Эммануила Гкатзиураса в блоге gkatzioura .
58
Share: