java—使用SpringCloud流SpringCloudKafka活页夹SpringV(2.3.9)将xml文件从服务a传输到服务b

knpiaxh1  于 2021-07-13  发布在  Java
关注(0)|答案(0)|浏览(212)

使用springcloudstream和springcloudkafka活页夹将xml文件或数据从服务a传输到服务b的最佳方式是什么,而不必在服务a中编组和解编组xml,选项1。将xml转换为字符串并传输,这是可行的,但是在服务b中,从字符串选项2中解析复杂的xml非常困难。将xml数据放入字节数组byte[]=file.getbyte();此选项可能有效,但会出现以下错误“[截断的3439字节];行:1,列:2];嵌套异常为com.fasterxml.jackson.core.jsonparseexception:意外字符(“<”(代码60)):在[源:(byte[])处应为有效值(json字符串、数字、数组、对象或标记“null”、“true”或“false”)
示例publisher@enablebinding(source.class) @RestController("/") 公共类publishfilecontroller{

@Autowired
private MessageChannel output;

@PostMapping(value="/upload", produces=MediaType.APPLICATION_XML_VALUE)
public ResponseEntity<Object> uploadFile(@RequestParam("file") MultipartFile file) {

    try {
        byte[] getDetails = file.getBytes();
        output.send(MessageBuilder.withPayload(getDetails).build());
    } catch (Exception e) {
        System.out.println(e);      
    }

示例订户 @EnableBinding(Sink.class) 公共级I850控制器{

private Logger logger = LoggerFactory.getLogger(I850Controller.class);

@StreamListener("input")
public void getFile(Byte[] s) throws ParserConfigurationException, SAXException, IOException {
    System.out.println(s);

}

}
任何帮助都将不胜感激

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题