程序员最近都爱上了这个网站  程序员们快来瞅瞅吧!  it98k网:it98k.com

本站消息

站长简介/公众号

  出租广告位,需要合作请联系站长


+关注
已关注

分类  

暂无分类

标签  

暂无标签

日期归档  

暂无数据

什么 Camel DSL 适合消息处理模式?

发布于2021-12-28 01:10     阅读(1480)     评论(0)     点赞(17)     收藏(2)


我有一种情况,我需要应用程序将消息发送到消息代理。另一个监听代理的客户端必须从队列中消费消息,确定它们是什么类型的消息,并将消息传递给适当的处理程序。

例如,如果一个FizzPOJO 被序列化为 JSON,然后发送到代理,另一个进程必须使用它,将它从 JSON 反序列化回一个Fizz实例,然后知道将其传递FizzFizzHandler处理器。同一个Buzz信息:它应该反序列化回一个Buzz并送至BuzzHandler

我相信路线的伪代码应该是这样的:

from(broker)
    .unmarshal().json(JsonLibrary.Gson)
    .dynamicRouter(someMechanismForDeterminingHandler)

相信动态路由器是解决这个问题的合适处理器,但我不是 EIP 专家,我可能不适合。

这里有两个大问题:

  • Camel-GSON 怎么知道一种类型的 JSON 代表一个Fizz对象,而另一种 JSON 字符串代表一个Buzz对象?
  • 应该使用什么 EIP/Camel DSL/处理器将反序列化的消息路由到正确的处理程序?

解决方案


您需要提前知道将某个字符串解组为哪个类。设置数据格式并在您想要解组到 Fizz 的任何地方引用它。Pojo -> JSON 更容易,因为 gson 可以通过查看手头的对象来确定格式。

GsonDataFormat json2Fizz = new GsonDataFormat(Fizz.class);
GsonDataFormat json2Buzz = new GsonDataFormat(Buzz.class);

最好的方法可能是在解组之前进行路由。使用基于内容的路由器,它可以轻松跟踪路由。

如果您在 json 本身中有一些东西可以让您识别 Fizz 或 Buzz,您可以使用表达式语言JsonPath,它允许您直接在 json 字符串上路由/过滤等。如果没有,您可能希望传递一个标头,以某种方式说明您可以路由的消息类型。



所属网站分类: 技术文章 > 问答

作者:黑洞官方问答小能手

链接:http://www.javaheidong.com/blog/article/368668/cd64f50558c3fc7ebc63/

来源:java黑洞网

任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任

17 0
收藏该文
已收藏

评论内容:(最多支持255个字符)