现在的位置: 首页 > 综合 > 正文

ActiveMQ的最简单应用-队列消息

2013年10月06日 ⁄ 综合 ⁄ 共 1933字 ⁄ 字号 评论关闭

有一段时间不使用JMS了。现在的项目又有可能需要应用JMS,来提高服务质量和提高系统资源的利用率。

提高服务质量,主要是保证不间断的服务。用JMS服务器接收任务,排成队列。应用服务可以暂停做维护,不影响接收的任务。应用服务运行后,再从队列中获取任务。

提高系统资源的利用率,主要是任务的派发不是24小时平均的,而是高峰时期任务量很多,比如1秒1000多个,有的时候很低,比如十几秒钟才来一个。应用服务通过JMS队列一个一个的取任务,做完一个再领一个,使系统资源的运用趋于平均。而JMS,比如JMS接收消息的效率是很高的,比如ActiveMQ,在赛扬(2.40GHz)机器上能够达到2000/s,消息大小为1-2k。好一些的服务器可以达到2万以上/秒。

 

ActiveMQ是开源免费的JMS实现,并且有很多扩展功能。地址:

http://activemq.apache.org

安装和运行很简单,下载后解压缩,执行:

activemq.bat

将启动默认配置的activemq。可以通过:

http://localhost:8161/admin

访问activemq的管理界面。查看队列(queue)和主题(topic)下的消息内容。

编写ActiveMQ程序前需要准备类库,如果使用maven就简单了:

<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.2.0</version> </dependency>

编写最简单的向JMS队列发送文本消息的程序:

 

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory( "tcp://localhost:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); System.out.println("start..."); Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); Queue destination = session.createQueue("example.C"); MessageProducer producer = session.createProducer(destination); producer.setDeliveryMode(DeliveryMode.PERSISTENT); TextMessage message = session.createTextMessage("中文"); producer.send(message); session.commit(); connection.close(); System.out.println("send text ok.");

执行程序后可通过上面提到的web界面查看example.C队列中收到的消息。不过中文信息显示的是??。这没有关系,是admin web应用自身的问题(使用的是iso-8859-1编码)。队列里的数据是对的。

异步接收数据的代码如下:

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory( "tcp://localhost:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); final Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); Queue destination = session.createQueue("example.C"); MessageConsumer consumer = session.createConsumer(destination); consumer.setMessageListener(new MessageListener(){ @Override public void onMessage(Message message) { System.out.println(message); try { session.commit(); } catch (JMSException e) { e.printStackTrace(); } } });

抱歉!评论已关闭.