使用JNDI通过ActiveMQ的Java

bluesky1年前 ⋅ 86 阅读

ChatGPT的回答仅作参考:

使用JNDI连接ActiveMQ的Java代码示例:

```java
import javax.jms.*;
import javax.naming.*;

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

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

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

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

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

            // 查找目的地
            Destination destination = (Destination) context.lookup("queue/MyQueue");

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

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

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

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

在上述代码中,我们使用JNDI查找ActiveMQ的连接工厂和目的地。然后,我们创建连接、会话和生产者,并发送一条消息到指定的目的地。最后,我们关闭连接。

请注意,你需要在ActiveMQ的配置文件中配置JNDI,以便能够通过JNDI查找连接工厂和目的地。

全部评论: 0

    相关推荐