Apache camel发送一条简单的消息

Question

我有一个简单的camel MINA服务器，使用JAVA DSL，我的运行方式与这里记录的示例类似：

• 独立运行骆驼并让它在JAVA中继续运行
• MINA 2组件

我正在尝试创建一个托管在mina：tcp://localhost:9991（又名MyApp_B）的示例应用程序，该应用程序向托管在mina：tcp://localhost:9990（又名MyApp_A）的服务器发送一个非常简单的消息。

我想发送一条简单的消息，消息头中包含一个字符串（即“Hellow World！”）还有尸体上的地址。

public class MyApp_B extends Main{

    public static final String MINA_HOST = "mina:tcp://localhost:9991";

    public static void main(String... args) throws Exception {
        MyApp_B main = new MyApp_B();

        main.enableHangupSupport();

        main.addRouteBuilder(
                new RouteBuilder(){
                    @Override
                    public void configure() throws Exception {

                        from("direct:start")
                        .setHeader("order", constant("Hello World!"))
                        .setBody(constant(MINA_HOST))
                        .to("mina:tcp://localhost:9990");
                    }
                }
                );

        System.out.println("Starting Camel MyApp_B. Use ctrl + c to terminate the JVM.\n");
        main.run();
    }
}

public class MainApp_A {

    public static void main(String... args) throws Exception {
        Main main = new Main();
        main.enableHangupSupport();
        main.addRouteBuilder(new RouteBuilder(){

            @Override
            public void configure() throws Exception {
                from("mina:tcp://localhost:9990").bean(MyRecipientListBean.class, 
                        "updateServers").to("direct:debug");

                from("direct:debug").process(new Processor() {
                    public void process(Exchange exchange) throws Exception {
                        System.out.println("Received order: " +
                                exchange.getIn().getBody());
                    }
                });

            }

        });
        main.run(args);
    }

}

MyApp_A使用的Bean：

public class MyRecipientListBean {

    public final static String REMOVE_SERVER = "remove";
    public final static String ADD_SERVER = "add";

    private Set<String> servers = new HashSet<String>();

    public void updateServers(@Body String serverURI, 
            @Header("order") String order){


        System.out.println("===============================================\n");
        System.out.println("Received " + order + "request from server " + serverURI + "\n");
        System.out.println("===============================================\n");

        if(order.equals(ADD_SERVER))
            servers.add(serverURI);
        else if(order.equals(REMOVE_SERVER))
            servers.remove(serverURI);
    }
}

我已经完成了这段代码，但是，另一端的服务器似乎没有收到任何东西。因此，我有两个问题：

1. 我做错什么了吗

Answer 1

MyApp_A不发送任何消息。您需要向直接endpoint发送消息才能开始路由。

您还可以直接更改为计时器组件，使其每X秒触发一次，等等。

应要求添加了最新评论：

是的，路线也是直达的。只是要向direct发送消息，需要使用Camel。direct是一个内部Camel组件，用于在其endpoint（路由）之间发送消息。要向其发送消息，可以使用producer模板。参见《骆驼行动手册》第7章第7.7节。