如何将具有键值的 JSON 文件转换为 apache camel headers - Spring DSL

Question

我有一个包含键值对的 JSON 文件，我想将键值对放入 headers。所以当我有一个内容如下的文件时：

[{"msgId": "8600C5A3-C666-4E63-BFDB-52BCF557F938", "jiraId": "ERR002"}]

我想用名称 msgId 和值“8600C5A3-C666-4E63-BFDB-52BCF557F938”等创建 headers

或者作为替代方案：有没有办法将交换的 headers 存储到文件中，稍后 headers 可以在另一个交换中恢复到该文件？

谢谢。

编辑：我的示例分支。

    public void jsonToHeaders(String body, @Headers Map<String, String> headers) throws ParseException {

        LOG.info("Starting JSON conversion...");
        LOG.debug("Body input, content: {} ", body);
        JSONParser parser = new JSONParser();
        JSONObject jsonObject = (JSONObject) parser.parse(body);
        if (jsonObject != null) 
        { 
            String stringValue = null;
            String stringKey = null ;
            final String NA_STRING = "*** N/A ***";

            for (Object key : jsonObject.keySet()) {

                stringKey = ((key == null) ? NA_STRING : (String)key);
                stringValue = ((jsonObject.get(stringKey) == null) ? NA_STRING : jsonObject.get(stringKey).toString());
                headers.put(stringKey, stringValue);
                LOG.debug("Processing key {} with value {}", stringKey, stringValue);
            }
            LOG.info("Done processed JSON: {}", headers.toString());
        }
    }

Answer 1

对于这种情况，您可以使用 bean。

JSONToHeadersBean


package org.mybean;


import org.apache.camel.Headers;
import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser;
import org.json.simple.parser.ParseException;

import java.io.IOException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

public class JSONToHeadersBean {

    public void jsonToHeaders(String body, @Headers Map<String, String> headers) throws ParseException {
        JSONParser parser = new JSONParser();
        JSONObject object = (JSONObject) parser.parse(body);
        object.keySet().forEach(key -> headers.put(key.toString(), object.get(key).toString()));
    }

    //for test
    public static void main(String[] args) throws ParseException {
        String body = "{\"msgId\": \"8600C5A3-C666-4E63-BFDB-52BCF557F938\", \"jiraId\": \"ERR002\"}";
        JSONParser parser = new JSONParser();
        JSONObject object = (JSONObject) parser.parse(body);
        final Map<String, String> headers = new HashMap<String, String>();
        object.keySet().forEach(key -> headers.put(key.toString(), object.get(key).toString()));
        System.out.println();
    }
}

创建 bean

<bean class="org.mybean.JSONToHeadersBean" id="JSONToHeadersBean" name="JSONToHeadersBean"/>

而且你可以在路线中使用它

<bean method="jsonToHeaders" ref="JSONToHeadersBean"/>

Answer 2

作为替代方案，您可以将 JSON 解析为 HashMap 并将其放入 header:

.unmarshal().json(JsonLibrary.Jackson, java.util.Map.class)
.setHeader("params", simple("body"))

（需要 camel-jackson 依赖项）

要访问存储的值：

.log(LoggingLevel.INFO, "MsgId: ${header.params[msgId]}")

如何将具有键值的 JSON 文件转换为 apache camel headers - Spring DSL

How to transform JSON file with key values to apache camel headers - Spring DSL

json

apache-camel

spring-boot

spring-camel