activemq如何测试连接
时间: 2023-09-10 08:13:18 浏览: 225
activeMQ测试程序
在 ActiveMQ 中,我们可以使用 ActiveMQConnectionFactory 类来创建一个连接工厂对象,然后使用该对象来创建一个连接并测试连接。下面是一个简单的 Java 代码片段,用于测试 ActiveMQ 连接:
```java
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.Connection;
import javax.jms.JMSException;
public class ActiveMQTest {
private static String brokerURL = "tcp://localhost:61616";
public static void main(String[] args) {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURL);
try {
Connection connection = connectionFactory.createConnection();
System.out.println("Connection established successfully!");
connection.close();
} catch (JMSException e) {
System.out.println("Connection could not be established!");
e.printStackTrace();
}
}
}
```
在上面的代码中,我们首先创建了一个 ActiveMQConnectionFactory 对象,并传递了 ActiveMQ 代理服务器的 URL。然后,我们使用该工厂对象创建了一个连接,并通过捕获 JMSException 来检查连接是否成功建立。如果连接成功建立,则打印 "Connection established successfully!",否则打印 "Connection could not be established!"。最后,我们关闭了连接。
您可以将上述代码作为启动器(main方法),以便在运行时测试 ActiveMQ 连接。
阅读全文