NameNotFoundException: подключение к удаленной очереди через logstash - PullRequest
Новая
       95

NameNotFoundException: подключение к удаленной очереди через logstash

1 голос
/ 23 января 2020

У меня есть развернутая очередь на JBoss EAP 7.1 (определена в standalone.xml), которая управляется ActiveMQ Artemis (имя модуля xmlns = "urn: jboss: domain: messaging-activemq: 2.0") и в то же время Когда я хочу подключиться к этой очереди с помощью плагина JMS в logsta sh (с JNDI) для использования сообщений, отправленных развернутым приложением на моем сервере JBoss, но при попытке получить NameNotFoundException для подключения factory (свойство jndi_name в файле logsta sh conf).

Я пытался найти записи JNDI фабрик соединений по умолчанию, но даже тогда это не сработало.

Так что я Хотите знать, созданы ли фабрики соединений брокером сообщений или существуют по умолчанию для клиента? Потому что, если я не ошибаюсь, фабрика соединений - это единственный способ подключиться к брокеру и очереди и исправить, если я ошибаюсь, пожалуйста, но они должны существовать по умолчанию для клиента.

Я надеюсь вы можете помочь мне, ребята, вот мой logsta sh 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"/>
...

log: 

[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.$2_dot_5_dot_0.gems.jruby_minus_jms_minus_1_dot_3_dot_0_minus_java.lib.jms.connection.initialize

1 Ответ

2 голосов
/ 23 января 2020

Существует несколько проблем с вашей конфигурацией как для JBoss EAP, так и для Logsta sh.

Давайте начнем с 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"/>

Требуется новая запись JNDI в пространстве имен java:jboss/exported/, чтобы она была доступна удаленным клиентам (например, как RemoteConnectionFactory). Поэтому вы должны использовать это: 

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

Теперь для Logsta sh ...

Сначала , вы используете неправильные свойства JNDI. Используемые вами свойства предназначены для реализации JNDI ActiveMQ Artemis. Вот ваша текущая конфигурация: 

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.

Second неверное имя JNDI фабрики соединений. Вы в настоящее время используете это: 

jndi_name => 'queueConnectionFactory'

Вы должны использовать это вместо: 

jndi_name => 'jms/RemoteConnectionFactory'

Третий , банки, которые вы используете, неверны. Вот ваша текущая конфигурация: 

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» банку, которая доступна здесь . Тогда ваша конфигурация будет выглядеть так: 

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