Apache Camel的routingSlip简单示例

比眉伴天荒 2022-08-04 15:43 149阅读 0赞

有些特殊的消息我们需要根据消息来动态的路由到一个多个结点。这是我们可以采用routing Slip的模式

<bean id="echo" class="com.lala.bean.Echo"></bean>
    <bean id="echo1" class="com.lala.bean.Echo1"></bean>
    <bean id="echo2" class="com.lala.bean.Echo2"></bean>
    <bean id="bean1" class="com.lala.bean.Bean1"></bean>
    
    <camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
    	<template id="camelContextTemplate" />
    	<route>
    		<from uri="timer://aaa?fixedRate=true&period=60000" />
    		<process ref="bean1" />
    		
    		<routingSlip uriDelimiter=",">
    			<header>routes</header>
    		</routingSlip>
    	</route>
    
    	<route>
    		<from uri="vm:s1" />
    		<to uri="bean:echo" />
    	</route>
    
    	<route>
    		<from uri="vm:s2" />
    		<to uri="bean:echo1" />
    	</route>
    
    	<route>
    		<from uri="vm:s3" />
    		<to uri="bean:echo2" />
    	</route>
    </camelContext>

package com.lala.bean;
    
    import org.apache.camel.Exchange;
    import org.apache.camel.Processor;
    
    public class Bean1 implements Processor 
    {
    	public void process(Exchange exchange) throws Exception 
    	{
    		exchange.getOut().setHeader("routes", "vm:s1,vm:s2,vm:s3");
    	}
    }

注意，这里的是以逗号分隔

package com.lala.bean;
    
    import org.apache.camel.Exchange;
    import org.apache.camel.Processor;
    
    public class Echo implements Processor 
    {
    	public void process(Exchange exchange) throws Exception 
    	{
    		System.out.println("+++++++++++++++"+this.getClass()+"++++++++++++++++");
    		System.out.println("echo:" + exchange.getIn().getHeaders());
    		System.out.println("echo:" + exchange.getProperty(Exchange.SLIP_ENDPOINT));
    		System.out.println("+++++++++++++++"+this.getClass()+"++++++++++++++++");
    	}
    }

package com.lala.bean;
    
    import org.apache.camel.Exchange;
    import org.apache.camel.Processor;
    
    public class Echo1 implements Processor 
    {
    	public void process(Exchange exchange) throws Exception 
    	{
    		System.out.println("+++++++++++++++"+this.getClass()+"++++++++++++++++");
    		System.out.println("echo1:" + exchange.getIn().getHeaders());
    		System.out.println("echo1:" + exchange.getProperty(Exchange.SLIP_ENDPOINT));
    		System.out.println("+++++++++++++++"+this.getClass()+"++++++++++++++++");
    	}
    }

package com.lala.bean;
    
    import org.apache.camel.Exchange;
    import org.apache.camel.Processor;
    
    public class Echo2 implements Processor 
    {
    	public void process(Exchange exchange) throws Exception 
    	{
    		System.out.println("+++++++++++++++"+this.getClass()+"++++++++++++++++");
    		System.out.println("echo2:" + exchange.getIn().getHeaders());
    		System.out.println("echo2:" + exchange.getProperty(Exchange.SLIP_ENDPOINT));
    		System.out.println("+++++++++++++++"+this.getClass()+"++++++++++++++++");
    	}
    }

最后，输出结果：

\+++++++++++++++class com.lala.bean.Echo++++++++++++++++  
\+++++++++++++++class com.lala.bean.Echo1++++++++++++++++  
\+++++++++++++++class com.lala.bean.Echo2++++++++++++++++  
echo1:\{breadcrumbId=ID-html-52597-1441419039411-0-3, routes=vm:s1,vm:s2,vm:s3\}  
echo1:vm://s2  
\+++++++++++++++class com.lala.bean.Echo1++++++++++++++++  
echo:\{breadcrumbId=ID-html-52597-1441419039411-0-3, routes=vm:s1,vm:s2,vm:s3\}  
echo:vm://s1  
\+++++++++++++++class com.lala.bean.Echo++++++++++++++++  
echo2:\{breadcrumbId=ID-html-52597-1441419039411-0-3, routes=vm:s1,vm:s2,vm:s3\}  
echo2:vm://s3  
\+++++++++++++++class com.lala.bean.Echo2++++++++++++++++

由此可以看出，最后路由到多个节点了