如何使用ActiveMQ测试小程序

介绍 Active MQ是个消息队列管理器，用于通讯的中间件。现在由我来给大家介绍一下如何使用ActiveMQ测试小程序。

修改bin目录下activemq.bat
在最后一行加入

set ACTIVEMQ_OPTS=-Xms1G -Xmx1G

保存后执行该bat文件
新建maven项目
pom文件中加入依赖

 dependencies 
 dependency 
 groupId org.apache.activemq /groupId 
 artifactId activemq-all /artifactId 
 !--我的mq版本为5.9.0-- 
 version 5.9.0 /version 
 /dependency 
 !-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-broker -- 
 dependency 
 groupId org.apache.activemq /groupId 
 artifactId activemq-broker /artifactId 
 version 5.10.0 /version 
 /dependency 
 !-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-client -- 
 dependency 
 groupId org.apache.activemq /groupId 
 artifactId activemq-client /artifactId 
 version 5.14.0 /version 
 /dependency 
 /dependencies 

发送端程序

import org.apache.activemq.ActiveMQConnection;import org.apache.activemq.
ActiveMQConnectionFactory;import javax.jms.*;public class Send {
 // private static final int SEND_NUMBER = 10;
 public static void main(String[] args){ //ConnectionFactory:连接工厂，JMS用它创建连接
 ConnectionFactory connectionFactory; //Connection:JMS客户端到JMS Provider的连接
 Connection connection = null; //Session:一个发送或接收消息的线程
 Session session; //Destination:消息的目的地；消息的接收者
 Destination destination; //MessageProducer:消息发送者
 MessageProducer producer; //TextMessage message;
 //构造ConnectionFactory实例对象，此处采用ActiveMQ的实现jar
 connectionFactory = new ActiveMQConnectionFactory(
 ActiveMQConnection.DEFAULT_USER,
 ActiveMQConnection.DEFAULT_PASSWORD, tcp://localhost:61616 
 ); try{ //构造从工厂得到连接对象
 connection = connectionFactory.createConnection(); 
 //启动
 connection.start(); 
 //获取操作连接
 session = connection.createSession(Boolean.TRUE,
 Session.AUTO_ACKNOWLEDGE); 
 //获取session注意参数值test是一个服务器的queue,须在ActiveMQ的console配置
 destination = session.createQueue( test 
 //得到发送者
 producer = session.createProducer(destination); 
 //设置不持久化，实际情况请根据项目决定
 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); 
 //构造消息，这里写死了，项目就是参数，或者方法获取
 sendMessage(session,producer);
 session.commit();
 }catch (Exception e){
 e.printStackTrace();
 }finally { try { if(null != connection)
 connection.close();
 }catch (Throwable ignore){}
 } public static void sendMessage(Session session, MessageProducer producer) throws Exception{ 
 for (int i = 1; i = 100000; i++){
 TextMessage message = session.createTextMessage( 今日天气asda + i)；//发送消息到目的地
 System.out.println( 发送: +message.getText());
 producer.send(message);
}

接收端程序

import org.apache.activemq.ActiveMQConnection;import org.apache.activemq.
ActiveMQConnectionFactory;import javax.jms.*;public class revice {
 public static void main(String[] args) {
 ConnectionFactory connectionFactory;
 Connection connection = null;
 Session session;
 Destination destination; //接收者-消费者
 MessageConsumer messageConsumer;
 connectionFactory = new ActiveMQConnectionFactory(
 ActiveMQConnectionFactory.DEFAULT_USER,
 ActiveMQConnectionFactory.DEFAULT_PASSWORD, tcp://localhost:61616 
 try{
 connection = connectionFactory.createConnection();
 connection.start();
 session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
 destination = session.createQueue( test 
 messageConsumer = session.createConsumer(destination); while(true){
 TextMessage message = (TextMessage) messageConsumer.receive(1000); 
 if(null != message){
 System.out.println( 收到: +message.getText());
 }else{ break;
 message.acknowledge();
 }catch(Exception ex){
 ex.printStackTrace();
 }finally{ try{ if(null != connection){
 connection.close();
 }catch(Throwable ig){
}

 相关推荐：

1ActiveMQ使用 2ActiveMQC#Client实现 3ActiveMQC++Client实现通

Yii的学习(5)--Active Record的关联，yii--active

以上就是如何使用ActiveMQ测试小程序的详细内容，更多请关注php中文网其它相关文章！

最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。