访问 Camel EIP bean 中消息体的元素

Question

我有一个骆驼路线，我在其中使用 Content Enricher EIP。所以我的路线是这样的：

AggregationStrategy aggregationStrategy = new TestAggregationStrategy(); 

from("timer:myTimer?repeatCount=1")
.setBody(simple("{\"channel\": \"orderbook\", \"market\": \"BTC/USD\", \"type\": \"update\", \"data\": {\"time\": 1626139758.986094, \"checksum\": 195176195, \"bids\": [[32965.0, 0.0], [32962.0, 3.4015]], \"asks\": [], \"action\": \"update\"}}"))
.setHeader(MongoDbConstants.CRITERIA, constant(Filters.eq("market", "BTC/USD")))
.enrich("mongodb:mongo?database=dev&collection=order&operation=findOneByQuery", aggregationStrategy)
.log("Test: ${body}");

在 TestAggregationStrategy 我有两个交换，原始和资源。

public class TestAggregationStrategy implements AggregationStrategy {
    public Exchange aggregate(Exchange original, Exchange resource) {
        System.out.println("Original: " + original.getMessage().getBody().toString());
        
    
        String bidsJsonQuery = "$.data.bids";
        DocumentContext updateContext = JsonPath.parse(original.getMessage().getBody().toString());
        List<String> updateJsonString = updateContext.read(bidsJsonQuery);
        
        System.out.println(resource.getMessage().getBody());
        
        //ArrayList test = (ArrayList) resource.getMessage().getBody(List.class);
        Object test = resource.getMessage().getBody();
        System.out.println("Test: " + test);

        
        System.out.println("Resource: " + resource.getMessage().getBody()); 
        return resource; 
    }
}

我可以使用resource.getMessage().getBody() 获取消息内容，它返回某种对象。如果我将它放入 println() 中，它会打印 Mongo 文档。当我检查与调试器的资源交换时，它看起来像这样：

交换 > in > 正文（“文档”）

其中包含一个哈希映射数组。在此示例中，其中一个哈希映射的键为“bids”，其值为数组列表。

您能否直接访问这些值？数组列表？我一直在试验，但无法通过 getBody()。

Answer 1

您的代码（Jsonpath 查询和转换）没问题，但“bids”不是List<String>

在您设置的消息正文中“出价”是List<List<Double>>。

当我获取您的 Json 字符串时，我可以像这样在纯 Java 中提取“出价”

    String jsonString = "{\"channel\": \"orderbook\", \"market\": \"BTC/USD\", \"type\": \"update\", \"data\": {\"time\": 1626139758.986094, \"checksum\": 195176195, \"bids\": [[32965.0, 0.0], [32962.0, 3.4015]], \"asks\": [], \"action\": \"update\"}}";
    String bidsJsonQuery = "$.data.bids";
    DocumentContext updateContext = JsonPath.parse(jsonString);
    List<List<Double>> bids = updateContext.read(bidsJsonQuery);
    for (List<Double> bid : bids) {
        for (Double singleBid : bid) {
            logger.info("{}", singleBid);
        }
    }

记录器的输出是

32965.0
0.0    
32962.0
3.4015 

顺便说一句：在您的代码中，您解析original 消息体。在你写的关于resource 正文的文本中。这是您的代码中的错误吗？