这是关于 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 消息。

Hiện nay 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)

hiện hữu messaging susbsytem 中，您应该能够看到：

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

接下来，让我们从 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 } }