这是关于 Camel 3 的第二个教程。在第一个（Camel 3 入门）中，我们讨论了如何设置一个基本的 Camel 3 项目并使用它运行一个简单的演示。现在我们将展示如何使用消息传递 API 连接到嵌入在 WildFly 分发中的远程 ArtemisMQ。

假设您已经建立了一个基本的 Camel 项目，让我们创建 Route 类，它负责将 JMS 消息发送到名为“demoQueue”的队列：

package com.mastertheboss.camel;

import org.apache.camel.builder.RouteBuilder;

public class MyJMSRouteBuilder extends RouteBuilder {
  @Override
  public void configure() throws Exception {
    from("timer:foo?period=3s").transform(constant("Hello World")).to("jms:queue:demoQueue");
    from("jms:queue:demoQueue").to("log:demoQueue");
  }
}

RouteBuilder 类将每 3 秒发送一次包含“Hello World”的 JMS 消息。

现在 Camel Main 类开始路线：

package com.mastertheboss.camel;
import org.apache.camel.main.Main;
public static void main(String...args) throws Exception {
  // use Camels Main class  

  Main main = new Main();
  // and add the routes (you can specify multiple classes)   
  main.addRouteBuilder(MyJMSRouteBuilder.class);
  // now keep the application running until the JVM is terminated
  (ctrl + c or sigterm) main.run(args);
}
}

就这样。在我们的 application.properties 中，我们将设置 JMS 组件并连接到 ActiveMQ Artemis 代理：

camel.main.name = CamelJMSHelloWorld  # properties used in the route myCron = 0/2 * * * * ?  # setup JMS component with connection to ActiveMQ Artemis broker camel.component.jms.connection-factory.brokerURL=tcp://localhost:61616 camel.component.jms.connection-factory.target-connection-factory.user=guest camel.component.jms.connection-factory.target-connection-factory.password=guest

现在让我们转到 WildFly 方面。首先创建一个绑定到端口 61616 的 JMS 远程接受器：

/socket-binding-group=standard-sockets/socket-binding=artemis-server:add(port=61616)  /subsystem=messaging-activemq/server=default/remote-acceptor=artemis-acceptor:add(socket-binding=artemis-server)

在 messaging susbsytem 中，您应该能够看到：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:8.0">             <server name="default">                 <!-- default configuration here -->                                   <remote-acceptor name="artemis-acceptor" socket-binding="artemis-server"/>             </server>         </subsystem>

反过来，remote-acceptor 引用绑定到端口 61616 的套接字绑定：

<?xml version="1.0" encoding="UTF-8"?><socket-binding-group name="standard-sockets" default-interface="public" port-offset="${jboss.socket.binding.port-offset:0}">
    	
   <socket-binding name="artemis-server" port="61616"/>
        
   <!-- Other bindings -->
     
</socket-binding-group>

接下来，让我们从 CLI 创建名为 demoQueue 的 JMS 队列：

jms-queue add --queue-address=demoQueue --entries=queues/demoQueue

最后，我们需要创建一个允许连接到 JMS 服务器的用户。在我们的 Camel 配置中，我们已经将其配置为 guest/guest，因此我们将使用 shell 脚本 add-user.sh 添加此用户：

$ ./add-user.sh   What type of user do you wish to add?   a) Management User (mgmt-users.properties)   b) Application User (application-users.properties) (a): b  Enter the details of the new user to add. Using realm 'ApplicationRealm' as discovered from the existing property files. Username : guest Password recommendations are listed below. To modify these restrictions edit the add-user.properties configuration file.  - The password should be different from the username  - The password should not be one of the following restricted values {root, admin, administrator}  - The password should contain at least 8 characters, 1 alphabetic character(s), 1 digit(s), 1 non-alphanumeric symbol(s) Password :  WFLYDM0098: The password should be different from the username Are you sure you want to use the password entered yes/no? yes Re-enter Password :  What groups do you want this user to belong to? (Please enter a comma separated list, or leave blank for none)[  ]: guest About to add user 'guest' for realm 'ApplicationRealm' Is this correct yes/no? yes Added user 'guest' to file '/home/francesco/jboss/wildfly-18.0.1.Final/standalone/configuration/application-users.properties' Added user 'guest' to file '/home/francesco/jboss/wildfly-18.0.1.Final/domain/configuration/application-users.properties' Added user 'guest' with groups guest to file '/home/francesco/jboss/wildfly-18.0.1.Final/standalone/configuration/application-roles.properties' Added user 'guest' with groups guest to file '/home/francesco/jboss/wildfly-18.0.1.Final/domain/configuration/application-roles.properties' Is this new user going to be used for one AS process to connect to another AS process?  e.g. for a slave host controller connecting to the master or for a Remoting connection for server to server EJB calls. yes/no? yes

我们完了！在启动 Camel Main 之前，我们需要为项目中找到的依赖项生成自动装配，因此我们将运行：

mvn camel-main:generate

现在我们终于可以运行 Camel 主程序了：

mvn exec:java

您应该能够从 CLI 或 Web 控制台看到队列 demoQueue 中正在接收消息：

/subsystem=messaging-activemq/server=default/jms-queue=demoQueue:read-resource(include-runtime=true) {     "outcome" => "success",     "result" => {         "consumer-count" => 1,         "dead-letter-address" => "jms.queue.DLQ",         "delivering-count" => 0,         "durable" => true,         "entries" => ["queues/demoQueue"],         "expiry-address" => "jms.queue.ExpiryQueue",         "legacy-entries" => undefined,         "message-count" => 0L,         "messages-added" => 24L,         "paused" => false,         "queue-address" => "jms.queue.demoQueue",         "scheduled-count" => 0L,         "selector" => undefined,         "temporary" => false     } }