如何通过Apache Camel为端口转发配置路由

Question

以下是编解码器和数据格式配置：

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、MLLP、SMTP、FTP、SMB等。请帮助我们配置端口转发路由，无论它们的协议如何。

Answer 1

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