如何配置Apache Camel端口转发路由？

这里是编解码器和数据格式配置：如何配置Apache Camel端口转发路由？

package com.chorke.boot.jproxy.config; 

import org.apache.camel.component.hl7.HL7DataFormat; 
import org.apache.camel.component.hl7.HL7MLLPCodec; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.context.annotation.ImportResource; 

@Configuration 
@ImportResource({"classpath*:/META-INF/camel/applicationContext-camel.xml"}) 
public class ApacheCamelConfig { 

    @SuppressWarnings("unused") 
    private static final Logger log = LoggerFactory.getLogger(ApacheCamelConfig.class); 

    @Bean 
    public HL7MLLPCodec hl7codec() { 
     HL7MLLPCodec hl7codec = new HL7MLLPCodec(); 
     hl7codec.setCharset("UTF-8"); 
     return hl7codec; 
    } 

    @Bean 
    public HL7DataFormat hl7Format() { 
     HL7DataFormat hl7Format = new HL7DataFormat(); 
     return hl7Format; 
    } 
}

这里是端口转发路线：

package com.chorke.boot.jproxy.route; 

import org.apache.camel.builder.RouteBuilder; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 

public class ProxyRoute extends RouteBuilder { 

    private static final Logger log =LoggerFactory.getLogger(ProxyRoute.class); 

    @Override 
    public void configure() throws Exception { 

     from("mina2://tcp://0.0.0.0:22210?codec=#hl7codec&sync=true").process(new Processor() { 
      public void process(Exchange exchange) throws Exception { 
       String body = exchange.getIn().getBody(String.class); 
       log.info("Port-Forwarded body:\n {}", body); 
      } 
     }).to("mina2://tcp://192.168.0.10:22210?codec=#hl7codec&sync=true").end(); 

     from("mina2://tcp://0.0.0.0:22211?codec=#hl7codec&sync=true").process(new Processor() { 
      public void process(Exchange exchange) throws Exception { 
       String body = exchange.getIn().getBody(String.class); 
       log.info("Port-Forwarded body:\n {}", body); 
      } 
     }).to("mina2://tcp://192.168.0.11:22211?codec=#hl7codec&sync=true").end(); 

    } 
}

路线夏日是：

============================================ 
    request     forwarded 
tcp ip:port    tcp ip:port 
============================================ 
0.0.0.0:22210   192.168.0.10:22210 
0.0.0.0:22211   192.168.0.11:22211 
============================================

它工作正常，它的协议特定于MLLP。但是我们的目标是不管协议的路由如何发送任何请求。可以说它可以处理任何类型的请求，不限于HTTP,REST,SOAP,,SMTP,,SMB等。请您帮助我们配置端口转发路由，而不管它们的协议如何。

来源

2015-10-29 Shahed Hossain

Apache Camel中不支持协议检测和路由端口转发。你最好找到一些可以做到这一点的现有产品。

来源

2015-10-29 07:19:43

如何配置Apache Camel端口转发路由？

回答

相关问题