单体架构服务转型至分布式的踩坑经历

@Servicepublic class SkuMainServiceImpl implements SkuMainService {    private static final org.slf4j.Logger LOGGER = LoggerFactory.getLogger(SkuMainServiceImpl.class);
    @Resource    private SkuMainDao skuMainDao;    @Resource    private ZkConfManagerCenterService zkConfManagerCenterService;    @Resource    private ProductImagesService productImagesService;//同级互相引用，未遵循依赖倒置    @Resource    private MqService mqServiceImpl;
    @Value("${system.group.environment}")    private String systemGroupEnvironment;    /**     * 问题：service层聚合了太多业务逻辑 倒置上层方法没办法统一     * @param skuMainInfoMQEntity     * @throws Exception     */    public void editorSaveProuct(SkuMainInfoMQEntity skuMainInfoMQEntity) throws Exception {        try {            SkuMainBean skuMainBean = skuMainInfoMQEntity.getSkuMainBean();            if (skuMainBean == null) {                throw new Exception("修改参数为空！");            }
            SkuMainBean originalSku = this.getSkuMainBeanBySkuId(skuMainBean.getId());            if (originalSku == null) {                throw new Exception("无效SkuId！");            }
            SkuMainBean skuMainUpdate = updateIsWeightMark(skuMainBean);            SkuMainBean skuMainPre = this.get(skuMainUpdate.getId());            // 系统下架的商品 强制下架            if (skuMainPre != null && skuMainPre.getSystemFixedStatus() != null && skuMainPre.getSystemFixedStatus().equals(SystemFixedStatusEnum.SYSTEM_FIXED_STATUS_DOWN.getCode())) {                skuMainUpdate.setFixedStatus(FixedStatusEnum.PRODUCT_DOWN.getCode());            }
            boolean flag = skuMainDao.editorProduct(skuMainUpdate);            if (flag) {                if (!zkConfManagerCenterService.isDefaultStoreStatisticsScore(skuMainBean.getOrgCode())) {                    SkuMainBean saveSkumainBean = this.get(skuMainUpdate.getId());                    // 防止未查到,把缓存覆盖                    if (saveSkumainBean != null) {                        cacheSkuMainBean(saveSkumainBean);                    }                    // 发送Sku修改MQ                    sendSkuModifyMq(SkuModifyOpSourceEnum.MIX_UPDATE_SKU, originalSku, new SkuMainInfoMQEntity(skuMainUpdate));                    ProductImagesBean productImagesBean = productImagesService.queryImagesBySkuId(skuMainUpdate.getId());                    SkuMainInfoCheckMQEntity skuMainInfoCheckMQEntity = new SkuMainInfoCheckMQEntity();                    skuMainInfoCheckMQEntity.setSkuMainBean(skuMainUpdate);                    skuMainInfoCheckMQEntity.setProductImagesBean(productImagesBean);                    mqServiceImpl.sendJosMQ(skuMainInfoCheckMQEntity, MqTypeEnum.RcsKeyWordsCheck);                    mqServiceImpl.sendJosMQ(skuMainInfoCheckMQEntity, MqTypeEnum.SenseKeyWordsCheck);                } else {                    LOGGER.info("add open platform sku , not not not send mq! skuId = {}", skuMainBean.getId());                }            }        } catch (Exception e) {            LOGGER.error("修改商品信息失败.e:", e);            throw new Exception(e);        }    }

@Servicepublic class SkuMainBusinessServiceImpl implements SkuMainBusinessService {    private static final org.slf4j.Logger LOGGER = LoggerFactory.getLogger(SkuMainBusinessServiceImpl.class);
    @Resource    private ZkConfManagerCenterService zkConfManagerCenterService;    @Resource    private MqService mqService;    @Resource    private SkuMainReadservice skuMainReadservice;    @Resource    private SkuMainWriteservice skuMainWriteservice;
    @Value("${system.group.environment}")    private String systemGroupEnvironment;    /**     * 问题：service层聚合了太多业务逻辑 倒置上层方法没办法统一     * @param skuMainInfoMQEntity     * @throws Exception     */    public void editorSaveProuct(SkuMainInfoMQEntity skuMainInfoMQEntity) throws Exception {        try {            SkuMainBean skuMainBean = skuMainInfoMQEntity.getSkuMainBean();            if (skuMainBean == null) {                throw new Exception("修改参数为空！");            }            SkuMainBean originalSku = skuMainReadservice.getSkuMainBeanBySkuId(skuMainBean.getId());            if (originalSku == null) {                throw new Exception("无效SkuId！");            }            SkuMainBean skuMainUpdate = skuMainWriteservice.updateIsWeightMark(skuMainBean);            SkuMainBean skuMainPre = skuMainReadservice.queryDbById(skuMainUpdate.getId());            // 系统下架的商品 强制下架            if (skuMainPre != null && skuMainPre.getSystemFixedStatus() != null && skuMainPre.getSystemFixedStatus().equals(SystemFixedStatusEnum.SYSTEM_FIXED_STATUS_DOWN.getCode())) {                skuMainUpdate.setFixedStatus(FixedStatusEnum.PRODUCT_DOWN.getCode());            }            boolean flag = skuMainWriteservice.editorProduct(skuMainUpdate);            if (flag) {                if (!zkConfManagerCenterService.isDefaultStoreStatisticsScore(skuMainBean.getOrgCode())) {                    SkuMainBean saveSkumainBean = skuMainservice.queryDbById(skuMainUpdate.getId());                    // 防止未查到,把缓存覆盖                    if (saveSkumainBean != null) {                        skuMainWriteservice.cacheSkuMainBean(saveSkumainBean);                    }                    // 发送Sku修改MQ                    skuMainWriteservice.sendSkuModifyMq(SkuModifyOpSourceEnum.MIX_UPDATE_SKU, originalSku, new SkuMainInfoMQEntity(skuMainUpdate));                } else {                    LOGGER.info("add open platform sku , not not not send mq! skuId = {}", skuMainBean.getId());                }            }        } catch (Exception e) {            LOGGER.error("修改商品信息失败.e:", e);            throw new Exception(e);        }    }