Spring Book Club + java查询数据库 + 百万数据 + 同步Elasticsearch（ES）+ 多线程 + FeignClient（远程调用）

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
@Service
public class BookService {
 
    @Autowired
    private BookRepository bookRepository;
 
    @Autowired
    private ElasticsearchService elasticsearchService;
 
    @Transactional
    public void synchronizeBooksWithElasticsearch() {
        List<Book> books = bookRepository.findAll(); // 查询数据库获取所有图书
        ExecutorService executorService = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池
        List<Future<String>> futures = new ArrayList<>();
 
        for (Book book : books) {
            futures.add(executorService.submit(() -> {
                // 将图书数据同步到Elasticsearch
                elasticsearchService.indexBook(book);
                return "Indexed book " + book.getId();
            }));
        }
 
        executorService.shutdown(); // 关闭线程池
 
        // 输出结果
        for (Future<String> future : futures) {
            try {
                System.out.println(future.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
}

这个代码示例展示了如何在Spring应用中使用@Service注解定义服务层，并且使用@Autowired注解自动装配数据仓库和Elasticsearch服务。synchronizeBooksWithElasticsearch方法中使用了@Transactional注解来保证操作的原子性，并且使用了ExecutorService来实现并发同步数据到Elasticsearch。这个例子简洁地展示了如何在实际应用中处理并发操作和数据库查询，对于开发者来说具有很好的教育意义。