gpt4 book ai didi

将Camel消息路由到嵌入WildFly的Artemis上

转载 作者:知者 更新时间:2024-03-12 08:30:49 28 4
gpt4 key购买 nike

这是关于 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     } }

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com