多節點,多線程下發訂單,使用zookeeper分佈式鎖機制保證訂單正確接入oms系統

 假設訂單下發, 採用單機每分鐘從訂單OrderEntry接口表中抓100單, 接入訂單oms系統中. 因爲雙十一期間, 訂單量激增, 致使訂單單機每分鐘100單形成, 訂單積壓. 因此採用多節點多線程處理三方商家的訂單接入系統.

流程圖:

如圖所示:

採用多節點, 多線程, 使用curator操做zk的方式實現, 訂單的下發.

之前的方式每分鐘下發100單, 以後採用如今的方式能夠每分鐘2000單, 大大增長系統的訂單下發的處理速度, 系統的吞吐量, 提升了效率.

1 操做zookeeper的工具類:

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;
 
public class ZkUtils {
 
    private static final String zkStr = ConfUtil.getProperty("zkStr");
    private static final String zkPath = ConfUtil.getProperty("zkPath");
    
    public static InterProcessMutex createMutexLock(){
        
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 10); //1 重試策略：初試時間爲1s 重試10次
        
        CuratorFramework client = CuratorFrameworkFactory.builder()//2 經過工廠建立鏈接
                    .connectString(zkStr)
                    .sessionTimeoutMs(5000)
                    .retryPolicy(retryPolicy)
                    .build();
        client.start(); // 開啓鏈接
        InterProcessMutex mutexLock = new InterProcessMutex(client, zkPath); // 建立分佈式鎖
        return mutexLock;
        
    }
}

2 使用該工具類處理訂單下發業務邏輯

public class Job {
    private final static org.slf4j.Logger logger=LoggerFactory.getLogger(HnJob.class);
 
    @Autowired
    private IHNOrderService iHNOrderService;
    
    public void execute(){
        
        InterProcessMutex mutexLock = ZkUtils.createMutexLock();
        try{
            mutexLock.acquire();
            bizHandler(); //執行訂單下發業務處理邏輯
            
        }catch (Exception e) {
            e.printStackTrace();
        }finally{
            try {
                mutexLock.release();
            } catch (Exception e) {
                e.printStackTrace();
            } 
        }
    }
    
    void bizHandler(){
        long start=System.currentTimeMillis();
        logger.info("====================訂單下發開始");
        iHNOrderService.hnOrderQuery();
        long end=System.currentTimeMillis();
        logger.info("=================訂單下發結束,耗時={}秒",(end-start)/(1000));
    }
    
    
    
}