springboot环境下使用多线程同步商品数据到多家门店数据到es

在Spring Boot环境下，可以使用多线程来同步商品数据到多家门店数据到Elasticsearch（ES）。下面是一个简单的示例：

首先，需要在pom.xml文件中添加Elasticsearch和多线程相关的依赖：

<dependencies>
  <!-- Elasticsearch -->
  <dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.2.0</version>
  </dependency>

  <!-- Elasticsearch High-Level REST Client -->
  <dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.2.0</version>
  </dependency>

  <!-- Apache HttpClient -->
  <dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.12</version>
  </dependency>

  <!-- Spring Boot -->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
    <version>2.4.0</version>
  </dependency>
  
  <!-- Spring Boot Web -->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.4.0</version>
  </dependency>
</dependencies>

创建一个Elasticsearch配置类，用于连接到Elasticsearch集群：

@Configuration
public class ElasticsearchConfig {

  @Value("${elasticsearch.host}")
  private String host;

  @Value("${elasticsearch.port}")
  private int port;

  @Bean
  public RestHighLevelClient elasticsearchClient() {
    RestClientBuilder builder = RestClient.builder(new HttpHost(host, port, "http"));
    RestHighLevelClient client = new RestHighLevelClient(builder);
    return client;
  }
}

创建一个商品数据同步任务类，用于将商品数据同步到ES中：

@Component
public class ProductDataSyncTask {

  @Autowired
  private ProductRepository productRepository;

  @Autowired
  private RestHighLevelClient elasticsearchClient;

  @Value("${elasticsearch.index}")
  private String index;

  public void syncData() {
    List<Product> products = productRepository.findAll(); // 获取所有商品数据

    // 使用多线程同步数据
    ExecutorService executorService = Executors.newFixedThreadPool(10);

    products.forEach(product -> {
      executorService.submit(() -> {
        try {
          IndexRequest indexRequest = new IndexRequest(index)
              .id(product.getId().toString())
              .source("name", product.getName(), "price", product.getPrice());

          IndexResponse indexResponse = elasticsearchClient.index(indexRequest, RequestOptions.DEFAULT);
          System.out.println("Indexed product: " + indexResponse.getId());
        } catch (IOException e) {
          e.printStackTrace();
        }
      });
    });

    executorService.shutdown();
  }
}

创建一个定时任务类，用于定期调用商品数据同步任务：

@Component
public class ProductDataSyncJob {

  @Autowired
  private ProductDataSyncTask productDataSyncTask;

  @Scheduled(cron = "0 0 0 * * ?") // 每天凌晨执行
  public void syncData() {
    productDataSyncTask.syncData();
  }
}

在application.properties文件中配置Elasticsearch相关参数：

elasticsearch.host=localhost
elasticsearch.port=9200
elasticsearch.index=products

以上示例中，我们使用了Spring Boot的自动配置和定时任务功能来定期同步商品数据到多家门店的Elasticsearch集群中。同时，为了提高同步效率，我们使用了多线程来并发处理商品数据的同步操作