NameNotFoundException：通过 logstash 连接到远程队列

Question

我在 JBoss EAP 7.1（在 standalone.xml 中定义）上部署了一个队列，该队列由 ActiveMQ Artemis（模块名称 xmlns="urn:jboss:domain:messaging-activemq:2.0"）管理，同时一次我想使用 logstash 中的 JMS 插件（使用 JNDI）连接到该队列以使用已部署的应用程序在我的 JBoss 服务器上发送的消息，但是当我尝试时我得到一个 NameNotFoundException对于连接工厂（logstash conf 文件中的属性 jndi_name）。

我试图找到默认的连接工厂 JNDI 条目，但即使那样也没有用。

所以我想知道连接工厂是由消息代理创建的还是默认存在于客户端？因为如果我没记错的话，连接工厂是连接到代理和队列的唯一方法，如果我错了请更正，但它们必须默认存在于客户端。

我希望你们能帮助我，这是我的 logstash conf 文件：

input {
    jms {
        # Logstash Configuration Settings. 
        include_header => false
        include_properties => false
        include_body => true
        use_jms_timestamp => false
        destination => "AuditTrailMDB"
        pub_sub => false
        # JNDI Settings
        jndi_name => 'queueConnectionFactory'
        jndi_context => { 
         'java.naming.factory.initial' => 'org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory'
         'java.naming.security.principal' => 'admin'
         'java.naming.provider.url' => 'tcp://localhost:5445?type=QUEUE_CF'
         'java.naming.security.credentials' => 'admin'
        }
        # Jar files to be imported
        require_jars=> ['/home/Alternant/logstash/dependencies/jboss-client.jar', 
                        '/home/Alternant/logstash/dependencies/artemis-ra.jar',
                        '/home/Alternant/logstash/dependencies/ironjacamar-core-impl.jar',
                        '/home/Alternant/logstash/dependencies/ironjacamar-core-api.jar',
                        '/home/Alternant/logstash/dependencies/ironjacamar-common-api.jar']
    }
 }output{
     stdout{}
 }

这是我在 standalone.xml:

中的队列定义

<subsystem xmlns="urn:jboss:domain:messaging-activemq:2.0">
    <server name="default">
        <security-setting name="#">
            <role consume="true" create-non-durable-queue="true" delete-non-durable-queue="true" name="guest" send="true"/>
        </security-setting>
        <address-setting dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" message-counter-history-day-limit="10" name="#" page-size-bytes="2097152"/>
        <http-connector endpoint="http-acceptor" name="http-connector" socket-binding="http"/>
        <http-connector endpoint="http-acceptor-throughput" name="http-connector-throughput" socket-binding="http">
            <param name="batch-delay" value="50"/>
        </http-connector>
        <in-vm-connector name="in-vm" server-id="0">
            <param name="buffer-pooling" value="false"/>
        </in-vm-connector>
        <remote-connector name="netty" socket-binding="remote-messaging"/>
        <http-acceptor http-listener="default" name="http-acceptor"/>
        <http-acceptor http-listener="default" name="http-acceptor-throughput">
            <param name="batch-delay" value="50"/>
            <param name="direct-deliver" value="false"/>
        </http-acceptor>
        <in-vm-acceptor name="in-vm" server-id="0">
            <param name="buffer-pooling" value="false"/>
        </in-vm-acceptor>
        <remote-acceptor name="netty" socket-binding="messaging"/>
        <jms-queue entries="java:/jms/queue/ExpiryQueue" name="ExpiryQueue"/>
        <jms-queue entries="java:/jms/queue/DLQ" name="DLQ"/>
        <jms-queue entries="queue/clientPending" name="clientPending"/>
        <jms-queue name="AuditTrailMDB" entries="queue/AuditTrailMDB"/>
        <connection-factory connectors="in-vm" entries="java:/ConnectionFactory" name="InVmConnectionFactory"/>
        <pooled-connection-factory connectors="netty" entries="java:jboss/exported/jms/RemoteConnectionFactory" name="RemoteConnectionFactory" user="admin" password="admin"/>
        <pooled-connection-factory connectors="in-vm" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" name="activemq-ra" transaction="xa"/>
        <connection-factory connectors="in-vm" entries="/ApplicationsQueueConnectionFactory" name="ApplicationsQueueConnectionFactory"/>
    </server>
</subsystem>
...
<socket-binding name="messaging" port="5445"/>
...

日志：

[WARN ][logstash.inputs.jms      ][main] JMS Consumer Died {:exception=>"Java::JavaxNaming::NameNotFoundException", :exception_message=>"queueConnectionFactory", :backtrace=>["org.apache.activemq.artemis.jndi.ReadOnlyContext.lookup(org/apache/activemq/artemis/jndi/ReadOnlyContext.java:236)", "javax.naming.InitialContext.lookup(javax/naming/InitialContext.java:417)", "java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:498)", "org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:455)", "org.jruby.javasupport.JavaMethod.invokeDirect(org/jruby/javasupport/JavaMethod.java:316)", "home.Alternant.logstash.vendor.bundle.jruby._dot_5_dot_0.gems.jruby_minus_jms_minus_1_dot_3_dot_0_minus_java.lib.jms.connection.initialize

Answer 1

您的 JBoss EAP 和 Logstash 配置都存在一些问题。

让我们从 JBoss EAP 开始...

首先，你把RemoteConnectionFactory的默认配置改成这样：

<pooled-connection-factory connectors="netty" entries="java:jboss/exported/jms/RemoteConnectionFactory" name="RemoteConnectionFactory" user="admin" password="admin"/>

这是不正确的。远程客户端不能使用 pooled-connection-factory，只有与应用程序服务器位于同一 JVM 中的客户端才能使用（例如，需要发送消息的 MDB）。您应该改用默认配置：

<connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>

其次，您的 AuditTrailMDB 队列将对远程客户端不可用。这是它的配置：

<jms-queue name="AuditTrailMDB" entries="queue/AuditTrailMDB"/>

它需要在 java:jboss/exported/ 命名空间中有一个新的 JNDI 条目，以便远程客户端可用（例如 RemoteConnectionFactory 有）。因此你应该使用这个：

<jms-queue name="AuditTrailMDB" entries="queue/AuditTrailMDB java:jboss/exported/AuditTrailMDB"/>

现在用于 Logstash...

首先，您使用了错误的 JNDI 属性。您使用的属性用于 ActiveMQ Artemis JNDI 实现。这是您当前的配置：

jndi_context => { 
 'java.naming.factory.initial' => 'org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory'
 'java.naming.security.principal' => 'admin'
 'java.naming.provider.url' => 'tcp://localhost:5445?type=QUEUE_CF'
 'java.naming.security.credentials' => 'admin'
}

这是不正确的。当 ActiveMQ Artemis 嵌入到 JBoss EAP 中时，EAP 本身会处理所有 JNDI 查找。因此，您应该改用此配置：

jndi_context => { 
 'java.naming.factory.initial' => 'org.wildfly.naming.client.WildFlyInitialContextFactory'
 'java.naming.security.principal' => 'admin'
 'java.naming.provider.url' => 'http-remoting://127.0.0.1:8080'
 'java.naming.security.credentials' => 'admin'
}

当然，这假定您已将正确的 admin 用户添加到 EAP。

其次，你的连接工厂JNDI名称不正确。您目前正在使用这个：

jndi_name => 'queueConnectionFactory'

你应该改用这个：

jndi_name => 'jms/RemoteConnectionFactory'

第三，你用的jar不对。这是您当前的配置：

require_jars=> ['/home/Alternant/logstash/dependencies/jboss-client.jar', 
                '/home/Alternant/logstash/dependencies/artemis-ra.jar',
                '/home/Alternant/logstash/dependencies/ironjacamar-core-impl.jar',
                '/home/Alternant/logstash/dependencies/ironjacamar-core-api.jar',
                '/home/Alternant/logstash/dependencies/ironjacamar-common-api.jar']

您根本不需要其中的大部分内容。您可以使用可用的 wildfly-client-all "uber" jar 来简化您的配置 here。那么您的配置将如下所示：

require_jars=> ['/home/Alternant/logstash/dependencies/wildfly-client-all-7.1.0.GA-redhat-11.jar']

NameNotFoundException：通过 logstash 连接到远程队列

NameNotFoundException: connecting to remote queue via logstash

queue

jboss

jms

logstash

activemq-artemis