fastJSON 解决kafka消息斜杠转义问题

Bug: kafka发送消息时的JSON转义异常

问题描述:

问题描述:kafka消息发送出去但是消费者执行相关逻辑的时候报错.

场景:当时实习的时候需要模拟数据做一个实时经纬度传输的接口,使用kafka实时发送消息将数据同步到数据库中

问题分析:

fastjson使用不当可能导致转义异常**,kafka消息发送出去但是消费不了原因是 发送到kafka中的消息会带一堆斜杠的转义字符**导致消费者获取数据执行相关业务之后报错:类似于下面这种

"[{\"birthday\":\"2000\",\"major\":[\"挖掘机\",\"炒菜\"],\"name\":\"xiaoming\",\"comment\":\"hello world\",\"age\":25.2,\"status\":0}]";

问题解决:

JSONObject.toJSONString() 是阿里巴巴的 fastjson 库中的一个方法,用于将 JSONObject 对象转换为其对应的 JSON 格式的字符串表示。这个方法在需要将 JSON 对象以字符串形式存储、传输或打印到控制台等场景时非常有用。

https://blog.csdn.net/qq_27706119/article/details/104828285 参考

image-20240409104720259

实例代码

@Service
@Slf4j
public class KafKaSendServiceImpl implements KafKaSendService {// 封装的kafka客户端@Resourceprivate KafkaCommonService kafkaCommonService;@Overridepublic void deviceGatVideoModelDtoSend() {// 模拟数据DeviceGatVideoModelDto device = new DeviceGatVideoModelDto("c2", "d2", "设备2", "海康威视", "m2", "o2", "320123200003043342", "江宁区", "百家湖", 2,"c22", 2, 2, "102", 2, 200, "2025-8-2", "20002002", "192.168.1.128", 3862,"qq456", 2, "部分支持", 2, 120.46, 35.61, 3, "456456", false, "anotherString1");log.info("kafka发送消息:DEVICE_VIDEO_TOPIC");kafkaCommonService.kafkaSendMessage("DEVICE_VIDEO_TOPIC", JSONObject.toJSONString(device));log.info("kafka发送消息后:DEVICE_VIDEO_TOPIC");}@Overridepublic void notifyMobilePositionDtoSend() {NotifyMobilePositionDto dto = new NotifyMobilePositionDto("d1", "1", "c1", "1", "2024-01-01","120.45", "35.6", "20", "15", "100",2);log.info("kafka发送消息:NOTIFY_MOBILE_POSITION_TOPIC");kafkaCommonService.kafkaSendMessage("NOTIFY_MOBILE_POSITION_TOPIC",JSONObject.toJSONString(dto));}@Overridepublic void merge(){deviceGatVideoModelDtoSend();notifyMobilePositionDtoSend();}}

核心代码

kafkaCommonService.kafkaSendMessage("DEVICE_VIDEO_TOPIC", JSONObject.toJSONString(device2));

代码理解

JSONObject.toJSONString() 是阿里巴巴的 fastjson 库中的一个方法,用于将 JSONObject 对象转换为其对应的 JSON 格式的字符串表示。这个方法在需要将 JSON 对象以字符串形式存储、传输或打印到控制台等场景时非常有用。

这行代码调用了kafkaCommonServicekafkaSendMessage方法,用于发送Kafka消息。

  • "DEVICE_VIDEO_TOPIC":这是Kafka的主题名称,消息会被发送到这个主题。
  • JSONObject.toJSONString(device):这是消息的内容。JSONObject.toJSONString是fastjson库的一个方法,用于将Java对象转换为JSON格式的字符串。在这里,它将`device对象转换为其JSON字符串表示。

  • 功能描述

这个方法会遍历 JSONObject 对象中的所有键值对,并按照 JSON 的语法规则将它们转换成一个字符串。键和字符串类型的值通常会被双引号包围,而其他类型的值(如数字、布尔值等)则按照其对应的 JSON 表示形式输出。

  • 示例
import com.alibaba.fastjson.JSONObject;  public class FastjsonExample {  public static void main(String[] args) {  // 创建一个JSONObject对象  JSONObject jsonObject = new JSONObject();  jsonObject.put("name", "Alice");  jsonObject.put("age", 30);  jsonObject.put("isStudent", false);  // 将JSONObject转换为JSON格式的字符串  String jsonString = jsonObject.toJSONString();  // 打印转换后的JSON字符串  System.out.println(jsonString);  }  
}

总结:

所以,JSONObject.toJSONString(device)的作用是将device对象转换为一个JSON格式的字符串,这样它就可以作为Kafka消息的内容被发送。在Kafka中,消息通常是字符串或字节数组,因此,将对象转换为JSON字符串是一种常见的方式来发送结构化数据。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/49200.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Android 15 之如何快速适配 16K Page Size

在此之前,我们通过 《Android 15 上 16K Page Size 为什么是最坑》 介绍了: 什么是16K Page Size为什么它对于 Android 很坑如何测试 如果你还没了解,建议先去了解下前文,然后本篇主要是提供适配的思路,因为这类适配…

计算机视觉9 全卷积网络

全卷积网络(Fully Convolutional Network,简称 FCN)在计算机视觉领域具有重要地位。 传统的卷积神经网络(CNN)在最后的输出层通常使用全连接层来进行分类任务。然而,全连接层会丢失空间信息,使得…

Facebook Dating:社交平台的约会新体验

随着社交媒体的普及和技术的发展,传统的社交方式正在经历革新,尤其是在约会这个领域。Facebook作为全球领先的社交平台,推出了Facebook Dating,旨在为用户提供一个全新的约会体验。本文将探讨Facebook Dating如何重新定义社交平台…

OpenCV 安装与基础使用教程(Python)

文章目录 一、硬件要求二、安装三、功能介绍总结 一、硬件要求 OpenCV 是一个跨平台的计算机视觉库,对硬件的要求并不严格,但为了更好的性能和体验,建议满足以下配置: 操作系统:Windows 10 或更高版本,Ub…

mysql 根据一个表的id,查询另一个表,看看数据是否存在

如果你想要检查一个表中的id是否在另一个表中作为外键存在,你可以使用SQL的EXISTS子句来完成这个任务。以下是一个例子: 假设我们有两个表,orders和customers。orders表有一个customer_id字段,我们想要检查customers表中的每个id是…

43 华三AC登录Web页面

一 无线上WEB页面 1 创建vlan 56 [AC-KongZhi]vlan 56 2 退出 [AC-KongZhi-vlan56]quit 3 进入vlan三层口 配置IP地址 [AC-KongZhi]interface Vlan-interface 56 [AC-KongZhi-Vlan-interface56]ip address 192.168.56.55 24 4 在AC控制器与Host主机的接口上能通关vlan 5…

高等数学重难点突破:高阶导数的计算

写在最前 文章目录 写在最前方法一:找规律方法二:牛顿莱布尼茨公式方法三:泰勒公式方法四: 数学归纳法 本文重点讨论总结面对高阶导数,我们可以使用哪些方法(工具)来解决计算高阶导数问题 方法概述&#xf…

【入门教程一】基于DE2-115的My First FPGA 工程

1.1. 概述 这是一个简单的练习, 可以帮助初学者开始了解如何使用Intel Quartus 软件进行 FPGA 开发。 在本章节中,您将学习如何编译 Verilog 代码,进行引脚分配,创建时序约束,然后对 FPGA 进行编程,驱动开…

React 学习指南:从入门到精通

在前端开发的世界里,React 无疑是一颗璀璨的明星。如果你渴望掌握这一强大的前端框架,那么这篇学习指南将为你指明道路。 一、React 简介 React 是一个用于构建用户界面的 JavaScript 库,由 Facebook 开发和维护。它以其高效的虚拟 DOM 机制、…

【Redis】主从复制分析-基础

1 主从节点运行数据的存储 在主从复制中, 对于主节点, 从节点就是自身的一个客户端, 所以和普通的客户端一样, 会被组织为一个 client 的结构体。 typedef struct client {// 省略 } client;同时无论是从节点, 还是主节点, 在运行中的数据都存放在一个 redisServer 的结构体中…

python批量图片重命名

为了使用Python将文件夹内的PNG图片重命名为递增数字加上13位时间戳的格式,你需要先确定几个关键点: 递增数字:你需要一个计数器来跟踪已经重命名的图片数量。时间戳:由于你需要的是13位的时间戳(这通常是毫秒级的时间…

求职学习day8

7/21回顾: 用面试鸭的意义可能就在于将知识点用问答的形式具象化在脑海,不然可能只停留在听说过的感觉 7.21 玩了一天。一个很不好的信号。今天下午要试试把 mall 项目的代码运行过一遍。 项目运行问题: 问题 1 :两个门服务器…

搜维尔科技:人机交互学术应用概览

人机交互学术应用概览 搜维尔科技:人机交互学术应用概览

Numpy常见操作总结

NumPy 提供高效的多维数组对象 (ndarray) 用于大规模数据处理。它包含丰富的数学函数库,支持线性代数、傅里叶变换和随机数生成等操作。 以下代码内容包括对于数组对象的查看、数据处理等操作 import numpy as np# 创建一个二维和三维数组 array_e1 np.array([[1,…

有序充电在新型电力系统下的解决方案

摘要:近年来,新能源汽车的销量快速增长,相应的充电桩数量也急剧增加,这一现象可能会给电网和变压器造成负担,与此同时,新型电力系统下以光伏为主的分布式发电系统占比也在逐渐提高,新能源的不稳定性叠加充电需求的不确定性会给电网带来严峻的…

Unity发布XR中用于worldbuilding的全新电子书

通过身临其境的虚拟领域开始旅程,在维度之间传送,或将数字奇迹与现实世界融合——虚拟现实(VR)和混合现实(MR)的千万种可能性将邀请创作者把他们的想象力带入生活。 Unity发布的最新版综合指南将帮助有抱负的创作者和经验丰富的开发者深入研究和理解构建…

洛谷看不了别人主页怎么办

首先,我们先点进去 可以看到,看不了一点 那我们看向上方,就可以发现,我们那有个URL,选中 把光标插到n和/中间 把.cn删了,变成国际服 我们就可以看了 但是国际服还没搭建完,跳转的时候可能503&a…

融云 2024 ChinaJoy | 你有一个必逛的展位 @W4 馆 B786

惊喜闪现👇 打开抖音搜索【融云】 关注融云官抖,可到展位领取好礼一份 更有惊喜内容不定时掉落~

Python从0到100(四十六):实现管理员登录及测试功能

前言: 零基础学Python:Python从0到100最新最全教程。 想做这件事情很久了,这次我更新了自己所写过的所有博客,汇集成了Python从0到100,共一百节课,帮助大家一个月时间里从零基础到学习Python基础语法、Pyth…

“微软蓝屏”事件暴露了网络安全哪些问题?

网络安全的隐性威胁:从“微软蓝屏”事件看全球IT基础设施的脆弱性 ---------------------------------------------------------------------------------------------------------------------------- 一、事件回顾 近日,由微软视窗系统软件更新引发的…