java 使用用户名和密码进行ActiveMQ JMS连接。

bluesky5月前 ⋅ 50 阅读

ChatGPT的回答仅作参考:

要使用用户名和密码进行ActiveMQ JMS连接,您可以使用以下代码示例:

```java
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

public class JMSConnectionExample {
    public static void main(String[] args) {
        String brokerUrl = "tcp://localhost:61616";
        String username = "admin";
        String password = "admin";

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
        Connection connection = null;
        Session session = null;

        try {
            connection = connectionFactory.createConnection(username, password);
            connection.start();

            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // 在这里执行JMS操作

        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            try {
                if (session != null) {
                    session.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}
```

在上面的示例中,我们使用`ActiveMQConnectionFactory`创建了一个连接工厂,并将用户名和密码作为参数传递给`createConnection`方法来创建连接。然后,我们可以使用连接创建会话,并在会话中执行JMS操作。

请确保将`brokerUrl`替换为您的ActiveMQ代理的正确URL,并将`username`和`password`替换为您的ActiveMQ代理的有效用户名和密码。

全部评论: 0

    相关推荐