处理json异常问题,由于发送kafka消息是一个字符串,等到消费时json字符串会有多个““引号,故需要先处理json再转对象

发送一个正确的json对象

发送kafka消息也是一个json传,也没问题

等到消费kafka时,也能接收到一个json字符串但是会多一个 " 引号, 就会导致json转对象失败所以需要先去除 开通和结尾的 " 引号

去除后的json 就是一个正常的json,才能转换对象

 处理 " 引号的代码逻辑

    @KafkaListener(topics = {"brok.............1"},containerFactory = "kafkaListenerContainerFactory")
//    @Transactional(rollbackOn = Exception.class)
    public void receive(String message) throws JsonProcessingException, ParseException, InterruptedException {
        ObjectMapper objectMapper=new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        try {
            message = message.replace("\\", "");
            String startStr = message.substring(0,1);
            // 去除开头 " 引号
            if( "\"".equals( startStr )){
                message = message.substring(1);
            }
            // 去除结尾 " 引号
            String lastStr = message.substring(message.length()-1,message.length());
            if( "\"".equals( lastStr )){
                message = message.substring(0, message.length() - 1);
            }
            System.out.println( message );
            MessageBean messageBean = JSON.parseObject(message, MessageBean.class);
            consumerService.consumer(messageBean);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

相关推荐

  1. json字符串处理

    2024-03-13 12:18:01       37 阅读
  2. json字符串json对象三种方式

    2024-03-13 12:18:01       34 阅读
  3. C# 字符串json

    2024-03-13 12:18:01       32 阅读
  4. 判断是否json字符串

    2024-03-13 12:18:01       58 阅读
  5. js实现字符串json对象的四种方法

    2024-03-13 12:18:01       37 阅读
  6. 发送json 发送对象

    2024-03-13 12:18:01       25 阅读
  7. hutool将字符串Json成数组

    2024-03-13 12:18:01       61 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-03-13 12:18:01       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-03-13 12:18:01       100 阅读
  3. 在Django里面运行非项目文件

    2024-03-13 12:18:01       82 阅读
  4. Python语言-面向对象

    2024-03-13 12:18:01       91 阅读

热门阅读

  1. c语言读写日志代码实现

    2024-03-13 12:18:01       48 阅读
  2. 力扣-中等

    2024-03-13 12:18:01       39 阅读
  3. OpenCV-交互相关接口

    2024-03-13 12:18:01       40 阅读
  4. 突破编程_C++_设计模式(责任链模式)

    2024-03-13 12:18:01       34 阅读
  5. OMP(Orthogonal Matching Pursuit,正交匹配追踪)算法

    2024-03-13 12:18:01       43 阅读
  6. vue3之异步组件(defineAsyncComponent)

    2024-03-13 12:18:01       44 阅读
  7. QT6.6下android编译及调用自定义so库方法

    2024-03-13 12:18:01       44 阅读
  8. 继电器RC保护电路阻值容值计算

    2024-03-13 12:18:01       47 阅读
  9. ElementUI自定义主题

    2024-03-13 12:18:01       41 阅读
  10. ORDaR23 数据集 json 标签文件结构一览

    2024-03-13 12:18:01       34 阅读