如何使用ActiveMQ添加JNDI目的地(主题和队列)？

ActiveMQ是一个开源的消息中间件，它实现了Java Message Service (JMS) API，提供了可靠的消息传递机制。JNDI（Java Naming and Directory Interface）是Java命名和目录接口，它提供了统一的访问命名和目录服务的方式。

要使用ActiveMQ添加JNDI目的地（主题和队列），可以按照以下步骤进行操作：

配置ActiveMQ服务器：首先，需要下载和安装ActiveMQ服务器。可以从ActiveMQ官方网站（https://activemq.apache.org/）下载最新版本的ActiveMQ，并按照官方文档进行安装和配置。
创建JNDI上下文：在ActiveMQ安装目录下的conf文件夹中，找到activemq.xml文件，编辑该文件。在<broker>标签内部，添加以下配置：

<broker>
  ...
  <managementContext>
    <managementContext createConnector="false"/>
  </managementContext>
  <persistenceAdapter>
    <kahaDB directory="${activemq.data}/kahadb"/>
  </persistenceAdapter>
  <transportConnectors>
    <transportConnector name="openwire" uri="tcp://localhost:61616"/>
  </transportConnectors>
  <destinationPolicy>
    <policyMap>
      <policyEntries>
        <policyEntry topic=">" producerFlowControl="true" memoryLimit="1mb">
          <pendingSubscriberPolicy>
            <vmCursor/>
          </pendingSubscriberPolicy>
        </policyEntry>
        <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb">
          <pendingQueuePolicy>
            <vmQueueCursor/>
          </pendingQueuePolicy>
        </policyEntry>
      </policyEntries>
    </policyMap>
  </destinationPolicy>
  <jmsBridgeConnectors>
    <jmsBridgeConnector name="default" uri="tcp://remote-activemq:61616" userName="admin" password="password"/>
  </jmsBridgeConnectors>
</broker>

这个配置文件中，我们定义了一个名为default的JMS桥接连接器，它连接到远程的ActiveMQ服务器。你可以根据实际需求进行配置。

创建JNDI资源文件：在ActiveMQ安装目录下的conf文件夹中，创建一个名为jndi.properties的文件，并添加以下内容：

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory
java.naming.provider.url = tcp://localhost:61616

这个文件指定了JNDI的初始上下文工厂和提供者URL。

创建Java代码：在Java项目中，创建一个类，并添加以下代码：

import javax.jms.*;
import javax.naming.*;

public class ActiveMQJNDIExample {
    public static void main(String[] args) {
        try {
            // 创建JNDI上下文
            Context jndiContext = new InitialContext();

            // 查找连接工厂
            ConnectionFactory connectionFactory = (ConnectionFactory) jndiContext.lookup("ConnectionFactory");

            // 创建连接
            Connection connection = connectionFactory.createConnection();

            // 启动连接
            connection.start();

            // 创建会话
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // 查找目的地
            Destination destination = (Destination) jndiContext.lookup("YourDestinationName");

            // 创建生产者
            MessageProducer producer = session.createProducer(destination);

            // 创建消息
            TextMessage message = session.createTextMessage("Hello, ActiveMQ!");

            // 发送消息
            producer.send(message);

            // 关闭连接
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这个示例代码中，我们使用JNDI查找连接工厂和目的地，并创建连接、会话、生产者。然后，创建一条文本消息并发送到目的地。