从代码内部:骆驼路由引擎第一部分

因此,最近我重新燃起了对Apache Camel工作原理的兴趣。 Camel是一种功能强大的集成工具,用途非常广泛,但是只要我投入使用,我都会忍不住想:“嗯,这到底是怎么做到的!” …猜想我只是有一个诀窍,不只是接受它的美妙。我想知道为什么。

如果您过去一直关注我的一些文章,您会记得我确实有一篇博客文章,深入探讨了Camel DSL API的工作原理 。 更具体地说,您如何神奇地键入“ from(..)”,“ choice(..)”,“ simple(..)”等,并且DSL足够聪明,足以知道您的意思以及如何将所有内容串在一起。 如果您对所有操作方式都感兴趣,请在该帖子上花点时间。 请注意,其中有一些冗长而冗长的UML类图。

因此,如果您回想起前一篇文章,则DSL(无论是Java DSL,XML还是Scala或任何其他)都具有非常特殊的作用。 它可以帮助集成路线的作者非常清楚地表达自己的意图,然后将其构建为一个名为RouteDefinition的抽象。 RouteDefinition是您路线的“蓝图”,并且了解您所有的处理器 , EIP和组件 。 您可以考虑从(..)调用的任何时间是新RouteDefinition的开始。 其余路线赋予其形状。 因此,对于每个from(..),都有一个到RouteDefinition的一对一映射。

因此,当CamelContext启动时,它将收集所有RouteDefinition并开始从它们中构建一条路由。 看一下DefaultCamelContext#doStartCamel作为所有这些的入口点。 除其他重要事项外,例如将注册表,端点,启动基本服务,管理等放在一起,您将看到对DefaultCamelContext#startRouteDefinitions的调用。 这告诉RouteDefinitions构建Route对象,即路由交换的实际使用者(输入)+处理器(输出)的管道 。

下一个方框将详细介绍这一切的工作原理。 就像以前有关Camel内部工作的博客文章一样,这个细节主要是给我的:即,将来当我忘记了一半的时候,我想复习一下。 一些想为骆驼做贡献的人可能会发现这很有趣。 对于其他所有人。.随时跳过此块。

–开始详细部分–

DefaultCamelContext将遍历每个RouteDefinition ,并将尝试构建Route S和RouteContext S的列表。

快速绕道:

什么是RouteContext ? 简单来说,您可以将其视为Route的大脑,以及路由特定配置所处的地方(流缓存,跟踪,处理故障等)。 它了解“来自”消费者,管道的其余部分,拦截策略,路由策略,并能够构造将在交换机上运行的Route。

这可能会造成混淆,因为在实际上它们正在构建RouteContext和构建Route时,有许多名为“ addRoutes()”的方法的调用。 但是,将其放在一边。 因此,对RouteDefinition#addRoutes(..)的调用将返回RouteContext对象的列表。 它还将填充(最初为空)路由的列表。 这里的重数基本上是n到n。 因为您可以有多个RouteDefinition 输入 (例如,通过将多个from(..)。from(..)串在一起),所以可以预期到路由的单个1-to-1 RouteContext,以及一对PER from( )。 因此,在前面的示例中,列表中将有两个RouteContext和两个Route。 在对addRoutes(..)的调用中,它还会尝试将输出定义转换为真实的Processors。 处理器是Route对象的基础。 每个处理器都是基于其各自的定义(例如ChoiceDefinition,LogDefinition)构建的,但最终被包装在Channel对象中并添加到RouteContext中。

序列

因此,总结一下, RouteDefinition将创建Route,RouteContext,并将各个输出定义转换为Processors。 创建这些路由后,将根据新创建的Route + RouteContext对创建一个RouteService ,并使用CamelContext建立该路由服务,以便稍后启动和控制路由的生命周期。

–结束详细部分–

块

因此,…一旦初始化了RouteService ,就需要启动路由,这取决于它们是否自动启动以及它们的顺序。 再次看一下DefaultCamelContext#doStartCamel ,对底部的是对DefaultCamelContext#doStartOrResumeRoutes的调用。 这将遍历我们的RouteService S并为路线确定正确的启动顺序,然后启动它们。

路线分为两个阶段:

  • 热身:在热身阶段,我们浏览所有路径并启动所有“输出”或处理器/设备。 骆驼要注意确保
    首先发生这种情况是因为我们不希望在所有“输出”可用之前就让“输入”或使用者启动。
  • 启动/恢复:启动使用者! 这是特定于端点/组件的。 例如,JMS使用者将开始侦听目的地。

注意,在生命周期的这些阶段的所有阶段,都有可以调用的回调,以便您可以插入此生命周期并添加自己的自定义启动代码以与应用程序协调。 看看Camel API中可用的回调类型LifecylceStrategy

那里有它。 这是将路由定义转换为实际路由然后启动的方式。

在第二部分中,我希望探讨如何将处理器链接在一起,包括使用AsyncProcessor进行更高级的链接。

参考:在Christian Posta – Software Blog博客上,使用我们的JCG合作伙伴 Christian Posta 使用k最近邻+遗传算法创建价格模型 。

翻译自: https://www.javacodegeeks.com/2013/08/from-inside-the-code-camel-routing-engine-part-i.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/367075.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java比较时间sql_如何正确比较日期 java.sql.Date

import java.sql.Date;...............例如今天是2010-12-2Date d1 new Date(System.currentTimeMili());Date d2 new Date(System.currentTimeMili()1);//比d1晚1毫秒日期上,我们认为d1和d2是相等的但是System.out.println(d1.before(d2));输出结果是true;其实我…

各种推导式合集

推导式的套路 之前我们已经学习了最简单的列表推导式和生成器表达式。但是除此之外,其实还有字典推导式、集合推导式等等。 下面是一个以列表推导式为例的推导式详细格式,同样适用于其他推导式。 variable [out_exp_res for out_exp in input_list if o…

javascript总结36:DOM-点击按钮切换图片案例

<!DOCTYPE html> <html lang"zh-CN"> <head><meta charset"UTF-8"><title>Title</title> </head><body><a href"http://www.baidu.com" id"link">点击切换</a> <br&g…

一个9年的技术最近一直担心找不到工作

我是一个从早期ASP ACCESS程序员慢慢转到一名从设计、前端到PHP后台MYSQL数据库都做的技术。07年末初入上海第一份工作1350RMB/月做ASP开发。到了春节离职了&#xff0c;当时只因同事间的关系没那么和谐&#xff0c;感觉不开心才提出的离职&#xff0c;试用期3个月&#xff0c;…

Spring MVC控制器的单元测试:REST API

Spring MVC提供了一种创建REST API的简便方法。 但是&#xff0c;为这些API编写全面而快速的单元测试一直很麻烦。 Spring MVC测试框架的发布使我们可以编写可读&#xff0c;全面且快速的单元测试。 这篇博客文章描述了如何使用Spring MVC Test框架编写REST API的单元测试。 在…

flask框架基本使用(2)(响应与重定向)

#转载请留言联系 flask 框架基本使用(1)&#xff1a;https://www.cnblogs.com/chichung/p/9756935.html 1. flask 自定义返回状态码与响应头 from flask import Flask,make_responseappFlask(__name__)app.route("/") def index():#666是指定的状态码&#xff0c;nam…

web.xml中webAppRootKey

<context-param> <param-name>webAppRootKey</param-name> <param-value>myproject.root</param-value> </context-param> 1、<param-value>里的值可以随便写配置。如果不配置默认值是"webapp.root"。 2、<param-value…

mpvue小程序以及微信直播踩坑总结

前段时间刚写完一个mpvue的小程序&#xff0c;现在得闲必须赶紧记录和总结一下&#xff0c;不然很多东西又要忘了 我是比较熟悉vue的语法&#xff0c;但是也犹豫过是用原生还是用mpvue&#xff0c;因为那时候原生小程序已经相当成熟而mpvue才刚出来&#xff08;踩坑和填坑的前…

适用于高级Java开发人员的十大书籍

Java是当今最流行的编程语言之一。 有很多适合初学者的书籍。 但是对于那些使用Java进行过一段时间编程的人来说&#xff0c;其中有些人看起来有些简单和多余。 初学者的书没有带来新鲜有趣的想法。 但是&#xff0c;高级Java书籍并不总是一应俱全&#xff0c;部分原因是因为它…

python apscheduler执行_python apscheduler 每两小时执行一次

from datetime import datetimefrom apscheduler.schedulers.blocking import BlockingSchedulerdef job_function():print("Hello World")sched BlockingScheduler()每2小时触发sched.add_job(job_function, interval, hours2)sched.start()设定执行区间sched.add_…

Ajax知识总结

一 AJAX Asynchronous JavaScript and XML&#xff08;异步的 JavaScript 和 XML&#xff09;。 AJAX 不是新的编程语言&#xff0c;而是一种使用现有标准的新方法。AJAX 最大的优点是在不重新加载整个页面的情况下&#xff0c;可以与服务器交换数据并更新部分网页内容。AJAX …

Leetcode 456. 132 Pattern

题目的意思就是给你一个数组 里面一堆数&#xff0c;你是否能找到这样三个数&#xff0c;第一个数比第三个数小&#xff0c;第二个数最大。比如 1, 3, 2 或者 4, 9, 5 这种&#xff0c;数字可以不连续在一起&#xff0c;但是要保证顺序不变&#xff0c;只要有这么一组数就可以…

「起点订阅页」Checkbox 美化引发的蝴蝶效应

本文作者&#xff1a;任家乐 原创声明&#xff1a;本文为阅文前端团队 YFE 成员出品&#xff0c;请尊重原创&#xff0c;转载请联系公众号 (id: yuewen_YFE) 获取授权&#xff0c;并注明作者、出处和链接。 性能风暴 「据说亚马逊雨林的一只蝴蝶偶尔扇动几下翅膀&#xff0c;可…

python polar函数_Python可视化很简单,可是你会吗?python绘制饼图、极线图和气泡图,让我来教教你吧,一文教会!!!...

matplotlib库作为Python数据化可视化的最经典和最常用库&#xff0c;掌握了它就相当于学会了Python的数据化可视化&#xff0c;今天呢&#xff0c;咱们就一起来聊聊关于Python如何去绘制饼图、极线图和气泡图吧好啦&#xff0c;废话少说&#xff0c;咱们就开始吧&#xff01;用…

Java中的访问者设计模式–示例教程

访客模式是行为设计模式之一 。 当我们必须对一组相似类型的对象执行操作时&#xff0c;将使用访问者模式。 借助访问者模式&#xff0c;我们可以将操作逻辑从对象移动到另一个类。 例如&#xff0c;假设有一个购物车&#xff0c;我们可以在其中添加不同类型的项目&#xff08…

函数递归与二分法

1.什么是函数递归 函数的递归调用是函数嵌套调用的一种特殊形式&#xff0c; 特殊在调用一个函数的过程中又直接或者间接地调用了该函数本身 递归本质就是一个循环的过程&#xff0c; 但是递归必须满足两个原则&#xff1a; 1.每进入下一层递归&#xff0c;问题的规模必须有所减…

使用Oracle WebLogic创建部署计划

创建部署计划 部署计划是JSR-88部署标准的一部分&#xff0c;尽管在该标准中未明确说明。 部署计划是一个XML文档&#xff0c;用于定义自定义WebLogic Server部署环境。 此配置可用于覆盖在应用程序归档文件中定义的特定设置。 有许多原因可能导致您不希望修改应用程序存档的原…

记录一个前端架构的想法

前端&#xff0c;真的是让我哭笑不得的职业&#xff0c;从几年前作为打酱油的理想职业到现在的热门职业&#xff0c;无疑在这个过程中&#xff0c;门槛变高了&#xff0c;而且还是非常高。一大堆的框架和库&#xff0c;像什么vue啦、react啦、angular啦、webpack啦等等等等。让…

java文件解压文件_java 文件解压缩

直接上代码&#xff1a;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.IOException;import java.io.I…

JAVA 遍历Map对象

方式一 这是最常见的并且在大多数情况下也是最可取的遍历方式。在键值都需要时使用。 Map<Integer, Integer> map new HashMap<Integer, Integer>(); for (Map.Entry<Integer, Integer> entry : map.entrySet()) { System.out.println("Key " …