7

我正在尝试通过 Geronimo 的 JNDI查找QueueConnectionFactory和查找。Queue得到很好的Queue返回，但QueueConnectionFactory查找总是返回 null。它不会抛出NamingException，如果 JNDI 名称不正确，这是我所期望的。

谁能看到我做错了什么？下面的测试代码输出：

真的
错误的


import javax.jms.Queue;
import javax.jms.QueueConnectionFactory;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class JndiTest
{
    private final static String QUEUE_NAME = "jca:/org.apache.geronimo.configs/activemq-ra/JCAAdminObject/SendReceiveQueue";
    private final static String FACTORY_NAME = "jca:/org.apache.geronimo.configs/activemq-ra/JCAManagedConnectionFactory/DefaultActiveMQConnectionFactory";

    public static void main(String[] args) throws NamingException
    {
        InitialContext ctx = new InitialContext();
        QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup(FACTORY_NAME);
        Queue queue = (Queue)ctx.lookup(QUEUE_NAME);
        System.out.println(factory == null);
        System.out.println(queue == null);      
    }

}

如果它有所作为：我已将 openejb-client-3.0.1.jar、geronimo-ejb_3.0_spec-1.0.1.jar 和 activemq-core-4.1.2-G20090207.jar 添加到我的类路径中，并且我的 jndi.properties 文件具有以下属性：

java.naming.factory.initial = org.apache.openejb.client.RemoteInitialContextFactory
java.naming.provider.url = ejbd://127.0.0.1:4201
4

4 回答 4

14

它不抛出异常的原因是 - 访问资源时会出现 ClassLoadException。

之所以发生这种情况，是因为从 ResourceManager 调用的 ClassLoader 正在搜索类：com.sun.jndi.url.jca.jcaURLContextFactory。

如果您将工厂名称更改为其他名称，那么您将看到 NamingException - 但在查找的情况下，对于 ClassNotFound/IllegalState 等异常 - 不会引发异常。

因此需要分析 ActiveMQ 的依赖关系。Update1：​​可能的原因之一是工厂对象只能在托管环境中实例化。您是否将代码作为应用程序客户端运行？

更新2：找到了导致此行为的其他一些指针：

openejb jndi 实现仅公开 ejb，不公开任何其他资源。如果您有一个 j2ee 应用程序客户端，并且希望使用 jms，则需要在客户端上部署一个 activemq 适配器的副本。然后，您可以使用 j2ee java:comp/env 上下文来查找您的内容。

在 ActiveMQ 网站上找到了这个：

ActiveMQ 的 JNDI 实现不与命名服务器对话。它是 JNDI 客户端的精简版本，只允许直接从 JMS 实例获取主题和队列。因此，您必须提供 JMS 服务器地址，而不是提供命名服务器地址。大多数 JNDI 实现使用 java.naming.provider.url 属性来指定命名服务器的地址。ActiveMQ 使用brokerURL之一。使用 java.naming.provider.url 将导致 ActiveMQ 尝试加载整个代理。

详细了解如何使用 JNDI 进行连接：

解释中使用的初始上下文工厂为：org.apache.activemq.jndi.ActiveMQInitialContextFactory

可以在此处找到一些使用 JNDI 进行测试的示例代码

我写了一个简单的 java 客户端 - 注意提供者 url 下面是正在使用的 brokerURL。

    Properties props = new Properties();            
props.put(Context.INITIAL_CONTEXT_FACTORY,
             "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
    //props.put(Context.PROVIDER_URL,"vm://localhost");//Either this or below
    props.put(Context.PROVIDER_URL,"tcp://localhost:65432"); 
    props.put("queue.SendReceiveQueue",
         "org.apache.geronimo.configs/activemq-ra/JCAAdminObject/SendReceiveQueue");
      
    InitialContext context = new InitialContext(props);   
    QueueConnectionFactory connectionFactory = (QueueConnectionFactory)context.lookup
                                                               ("ConnectionFactory");
    Queue q = (Queue) context.lookup("SendReceiveQueue");
    System.out.println("conn is : "  + connectionFactory.getClass().getName());
    System.out.println("queue is : " + q.getQueueName());

该程序给出输出：

conn 是：org.apache.activemq.ActiveMQConnectionFactory 队列是：org.apache.geronimo.configs/activemq-ra/JCAAdminObject/SendReceiveQueue

于 2009-08-29T23:20:51.397 回答
1

我有一个有点等效的配置 Tomcat/Geronimo J2EE jar / Geronimo JMS Jar / ActiveMQ 4 我对你的 jndi.propertie 文件有点困惑。我的看起来像这样：

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory

java.naming.provider.url = tcp://localhost:61616

connectionFactoryNames = connectionFactory , TopicConnectionFactory

最大的区别显然是您的初始上下文是远程的。除此之外，我必须提供一个 connectionFactoryNames，否则我会得到一个 NamingException。

于 2009-09-02T12:15:26.237 回答
1

我不知道为什么，但对我来说，使用上下文不起作用。好像发送了消息，但是我的消费者的onMessage没有被调用。

使用上下文不会抛出异常但不起作用：

import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;

public class HelloClient {

public static void main(String[] args) throws Exception {
    Properties ppt2 = new Properties();
    ppt2.put(Context.INITIAL_CONTEXT_FACTORY,
            "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
    ppt2.put(Context.PROVIDER_URL, "tcp://localhost:61616");
    ppt2.put("topic.MessageDestinationTopic", "console.jms/TopicQueue/JCAAdminObject/MessageDestinationTopic");
    Context ctx2 = new InitialContext(ppt2);

    TopicConnectionFactory factory = (TopicConnectionFactory) ctx2.lookup("ConnectionFactory");
    TopicConnection connection = factory.createTopicConnection();
    TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
    Topic topic = (Topic) ctx2.lookup("MessageDestinationTopic");

    MessageProducer producer = session.createProducer(topic);

    TextMessage msg = session.createTextMessage();
    msg.setText("this is a test message");
    producer.send(msg);
    producer.close();
    session.close();
    System.out.println("Message published. Please check application server's console to see the response from MDB");
    ctx2.close();
    System.exit(0);

}

}

使用下面的代码（没有上下文）效果很好：

import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;

public class HelloClient {

    public static void main(String[] args) throws Exception {

        TopicConnectionFactory factory = new org.apache.activemq.ActiveMQConnectionFactory("tcp://localhost:61616");
        TopicConnection connection = factory.createTopicConnection();
        TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
        Topic topic = session.createTopic("MessageDestinationTopic");

        MessageProducer producer = session.createProducer(topic);

        TextMessage msg = session.createTextMessage();
        msg.setText("this is a test message");
        producer.send(msg);
        producer.close();
        session.close();
        System.out.println("Message published. Please check application server's console to see the response from MDB");
        System.exit(0);

    }

}
于 2011-04-29T16:18:58.723 回答
0

这里有两个参与者，您正在 JNDI 中寻找一些东西。别人不得不把它放在那里。我不知道您的环境的具体情况，但我对此类问题的处理方法是

  • 探索命名空间——那里有什么？你有任何 JNDI 浏览工具吗？
  • 在日志中仔细查看应该向 JNDI 注册的服务，它是否报告任何错误？
于 2009-08-26T09:23:18.223 回答