Springboot中调用API的多线程方法

Question

我需要在Springboot中实现多线程，同时使用POST方法调用API。我根据一个SELECT查询从oracle数据库中提取记录，然后使用行映射器逐个遍历每个记录。在下一步中，我只调用一个方法将这些记录发送到API，以postmapping的形式发送这些记录并取回记录。

因为select查询一次可以返回10、20或100条记录。逐个调用每条记录并不理想。我在想我是否可以一次发送多个记录。我不知道如何实现它，因为我对Springboot还不熟悉，还在学习。

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

import com.demo.payengine.api.ProviderUpdateAPI;
import com.demo.payengine.config.DataSourceDbConfig;
import com.demo.payengine.pojo.ProvRecordMappingPOJO;

public class ProvRecordProcessing {
    
    //declare variables
    private static String tn_id                     ;
    private static String pr_id                     ; 
    private static String pr_entity                 ;
    private static String pr_cl_eft_ind             ;    
    private static String pr_edi_dest_ind           ; 
    private static String pr_ra_dest_ind            ; 
    private static String br_id                     ; 
    private static String br_account_no             ; 
    private static String br_account_name           ; 
    private static String br_account_number_qual    ;

    @Autowired
    DataSourceDbConfig dbConfig;
    
    @Autowired
    ProviderUpdateAPI provUpdate;
    
    DataSource dataSource;
    
    
    public void dbProvRecordProcessing() {
        
        dataSource = dbConfig.dataSource();
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        
        
        String sqlQuery ="tn_id, pr_id, pr_entity, pr_cl_eft_ind, pr_edi_dest_ind, pr_ra_dest_ind, \r\n" + 
                "br_id, br_account_no, br_account_name, br_account_number_qual\r\n" + 
                "from mc_pr_prv pr \r\n" + 
                "inner join sg_prb_enrll_fl enroll\r\n" + 
                "on pr.tn_id = enroll.pr_payee_id\r\n" + 
                "inner join mc_mbr_bank_rel br\r\n" + 
                "on br.br_ck = pr.br_ck\r\n" + 
                "where pr.pr_entity ='G'";
        
        
        RowMapper<ProvRecordMappingPOJO> rowMapper = new RowMapper<ProvRecordMappingPOJO>(){

            @Override
            public ProvRecordMappingPOJO mapRow(ResultSet rs, int rowNum) throws SQLException {
                tn_id                   = rs.getString("tn_id")                     ;
                pr_id                   = rs.getString("pr_id")                     ;
                pr_entity               = rs.getString("pr_entity")                 ;
                pr_cl_eft_ind           = rs.getString("pr_cl_eft_ind")             ;
                pr_edi_dest_ind         = rs.getString("pr_edi_dest_ind ")          ;
                br_id                   = rs.getString("br_id")                     ;
                br_account_no           = rs.getString("br_account_no")             ;
                br_account_name         = rs.getString("br_account_name")           ;
                br_account_number_qual  = rs.getString("br_account_number_qual")    ;
                
                
                return new ProvRecordMappingPOJO(tn_id, pr_id, pr_entity, pr_cl_eft_ind, pr_edi_dest_ind, 
                        pr_ra_dest_ind, br_id, br_account_no, br_account_name, br_account_number_qual);
                }
            };
        
        //intialize sql query
        List<ProvRecordMappingPOJO> provRecords = jdbcTemplate.query(sqlQuery, rowMapper);
        
        for(ProvRecordMappingPOJO record : provRecords) {
            
            System.out.println("Processing provider record.." + record);
            
            //This method will call API <--- how to make it multi threaded
            provUpdate.provUpdateAPI(tn_id, pr_id, pr_entity, pr_cl_eft_ind, pr_edi_dest_ind, pr_ra_dest_ind, 
                    br_id, br_account_no, br_account_name, br_account_number_qual); 
            
        }
        
    }
    
}

Answer 1

更好的选择可能是CompletableFutureAPI，创建API调用的CompletableFutureAPI列表，然后连接在一起，一旦所有这些完成，就提取结果。

检查以下两个网页：

1. 这将为您的需求提供一个实际的用例-

Answer 2

创建一个类ProvUpdateExecitor，它接受一个ProvUpdateResult对象。为了易读性，我使用ProvUpdateResult对象封装了下面方法中的所有方法参数

provUpdate.provUpdateAPI(tn_id, pr_id, pr_entity, pr_cl_eft_ind, pr_edi_dest_ind, pr_ra_dest_ind, 
                    br_id, br_account_no, br_account_name, br_account_number_qual);

类的职责是以多线程的方式执行API调用

public class ProvUpdateExecutor {

  private ExecutorService executorService = Executors.newFixedThreadPool(noThreads);
  private ProviderUpdateAPI providerUpdateAPI;

  public ProvUpdateExecutor(ProviderUpdateAPI providerUpdateAPI) {
    this.providerUpdateAPI = providerUpdateAPI;
  }

  public void execute(List<ProvUpdateResult> provUpdateResults) {
    List<Future<?>> futures = new ArrayList<>();
    for (ProvUpdateResult provUpdateResult : provUpdateResults) {
      futures.add(executorService.submit(() -> providerUpdateAPI.provUpdateAPI(provUpdateResult)));
    }

    for (Future<?> future : futures) {
      try {
        future.get();
      } catch (InterruptedException | ExecutionException e) {
        e.printStackTrace();
      }
    }
  }
}

其中可配置（通过配置参数传递）。请注意，创建线程池有相关的成本，因此您可能希望将此类创建为单件对象。

在方法中调用provUpdateExecutor。执行（provUpdateResults）外部循环