Mq接收消息为JSONObject时报错怎么解决

这篇文章主要介绍“接收消息为JSONObject时报错怎么解决”，在日常操作中，相信很多人在接收消息为JSONObject时报错怎么解决问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”接收消息为JSONObject时报错怎么解决”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

今天在Mq出来业务的时候发现使用JSONObject时会报错，只能获取String类型，所以使用JSONObject转换后获取，代码如下

JSONObject mq = new JSONObject();
mq.put("websiteCode",websiteCode);
 
for (int i = 0, len = skuInfo.size(); i < len; i++) {
itemCodes.add(skuInfo.getJSONObject(i).getString("itemSkuCode"));
// 通知Mq刷新 TODO
mq.put("itemSkuCode",skuInfo.getJSONObject(i).getString("itemSkuCode"));
String s = JSONObject.toJSONString(mq);
                rabbitTemplate.convertAndSend(MqKey.RECOMMENDED_PRODUCTS,MqKey.RECOMMENDED_PRODUCTS,s);
}

接收方代码

@RabbitListener(bindings = {@QueueBinding(value = @Queue(value = "restHomeData", autoDelete = "true", durable = "true"),        exchange = @Exchange(name = MqKey.RECOMMENDED_PRODUCTS, type = ExchangeTypes.FANOUT),        key = MqKey.RECOMMENDED_PRODUCTS)})public void getRecommendedProductsMq(String object) {
    JSONObject jsonObject = JSONObject.parseObject(object);    log.info("收到通知" + jsonObject);    getRecommendedProducts(jsonObject);}

到此，关于“接收消息为JSONObject时报错怎么解决”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注本站网站，小编会继续努力为大家带来更多实用的文章！