Попытка использовать Redis. Маленькое время ответа. И нет ускорения

@billy121 · Регистрация: 15.10.2019

Студворк — интернет-сервис помощи студентам

Всем привет!
Я посмотрел видео

И захотел набросать простенький проект похожий, чтоб также сравнить результаты.

У автора видео, ответ приходит примерно за 200 мс. У меня за 2-3 мс. Структуру сделал максимально похожую.
Есть товары (айди, название, цена) и отзывы (айди, айди товара, оценка, коментарий). Когда делается запрос, то расчитывается средняя оценка на товар (возвращаем товарДТО(айди, название, цена, сред оценка)) У меня и у него - 100 продуктов, сколько у него отзывов - неизвестно, у меня 50-100.

Затем добавляю "кэширование" с помощью редис, мое время не изменяется и не улучшается. (у автора видео же, есть улучшения)

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

Мои результаты:
Без редиса - 1 миниатюра. С редисом - 2 миниатюра.

Кликните здесь для просмотра всего текста

Попытка использовать Redis. Маленькое время ответа. И нет ускорения

База H2 (пробовал постгресс, результаты получил аналогичные). Кэширование у БД отключил. (Может еще где нужно?)

Вот код:

Сущности:

Кликните здесь для просмотра всего текста

Товары

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
package science.examplerediska.entities;
 
import jakarta.persistence.*;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
 
import java.util.List;
 
@Data
@Entity
@Table(name = "PRODUCTS")
@NoArgsConstructor()
@AllArgsConstructor()
public class Product {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private int id;
    private String name;
    private double price;
 
    @OneToMany(mappedBy = "product", cascade = CascadeType.ALL, fetch = FetchType.LAZY)
    private List<Review> reviews;
}

Отзывы

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
package science.examplerediska.entities;
 
 
import jakarta.persistence.*;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
 
@Data
@Entity
@Table(name = "REVIEWS")
@NoArgsConstructor()
@AllArgsConstructor()
public class Review {
 
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private int id;
 
    @ManyToOne
    private Product product;
 
    private int rating;
 
    private String comment;
}

ТоварыДТО

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
package science.examplerediska.entities;
 
import lombok.Data;
import lombok.NoArgsConstructor;
 
@Data
@NoArgsConstructor
public class ProductDTO {
    private int id;
    private String name;
    private double price;
    private double avgRating;
 
    public ProductDTO(int id, String name, double price, double avgRating) {
        this.id = id;
        this.name = name;
        this.price = price;
        this.avgRating = avgRating;
    }
}

Репозитории:

Кликните здесь для просмотра всего текста

Java
1
2
3
4
5
6
7
8
9
10
11
12
package science.examplerediska.repositories;
 
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import science.examplerediska.entities.Product;
 
public interface ProductRepository extends JpaRepository<Product, Integer> {
    @Query("SELECT COUNT(p) FROM Product p")
    long countAllProducts();
 
    
}

Java
1
2
3
4
5
6
7
package science.examplerediska.repositories;
 
import org.springframework.data.jpa.repository.JpaRepository;
import science.examplerediska.entities.Review;
 
public interface ReviewRepository extends JpaRepository<Review, Integer> {
}

Сервис

Кликните здесь для просмотра всего текста

Java
1
2
3
4
5
6
7
8
9
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
package science.examplerediska.services;
 
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.rest.webmvc.ResourceNotFoundException;
import org.springframework.stereotype.Service;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import science.examplerediska.entities.Product;
import science.examplerediska.entities.ProductDTO;
import science.examplerediska.entities.Review;
import science.examplerediska.repositories.ProductRepository;
 
import java.util.Random;
 
 
 
@Service
public class ProductService {
 
    @Autowired
    private final ProductRepository productRepository;
    @Autowired
    private JedisPool jedisPool;
    private ObjectMapper mapper;
    private static final int TTL = 10;
 
    public ProductService(ProductRepository productRepository, ObjectMapper mapper) {
        this.productRepository = productRepository;
        this.mapper = mapper;
    }
 
 
    public ProductDTO getProductById(int id) {
        return productRepository.findById(id)
                .map(product -> new ProductDTO(
                        product.getId(),
                        product.getName(),
                        product.getPrice(),
                        product.getReviews().stream()
                                .mapToDouble(Review::getRating)
                                .average().orElse(0)
                )).orElse(null);
    }
 
    public ProductDTO getProductByIdRedisCached(int id) {
        try (Jedis jedis = jedisPool.getResource()){
            String key = "product:%d".formatted(id);
            String raw = jedis.get(key);
            if (raw != null) {
                return mapper.readValue(raw, ProductDTO.class);
            }
            var productDTO = getProductById(id);
            if (productDTO == null) {
                throw new ResourceNotFoundException();
            }
 
 
            jedis.setex(key, TTL, mapper.writeValueAsString(productDTO));
            return productDTO;
        } catch (JsonProcessingException e) {
            throw new RuntimeException("Could not get product with id " + id);
        }
    }
 
    public ProductDTO getProductRandom() {
        long countProducts = productRepository.countAllProducts();
        int randomId = new Random().nextInt(1, (int) countProducts);
        return getProductById(randomId);
//        return getProductByIdRedisCached(randomId);
    }
}

Контролер

Кликните здесь для просмотра всего текста

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
package science.examplerediska.controllers;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import science.examplerediska.entities.ProductDTO;
import science.examplerediska.services.ProductService;
 
@RestController
@RequestMapping("/api/products")
public class ProductController {
 
    private static final int TTL = 10;
    @Autowired
    private ProductService productService;
    
    @GetMapping("/{id}")
    public ProductDTO getProductById(@PathVariable int id) {
        return productService.getProductById(id);
    }
 
    @GetMapping("/random")
    public ProductDTO getProductRandom() {
        return productService.getProductRandom();
    }

РедисКонфиг

Кликните здесь для просмотра всего текста

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
package science.examplerediska;
 
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
 
@Configuration
@EnableCaching
public class RedisConfig {
 
    @Bean
    public JedisPool jedisPool() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxIdle(5);
        jedisPoolConfig.setMaxTotal(10);
        jedisPoolConfig.setJmxEnabled(false);
        return new JedisPool(jedisPoolConfig, "localhost", 6379);
    }
 
    @Bean
    public ObjectMapper objectMapper() {
        return new ObjectMapper();
    }
}

Генерация данных в бд

Кликните здесь для просмотра всего текста

Java
1
2
3
4
5
6
7
8
9
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
package science.examplerediska;
 
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import science.examplerediska.entities.Product;
import science.examplerediska.entities.Review;
import science.examplerediska.repositories.ProductRepository;
 
import java.util.ArrayList;
import java.util.Random;
 
@Component
public class DataInitializer {
 
    @Bean
    public CommandLineRunner loadData(ProductRepository productRepository) {
        return args -> {
            Random rand = new Random();
 
            for (int i = 1; i <= 100; i++) {
                double randomPrice = 10 + (3500 - 10) * rand.nextDouble();
                randomPrice = Math.round(randomPrice * 100.0) / 100.0;
 
                Product product = new Product(0, "Product " + i, randomPrice, new ArrayList<>());
 
                int reviewCount = 20 + rand.nextInt(100);
                for (int j = 0; j < reviewCount; j++) {
                    int randomRating = 1 + rand.nextInt(5); // Рейтинг от 1 до 5
                    String randomComment = "This is a review for Product " + i;
 
                    Review review = new Review(0, product, randomRating, randomComment);
                    product.getReviews().add(review); 
                }
 
                productRepository.save(product);
            }
        };
    }
}

Основной запускающий класс

Кликните здесь для просмотра всего текста

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
package science.examplerediska;
 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
 
@SpringBootApplication
@EnableCaching
public class ExampleRedisKaApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(ExampleRedisKaApplication.class, args);
    }
 
}

проперти ямл

Кликните здесь для просмотра всего текста

XML
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
spring:
  application:
    name: exampleRedisKa
 
  h2:
    console:
      enabled: true
 
  datasource:
    url: jdbc:h2:mem:rediska;CACHE_SIZE=0
    driver-class-name: org.h2.Driver
    username: admin
    password:
 
  jpa:
    database-platform: org.hibernate.dialect.H2Dialect
    hibernate:
      ddl-auto: update
 
  data:
    redis:
      host: localhost
      port: 6379

Это я что то делаю не так? Или здесь нет такого объема данных, чтоб была заметна разница?

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .	Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .
Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .	SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .