ActiveMQ(二)——ActiveMQ的安装和基本使用
一、安装
启动之后成功
创新互联是一家集网站建设,慈溪企业网站建设,慈溪品牌网站建设,网站定制,慈溪网站建设报价,网络营销,网络优化,慈溪网站推广为一体的创新建站企业,帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿,时刻以成就客户成长自我,坚持不断学习、思考、沉淀、净化自己,让我们为更多的企业打造出实用型网站。
二、创建实例测试ActiveMQ
- 配置Maven所需的依赖
org.apache.activemq activemq-all 5.9.0 org.apache.xbean xbean-spring 3.16 消息发送
public class QueueSender { public static void main(String[] args) throws Exception{ //连接工厂 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); //带事务的session Session session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("my-queue"); MessageProducer producer = session.createProducer(destination); for (int i = 0; i < 3; i++) { TextMessage message = session.createTextMessage("message--"+i); Thread.sleep(1000); //通过消息生产者发出消息 producer.send(message); } session.commit(); session.close(); connection.close(); } }
运行main方法,控制台输出如下:
那这个消息发送到哪里去了呢?
消息接收
public class QueueReceive { public static void main(String[] args) throws Exception{ //连接工厂 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); //带事务的session,并且自动签收 final Session session = connection.createSession(Boolean.TRUE,Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("my-queue"); MessageConsumer consumer = session.createConsumer(destination); int i = 0; while (i<3){ i++; TextMessage message = (TextMessage) consumer.receive(); session.commit(); System.out.println("收到的消息是:"+message.getText()); } session.close(); connection.close(); } }
运行main方法
此时再看服务器端会发送消息已经被接收处理了。
新闻标题:ActiveMQ(二)——ActiveMQ的安装和基本使用
转载来源:http://scpingwu.com/article/peepoe.html