在 JBoss 5.1.0 GA 中使用来自 MDB 的身份验证连接到 weblogic 10.3.6 JMS 队列时出现问题

Question

我正在使用 sun-jms-adapter.rar。在开始使用身份验证之前，我的所有配置都可以正常工作。我还尝试从独立应用程序和无状态 bean（用于向队列发送消息）访问队列，一切正常。

我的实际配置是：

weblogic-ds.xml

    <connection-factories>

    <!-- SUN JMS JCA Resource adapter, use this to get transacted JMS in beans -->
    <no-tx-connection-factory>
        <jndi-name>CFX/ExternalConnectionFactory</jndi-name>
        <xa-transaction />
        <rar-name>sun-jms-adapter.rar</rar-name>
        <connection-definition>javax.jms.QueueConnectionFactory</connection-definition>
        <config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Queue</config-property>
        <config-property name="JmsProviderAdapterJNDI" type="java.lang.String">java:/DefaultJMSProvider</config-property>
        <config-property name="Destination" type="java.lang.String">javax.jms.Destination</config-property>
        <max-pool-size>20</max-pool-size>
        <depends>jboss.messaging:service=ServerPeer</depends>
    </no-tx-connection-factory>
</connection-factories>

ejb-jar.xml 配置：

    <enterprise-beans>
    <message-driven>
        <ejb-name>QueueReceiverMDB</ejb-name>
        <ejb-class>com.tests.mdb.QueueReceiverMDB</ejb-class>
        <transaction-type>Bean</transaction-type>
        <activation-config>
            <activation-config-property>
                <activation-config-property-name>destination</activation-config-property-name>
                <activation-config-property-value>${weblogic.jms.queue.in}</activation-config-property-value>
            </activation-config-property>
            <activation-config-property>
                <activation-config-property-name>destinationType</activation-config-property-name>
                <activation-config-property-value>javax.jms.Queue</activation-config-property-value>
            </activation-config-property>
            <activation-config-property>
                <activation-config-property-name>ConnectionURL</activation-config-property-name>
                <activation-config-property-value>${weblogic.jms.url}</activation-config-property-value>
            </activation-config-property>
            <activation-config-property>
                <activation-config-property-name>UserName</activation-config-property-name>
                <activation-config-property-value>${weblogic.jms.username}</activation-config-property-value>
            </activation-config-property>
            <activation-config-property>
                <activation-config-property-name>Password</activation-config-property-name>
                <activation-config-property-value>${weblogic.jms.password}</activation-config-property-value>
            </activation-config-property>
        </activation-config>
    </message-driven>
</enterprise-beans>

最后是我的 jboss.xml：

        <message-driven>
        <ejb-name>QueueReceiverMDB</ejb-name>
        <destination-jndi-name>java:/CFX/ExternalConnectionFactory</destination-jndi-name>
        <local-jndi-name>local/QueueReceiverMDB</local-jndi-name>
        <resource-adapter-name>sun-jms-adapter.rar</resource-adapter-name>
        <configuration-name>JMSJCA Message Driven Bean</configuration-name>
    </message-driven>

我总是收到此错误：

16:25:07,126 警告 [激活] JMSJCA-E016: [sync-QueueReceiver(jms/TestJMSQueueIn) @ [t3://localhost:7001]]: 消息传递启动失败（尝试 #1）；将在 1 秒后重试。错误是：拒绝访问资源：type=，application=TestJMSModule，destinationType=queue，resource=TestJMSQueueIn，action=receive weblogic.jms.common.JMSSecurityException：拒绝访问资源：type=，application=TestJMSModule，destinationType=queue，resource=TestJMSQueueIn，action=receive 在 weblogic.jms.dispatcher.DispatcherAdapter.convertToJMSExceptionAndThrow(DispatcherAdapter.java:110) 在 weblogic.jms.dispatcher.DispatcherAdapter.dispatchSync（DispatcherAdapter.java:45） 在 weblogic.jms.client.JMSSession.consumerCreate(JMSSession.java:2982) 在 weblogic.jms.client.JMSSession.setupConsumer(JMSSession.java:2749) 在 weblogic.jms.client.JMSSession.createConsumer(JMSSession.java:2691) 在 weblogic.jms.client.JMSSession.createReceiver(JMSSession.java:2596) 在 weblogic.jms.client.WLSessionImpl.createReceiver(WLSessionImpl.java:991) 在 com.stc.jmsjca.core.RAJMSObjectFactory.createMessageConsumer（RAJMSObjectFactory.java:620） 在 com.stc.jmsjca.core.SyncDelivery$SyncWorker.init(SyncDelivery.java:502) 在 com.stc.jmsjca.core.SyncDelivery.start（SyncDelivery.java:202） 在 com.stc.jmsjca.core.Activation.asyncStart(Activation.java:557) 在 com.stc.jmsjca.core.Activation.access$000(Activation.java:82) 在 com.stc.jmsjca.core.Activation$1.run(Activation.java:351) 在 java.lang.Thread.run(Thread.java:745) 原因：weblogic.jms.common.JMSSecurityException：拒绝访问资源：type=，application=TestJMSModule，destinationType=queue，resource=TestJMSQueueIn，action=receive 在 weblogic.jms.dispatcher.DispatcherAdapter.convertToJMSExceptionAndThrow(DispatcherAdapter.java:110) 在 weblogic.jms.dispatcher.DispatcherAdapter.dispatchSync（DispatcherAdapter.java:45） 在 weblogic.jms.frontend.FEConsumer.(FEConsumer.java:296) 在 weblogic.jms.frontend.FESession$2.run(FESession.java:1076) 在 weblogic.security.acl.internal.AuthenticatedSubject.doAs(AuthenticatedSubject.java:363) 在 weblogic.security.service.SecurityManager.runAs(SecurityManager.java:146) 在 weblogic.jms.frontend.FESession.consumerCreate(FESession.java:1072) 在 weblogic.jms.frontend.FESession.invoke(FESession.java:3027) 在 weblogic.messaging.dispatcher.Request.wrappedFiniteStateMachine(Request.java:961) 在 weblogic.messaging.dispatcher.DispatcherServerRef.invoke（DispatcherServerRef.java:276） 在 weblogic.messaging.dispatcher.DispatcherServerRef.handleRequest(DispatcherServerRef.java:141) 在 weblogic.messaging.dispatcher.DispatcherServerRef.access$000(DispatcherServerRef.java:34) 在 weblogic.messaging.dispatcher.DispatcherServerRef$2.run(DispatcherServerRef.java:111) 在 weblogic.work.ExecuteThread.execute(ExecuteThread.java:256) 在 weblogic.work.ExecuteThread.run(ExecuteThread.java:221) 原因：weblogic.jms.common.JMSSecurityException：拒绝访问资源：type=，application=TestJMSModule，destinationType=queue，resource=TestJMSQueueIn，action=receive 在 weblogic.jms.dispatcher.Request.handleThrowable(Request.java:87) 在 weblogic.jms.dispatcher.Request.getResult(Request.java:52) 在 weblogic.messaging.dispatcher.Request.wrappedFiniteStateMachine(Request.java:1124) 在 weblogic.messaging.dispatcher.DispatcherImpl.syncRequest(DispatcherImpl.java:185) 在 weblogic.messaging.dispatcher.DispatcherImpl.dispatchSync(DispatcherImpl.java:220) 在 weblogic.jms.dispatcher.DispatcherAdapter.dispatchSync（DispatcherAdapter.java:43） ... 13 更多 原因：weblogic.jms.common.JMSSecurityException：拒绝访问资源：type=，application=TestJMSModule，destinationType=queue，resource=TestJMSQueueIn，action=receive 在 weblogic.jms.common.JMSSecurityHelper.checkPermission(JMSSecurityHelper.java:162) 在 weblogic.jms.backend.BEDestinationSecurityImpl.checkReceivePermission(BEDestinationSecurityImpl.java:87) 在 weblogic.jms.backend.BEConsumerImpl.init(BEConsumerImpl.java:312) 在 weblogic.jms.backend.BEConsumerImpl.(BEConsumerImpl.java:268) 在 weblogic.jms.backend.BEQueueImpl.createConsumer(BEQueueImpl.java:188) 在 weblogic.jms.backend.BESessionImpl.createBEConsumer(BESessionImpl.java:469) 在 weblogic.jms.backend.BESessionImpl.createConsumer(BESessionImpl.java:479) 在 weblogic.jms.backend.BESessionImpl.invoke(BESessionImpl.java:297) 在 weblogic.messaging.dispatcher.Request.wrappedFiniteStateMachine(Request.java:961) ... 16 更多

欢迎提出任何建议...

Answer 1

我找到了解决问题的方法，虽然不是最好的，但它确实有效。

花了很多时间尝试让它工作后，我从here查看了资源适配器的源代码（sun-jms-adapter.rar），发现可能有错误。他们不会在创建会话后将凭据放入 initialContext 和关闭上下文中。所以我修改了这个步骤，将“Context.SECURITY_PRINCIPAL”和“Context.SECURITY_CREDENTIALS”添加到上下文中，并保持打开状态。这确实有效。所有这些都在 RAWLObjectFactory 类的 getJndiObject 方法中。

如果有人找到另一种方法和最佳方法，请分享...因为他们在创建队列连接时放置了凭据，所以可能是 weblogic 源的错误。

我留下修改后的代码：

private Object getJndiObject(UrlParser url, String name, String username, String password) throws JMSException {

    if (sLog.isDebugEnabled()) {
        sLog.debug("Looking up JNDI object " + name);
    }

    if (name == null || name.length() == 0) {
        throw Exc.jmsExc(LOCALE.x("E401: The JNDI name is null"));
    }

    InitialContext ctx = null;
    try {
        if (mSpecialISORBMethod != null) {
            // Works on IS only
            if (mSpecialISORBMethodIsOn != null) {
                Boolean isEnabled = (Boolean) mSpecialISORBMethodIsOn.invoke(null, new Object[0]);
                if (!isEnabled.booleanValue()) {
                    throw Exc.rsrcExc(LOCALE.x("E823: CORBA-SE needs to be enabled on" 
                        + " this server. Please change the value of the <se-orb enabled=\"false\"/>"
                        + " to <se-orb enabled=\"true\"/> in the configuration file of "
                        + " the Integration Server (logicalhost/is/domains/<domain-name>"
                        + "/config/domain.xml) and restart the server."));
                }
            }
            final Properties prop = (Properties) mSpecialISORBMethod.invoke(null, new Object[0]);
            prop.put(Context.URL_PKG_PREFIXES, JNDI_WEBLOGIC_PROTOCOL_PACKAGES);
            ctx = new InitialContext(prop);
            return ctx.lookup("corbaname:iiop:1.2@" + url.getHost() + ":" + url.getPort()
                + '#' + name); 
        } else {
            // Will be executed on other application servers than the IS

            //add username/password if not null to context
            Hashtable<String, String> env = new Hashtable<String, String>();
            env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
            env.put(Context.PROVIDER_URL, "t3://" + url.getHost() + ":" + url.getPort());
            if (username != null) {
                env.put(Context.SECURITY_PRINCIPAL, username);
                env.put(Context.SECURITY_CREDENTIALS, password);
            }
            ctx = new InitialContext(env);
            return ctx.lookup(name);
        }
    } catch (Exception e) {
        throw Exc.jmsExc(LOCALE.x("E821: Could not find JNDI object by name [{0}]: {1}", name, e), e);
    } 
    //leave context open
    /*finally {
        safeClose(ctx);
    }*/
}