Java-关注字段发生变化,发送变化信息

MySQL数据库某些字段发生变化时,将信息发送到rabbitMq。

GoodsChange goodsChangeBefore =new GoodsChange();
GoodsChange goodsChangeAfter =new GoodsChange();
Goods goodsBefore;
Goods goodsAfter;
...
        else if (operator != null && tableName != null && Arrays.asList(tableList).contains(tableName)
                                && "u".contains(operator)) {
        goodsBefore = JSONObject.parseObject(jsonObj2Map(before), Goods.class);
        goodsAfter = JSONObject.parseObject(jsonObj2Map(after), Goods.class);              BeanUtils.copyProperties(goodsBefore,goodsChangeBefore);
        BeanUtils.copyProperties(goodsAfter, goodsChangeAfter);
       //判断关注的字段值是否有变化,有变化时向MQ发送消息
        if((ObjectToJson.ObjectToJson(goodsChangeBefore)).equals(ObjectToJson.ObjectToJson(goodsChangeAfter))){
            goodsProducer.send(goodsAfter);
            log.info(tableName+"表发生更新"+goodsAfter);
        } else{
            log.info("非关注字段发生变化,不需要发送消息");
        }
    }
...
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容