Powerful svn merge

Since I'm always using svnmerge.py to do the merge stuff, I have no chance to go through the svn merge doc.
Now I just found svn merge is so powerful.

If you just want to merge one pic of change from trunk to branch, you don't have to do the

svnmerge.py init

svnmerge.py merge ...

You can just type in you working copy directory

svn merge -c VERSION YOUR_TRUNK_URL [WCPATH]

If you want to revert the change for the svn server side , not just your working copy

svn merge -rVERSION:VERSION-1 SOURCE [WCPATH]

What's new in Camel 2.0

I have been asked by lots of friend who are using or going to using Camel, what's new in Camel 2.0.
I just found Claus set up a good wiki page for all these kind informations.
Some high lights includes:

New features:

• Make more endpoints easily configurable as beans in Spring XML.
• Improve the DSL
• ...
  

API Changes

• Remove the use of generics on Component, Exchange, Producer, Consumer
• Change to use verb for EIP action
• ...
  

You can find the release notes about Camel 2.0 (Working in progress) here.

Camel中的几个重要概念之Routes, RouteBuilders 和 Java DSL

Route

一个route就是将一个输入队列中获得的消息，通过一步一步地设置好的逻辑判断（例如过滤器和路由规则）到达一个目标队列中（如果有的话）。Camel为应用开发者提供了两种途径来定义这些路由规则。一个是通过XML来定义路由信息，有关这部分的内容不会在本文档中讨论。另一种方式就是通过Camel所谓的Java DSL(domain-specific language) 来定义。

Introduction to Java DSL

对于许多人来说，要实现一个“domain-specific language” （面向领域的语言）涉及到了一个能够处理这个特定领域语言的关键字以及语法的编译器或者是解释器。对于Camel来说，它没有这么做。在Camel文档中一直都在使用的“Java DSL”而不是 “DSL” ，其目的就是想避免混淆这两个概念。Camel中的“Java DSL”是一个可以像DSL一样被使用的类库，除此之外它还使用了大量Java的语义。你可以看一下下面的例子，在例子下面的备注里， 解释了这个例子的中所用的组件。

Example of Camel's "Java DSL"
RouteBuilder builder = new RouteBuilder() {
public void configure() {
from("queue:a").filter(header("foo").isEqualTo("bar")).to("queue:b");
from("queue:c").choice()
.when(header("foo").isEqualTo("bar")).to("queue:d")
.when(header("foo").isEqualTo("cheese")).to("queue:e")
.otherwise().to("queue:f");
}
};
CamelContext myCamelContext = new DefaultCamelContext();
myCamelContext.addRoutes(builder);

上面例子的第一行创建一个一个RouteBuilder的匿名类的实例，这个匿名类需要实现 configure（）方法。
camelContext.addRoutes(RouterBuilder builder) 方法中调用了builder.setContext(this)方法，这样RouteBuilder对象就获得了与之对应的CamelContext的，然后调用builder.configure()方法。在configure方法中，可以调用例如 from()， filter(), choice(), when(),isEqualTo(), otherwise()以及to() 方法。
RouteBuilder.from(String uri) 方法会调用与之对应的CamelContext的getEndpoint(uri)方法来获得指定的Endpoint，并用一个FromBuilder包装这个Endpoint。这样 FromBuilder.filter(Predicate predicate) 方法就会创建一个在header("foo").isEqualTo("bar")这个表达式基础创建的Predicate（所谓的条件）创建一个FilterProcessor对象。就这样， 通过定义这些操作我们逐渐构建出了一个Route对象（使用RouterBuilder进行包装的）并且将这个Route对象添加进了与RouteBuilder所关联的CamelContext中。

Critique of Java DSL

在camel的在线文档中比较了Java DSL与建立在XML基础上的Spring配置文件的在配置routes和endpoint方法优势。特别是Java DSL比 XML 来说要精简很多。还有需要指出的是，现在很多集成开发环境都提供了一个自动补全的功能， 当然这种功能可以编写Java DSL的过程中使用，这也可以大大降低开发者编写Java DSL的难度。

当然在Camel的文档中还忽略了一些内容，就是通过一个解析器来处理存放在外部的DSL。当前Camel并没有提供这也的解析器，并且我也不知道Camel的开发维护人员是否打算做这样一个解析器。我像这个DSL解析器应该提供一个比当前Java DSL更大的一个好处。这个DSL可以通过巴柯斯范式来定义语法，这样Camel的用户可以通过阅读巴柯斯范式来获取书写DSL的知识，而不是像现在需要花费大量的时间通过阅读RouterBuilder类的API来获取。

Camel中的几个重要概念之 Processor

Processor

Processor接口是用来表示一个处理消息的类， 这个接口的定义如下。

Processor
package org.apache.camel;
public interface Processor {
void process(Exchange exchange) throws Exception;
}

注意Process()方法中的参数是一个Exchange而不是一个Message。 这样的定义提供了更大的灵活性。例如我们可以在Process方法中调用exchange.getIn()来获取输入的消息，并处理它。 如果在处理过程中发生了错误，我们可以通过调用 exchange.setException() 设置这个异常。

对于一个应用开发这来说，他们可以通过实现Process接口来实现他们的业务逻辑。然后，在Camel内部库中， 这里有很多类通过实现了Process接口来提供EIP book中设计模式的实现。例如 ChoiceProcessor就实现了一个消息路由的模式。它通过使用和if-then-else相当的定义来完成一个消息从一个输入队列到多个输出队列的路由。另一个例子就是FilterProcessor，当通过这个Processor的处理的消息不能满足某个条件时，这个消息将被抛弃。

Camel中的几个重要概念之 Message和Exchange

Message

Message 接口提供了一个对单个消息的抽象，这些消息可以是一个请求，回复或者是一个异常。
对于每个Camel是支持的通讯技术来说，都需要提供一个Message接口的实现。例如JmsMessage就提供了一个Message接口的JMS实现. 在message接口中提供一个get/set方法来访问message id, body 以及message中每个单独header。
而exchange接口则表示了对message exchange的抽象， 也就是说一个请求消息以及与之对应的应答消息或者异常消息肯定会与一个Exchange相关联。对于Camel来说，请求和应答以及异常消息都分别被称为in, out 以及 fault message。
对于每个Camel所支持的通信技术来说来说，都需要一个实现了Exchang接口的的类。 例如JmsExchange 类就提供了一个Exchange接口的JMS实现。对于Exchange接口来说它提供的公共的API很有限。 但是对于实现Exchange的具体的类来说，它可以添加很多与其支持的通讯协议相关操作。
应用层的程序应该很少直接访问Exchange（或者是实现Exchange的类）。由于Camel很多类都大量使用了有关（Exchange）的泛型定义，所有你会在很多的类和方法中看到Exchange接口的身影。

Camel中的几个重要概念之 Components

Components

Component 是一个容易混淆的名词，可能使用EndpointFactory会更合适，因为Component是创建Endpoint实力的工厂类。例如如果一个Camel应用使用了几个JMS 队列，那么这个应用首先需要创建一个叫JmsComponent（实现了Component接口）的实例，然后应用会调用这个JMSComponent对象的createEndpoint()方法来创建一个JmsEndpoint对象（这个对象实现了Endpoint接口）。事实上，应用代码并没直接调用Component.createEndoint() 方法，而是CamelContext对象通过找到对应的Component对象（我马上会在后续的文章中介绍）,并调用createEndpoint() 方法来实现的。

myCamelContext.getEndpoint("pop3://john.smith@mailserv.example.com?password=myPassword");

在getEndpoint()中使用的参数就是URI。这个URI的前缀(: 之前的那部分内容）描述了一个组件的名字，CamelContext对象内部维护着一个组件名字与Component对象的映射表。对于上面给定的URI例子来说，CamelContext对象会根据pop3前缀找到MailComponent类，然后CamelContext对会调用MailComponent的createEndpoint("pop3://john.smith@mailserv.example.com?password=myPassword") 方法。在createEndpoint()方法中， 将把URI分割成一段段小的参数，这些小参数将被用来设置生成的Endpoint对象。

在上一段中， 我提到的CamelContext对象维护了一个组件名到Component对象的映射表。但这个映射表是如何产生的呢？这里可以在通过代码调用CamelContext.addComponent(String componentName, Component component)来实现。 下面的例子就是展示了如何给一个MailComponent对象注册上三个不同的名字。
Component mailComponent = new org.apache.camel.component.mail.MailComponent();
myCamelContext.addComponent("pop3", mailComponent);
myCamelContext.addComponent("imap", mailComponent);
myCamelContext.addComponent("smtp", mailComponent);

第二个方法也是最常用的方法，就是通过CamelContext对象来实现一个懒初始化。这个方法依赖于一套Camel内部的定义Component发现规则， 开发者只要在实现Component接口的时候按照这一规则设置，就可以保证CamelContext能够正常发现这一Component。这里我们假设你所写的Class名字为 com.example.myproject.FooComponent， 并且你想让Camel自动将这个component和"foo”这个名字相对应。为了做到这一点，你需要先写一个叫做"META-INF/services/org/apache/camel/component/foo" 属性文件， 注意这个文件没有".properties"作为后缀名，在这个属性文件中只有一个class的条目，而这个条目的只就是你所写的类的全名。如下所示

META-INF/services/org/apache/camel/component/foo
class=com.example.myproject.FooComponent

如果你还想让Camel将上面的类和”bar” 这个名字联系起来，那你需要在同样的目录下在创建一个相同内容叫bar的文件。一旦完成了这些配置， 你可以把 com.example.myproject.FooComponent class和这些配置文件一同打成一个jar 包，然后把这个jar包放你的CLASSPATH中。这样Camel就会通过分析这些属性文件的class 项目，通过使用reflectionAPI创建这个指定的类的实例。

正如我在Endpoint中说描述的， Camel提供了对多种通信协议一个开箱即用的支持。这种支持是建立在实现了Component接口的类以及让CamelContext对象自动建立映射关系的配置文件基础之上的。

在这一节的开始， 我使用的这个例子来调用CamelContext.getEndpoint()。
myCamelContext.getEndpoint("pop3://john.smith@mailserv.example.com?password=myPassword");

在最开始举这个例子的时候，我说这个getEndpoint()方法的参数是一个URI。我这么说是因为Camel的在线问答以及Camel的源代码就把这个参数声明为一个URI。在现实生活中，这个参数是按照URL来定义的。这是因为Camel会从参数中通过一个简单的算法查找第一：来分析出组件名。为了了解其中的奥妙，大家可以回想一下我在前面 URL，URI，URN和IRI是什么中谈到的 一个URI可以是URL或者URN。 现在让我们来看一下下面的getEndpoint()调用。
myCamelContext.getEndpoint("pop3:...");
myCamelContext.getEndpoint("jms:...");
myCamelContext.getEndpoint("urn:foo:...");
myCamelContext.getEndpoint("urn:bar:...");

Camel会先找出这些component的标识，例如 "pop3", "jms", "urn" 和 "urn"。如果"urn:foo" 和"urn:bar" 能够别用来识别component，或者是使用"foo" 和"bar" （这一可以跳过这个"urn:"前缀）。所以在实际的编程中，大家更喜欢使用URL来制定一个Endpoint（使用":..."来描述的字符串）而不是用一个URN（ 使用"urn::..."来描述的字符串）。正因为我们没有安全按照URN的规定的参数来调用getEndpoint() 方法， 所以这个方法的参数更像一个URL而不是一个URI。

Camel 中的几个重要概念之 CamelContext与CamelTemplate

CamelContext

CamelContext是对Camel 运行时的一个抽象， 一般来说一个应用里面会有一个CamelContext 对象。一个典型的Camel 应用按照下面几个步骤执行。

1. 创建一个CamelContext对象。
2. 向CamelContext对象中添加Endpoints或者是Components
3. 向CamelContext对象中添加路由(routes)规则
4. 调用CamelContext的start() 方法，这样可以启动Camel内部有关消息发送，接收，处理所使用的线程。
5. 当调用CamelContext的stop() 方法时，Camel 会将妥善关闭所有endpoint和Camel内部的线程。注意在调用CamelContext.start() 方法时并不一定阻塞， 而是在启动完每个Comonent和Endpoint的内部线程后start() 方法返回。而CamelContext.stop()方法会等待所有Endpoint和Component的内部线程都结束后 stop() 方法才返回。如果你没有在你的Camel 应用程序中调用CamelContext.start() 方法，那么由于内部线程并没有被创建那些消息将不会被处理。 如果你没有在你的Camel应用程序中调用CamelContext.stop()方法，那你你的应用将不会正常退出。如果你在一个JUnit 测试没有调用CamelContext.stop()方法，这可能会造成消息不能被完整地处理，而导致测试运行失败。

CamelTemplate

Camel曾经使用一个叫CamelClient的类来发送消息， 后来为了和其他的open-source项目类似功能的模块例如Spring中 TransactionTemplate 和 JmsTemplate， 命名一致而改名为CamelTemplate。
这个CamelTemplate（注现在已经改名为ProducerTemplate）类对CamelContext进行了一个简单的封装。在CamelTemplate中有向一个Endpoint（将在Endpoint中讨论）发送Message或者Exchange的方法， 这部分的内容将在 Message和Exchange中进行讨论。 CamelTemplate提供了一条向Camel内部路由中的Endpoint发送消息的道路， 这样消息就可以在Camel内部的路由规则（参考 Routes，RouteBuilders 和JAVA DSL）里面流动而到达指定的目标节点了。

Camel中的几个重要概念之 Endpoint

前段时间和一些朋友聊过Apache Camel， 他们都反映一个问题就是有关Camel构架的介绍文档很少。其实在Camel发行包中所带的文档Camel Manual 就有一段对Camel内部设计有一个比较好的介绍。我在这里把其中大部分的内容翻译成了中文，希望能对大家了解Camel有所帮助。

Endpoint
Endpoint这个词以前经常被用来描述进程间通信。例如，在客户端与服务器之间的通讯，客户端是一个Endpoint和服务器是另外一个Endpoint。根据不同的情况下，一个Endpoint可能指的地址，如一个TCP通信的（主机：端口）对，也可能是指与这个地址相对应的一个软件实体。例如，如果大家使用“ www.example.com:80 ”来描述一个Endpoint。这些Endpoint可能是指实际的端口上的主机名称（即地址） ，也可能是指与地址相关的的网页服务器（即在这个地址之上运行的软件地址） 。通常情况下，这种地址和在这个地址之上运行的软件之前的区别并不是一个重要问题。

一些中间件技术可以使一些软件实体的绑定在相同的物理地址上。例如， CORBA是一种面向对象的远程过程调用（ RPC ）的中间件标准。如果一个CORBA的服务器进程包含几个对象，客户端可以与这些在同一物理地址（主机：端口）之上的任意对象进行通讯 ，但当客户端想与特定对象进行通讯是， 需要指定这个对象的逻辑地址（在CORBA中称为IOR）。 IOR是由物理地址（主机：端口） ，以及一个唯一识别的对象在其服务器进程标识所组成。 （IOR还包含了与此本次讨论无关其他一些额外的信息。）当谈论CORBA的时候，有些人可能会使用“endpoint”来描述CORBA的服务器的物理地址，而其他人可能使用Endpoint来描述一个CORBA对象的逻辑地址，和其他人可能会使用这个词来描述下面这些：

• CORBA的服务器进程的物理地址（主机：端口）
• CORBA对象的逻辑地址（主机：端口加上编号）
• CORBA的服务器进程（相对重量级的软件实体）
• 一个基于CORBA对象（一个轻量级的软件实体）

正因为如此，你可以看到Endpoint这个词至少在两方面是模糊的。首先，它可能是指一个地址或联络软件实体在该地址。其次，粒度上可能是模糊的：一个重量级与轻量级的软件实体，或物理地址与逻辑地址。了解了Endpoint这个名词在不同场景下的不同描述可以帮助我们更好地理解为什么Camel中的Endpoint。

Camel中的Endpoint支持许多不同的通信技术。以下是Camel所支持Endpoint。

• 一个JMS队列。
• 一个Web服务。
• 一个文件。文件可能听起来不是一个典型的Endoint端点。但是你可以这么想，一些应用系统会把信息写到一个文件中，然后另一个应用程序可能读取该文件获得这一信息。
• 一个FTP服务器。
• 一个电子邮件地址。客户可以发送邮件到电子邮件地址，和一台服务器可以读取的这个从邮件服务器传入的邮件。
• 一个POJO （普通旧Java对象）。