使用 ActiveMQ 示例


企业中各项目中相互协作的时候可能用得到消息通知机制。比如有东西更新了，可以通知做索引。

在 Java 里有 JMS 的多个实现。其中 apache 下的 ActiveMQ 就是不错的选择。还有一个比较热的是 RabbitMQ （是 erlang 语言实现的）。这里示例下使用 ActiveMQ

用 ActiveMQ 最好还是了解下 JMS

JMS 公共 点对点域 发布/订阅域
ConnectionFactory QueueConnectionFactory TopicConnectionFactory
Connection QueueConnection TopicConnection
Destination Queue Topic
Session QueueSession TopicSession
MessageProducer QueueSender TopicPublisher
MessageConsumer QueueReceiver TopicSubscriber

JMS 定义了两种方式：Quere（点对点）；Topic（发布/订阅）。

ConnectionFactory 是连接工厂，负责创建Connection。

Connection 负责创建 Session。

Session 创建 MessageProducer（用来发消息） 和 MessageConsumer（用来接收消息）。

Destination 是消息的目的地。

详细的可以网上找些 JMS 规范（有中文版）。

下载 apache-activemq-5.3.0。http://activemq.apache.org/download.html，解压，然后双击 bin/activemq.bat。运行后，可以在 http://localhost:8161/admin 观察。也有
demo， http://localhost:8161/demo。把 activemq-all-5.3.0.jar 加入 classpath。

Jms 发送 代码：

  1. public static void main(String[] args) throws Exception {
  2. ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
  3. Connection connection = connectionFactory.createConnection();
  4. connection.start();
  5. Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
  6. Destination destination = session.createQueue("my-queue");
  7. MessageProducer producer = session.createProducer(destination);
  8. ; i<3; i++) {
  9. MapMessage message = session.createMapMessage();
  10. message.setLong("count", new Date().getTime());
  11. );
  12. //通过消息生产者发出消息
  13. producer.send(message);
  14. }
  15. session.commit();
  16. session.close();
  17. connection.close();
  18. }

Jms 接收代码：

  1. public static void main(String[] args) throws Exception {
  2. ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
  3. Connection connection = connectionFactory.createConnection();
  4. connection.start();
  5. final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
  6. Destination destination = session.createQueue("my-queue");
  7. MessageConsumer consumer = session.createConsumer(destination);
  8. /*//listener 方式
  9. consumer.setMessageListener(new MessageListener() {
  10. public void onMessage(Message msg) {
  11. MapMessage message = (MapMessage) msg;
  12. //TODO something....
  13. System.out.println("收到消息：" + new Date(message.getLong("count")));
  14. session.commit();
  15. }
  16. });
  17. Thread.sleep(30000);
  18. */
  19. ;
  20. ) {
  21. i++;
  22. MapMessage message = (MapMessage) consumer.receive();
  23. session.commit();
  24. //TODO something....
  25. System.out.println("收到消息：" + new Date(message.getLong("count")));
  26. }
  27. session.close();
  28. connection.close();
  29. }

启动 JmsReceiver 和 JmsSender 可以在看输出三条时间信息。当然 Jms 还指定有其它格式的数据，如 TextMessage

结合 Spring 的 JmsTemplate 方便用：

xml：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
  4. <!-- 在非 web / ejb 容器中使用 pool 时，要手动 stop，spring 不会为你执行 destroy-method 的方法
  5. <bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
  6. <property name="connectionFactory">
  7. <bean class="org.apache.activemq.ActiveMQConnectionFactory">
  8. <property name="brokerURL" value="tcp://localhost:61616" />
  9. </bean>
  10. </property>
  11. </bean>
  12. -->
  13. <bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
  14. <property name="brokerURL" value="tcp://localhost:61616" />
  15. </bean>
  16. <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
  17. <property name="connectionFactory" ref="jmsFactory" />
  18. <property name="defaultDestination" ref="destination" />
  19. <property name="messageConverter">
  20. <bean class="org.springframework.jms.support.converter.SimpleMessageConverter" />
  21. </property>
  22. </bean>
  23. <bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
  24. <constructor-arg index="0" value="my-queue" />
  25. </bean>
  26. </beans>

sender：

  1. public static void main(String[] args) {
  2. ApplicationContext ctx = new FileSystemXmlApplicationContext("classpath:app*.xml");
  3. JmsTemplate jmsTemplate = (JmsTemplate) ctx.getBean("jmsTemplate");
  4. jmsTemplate.send(new MessageCreator() {
  5. public Message createMessage(Session session) throws JMSException {
  6. MapMessage mm = session.createMapMessage();
  7. mm.setLong("count", new Date().getTime());
  8. return mm;
  9. }
  10. });
  11. }

receiver：

  1. public static void main(String[] args) {
  2. ApplicationContext ctx = new FileSystemXmlApplicationContext("classpath:app*.xml");
  3. JmsTemplate jmsTemplate = (JmsTemplate) ctx.getBean("jmsTemplate");
  4. while(true) {
  5. Map<String, Object> mm =  (Map<String, Object>) jmsTemplate.receiveAndConvert();
  6. System.out.println("收到消息：" + new Date((Long)mm.get("count")));
  7. }
  8. }

注意：直接用 Jms 接口时接收了消息后要提交一下，否则下次启动接收者时还可以收到旧数据。有了 JmsTemplate 就不用自己提交 session.commit() 了。如果使用了 PooledConnectionFactory 要把 apache-activemq-5.3.0\lib\optional\activemq-pool-5.3.0.jar 加到 classpath

参考资料：

Hello ActiveMQ

Spring2.5整合ActiveMQ 5.2

spring-support

JMS 相关资料

原文出处：http://blog.chenlb.com/2010/01/activemq-hello.html

最新文章

  1. 【python网络编程】使用rsa加密算法模块模拟登录新浪微博
  2. 【翻译】配置RSVP-signaled LSP
  3. Count Numbers with Unique Digits
  4. 40免费的 jQuery &amp; CSS3 图片热点特效
  5. MDK4.6和J-LINK调试出现问题，软件自动关闭，在网上收集整理的解决办法
  6. CSS之简单树形菜单
  7. android显示手机电量
  8. 修改系统启动项 grub2配置的方法 ubuntu[转]
  9. Java程序员应该知道的10个Eclipse调试技巧
  10. ios给textView提价提示性文字
  11. 【转】C\C++代码优化的27个建议
  12. ThinkPHP 分组，应用，跳转
  13. zoj1383 zoj3418 二进制 基础
  14. Android为TV端助力 转载:Android绘图Canvas十八般武器之Shader详解及实战篇(上)
  15. C#实现局部峰值查找,功能对应Matlab中的findpeaks.m（转）
  16. [luogu P3384] [模板]树链剖分
  17. cas client
  18. 【转】Java学习---解析Java Servlet工作过程
  19. [Spring boot] Read values from external properties file
  20. python初步学习-练习题

热门文章

  1. ubuntu14.10安装gitlab
  2. 编程作业2.2：Regularized Logistic regression
  3. jsp动作标签学习
  4. PAT Advanced 1032 Sharing(25) [链表]
  5. 调用新浪短地址转换api的一个测试
  6. bzoj2127happiness（最小割）
  7. JavaScript学习笔记 - 进阶篇（8）- DOM对象，控制HTML元素
  8. Python基础学习三
  9. zabbix自定义添加主机
  10. 第04项目：淘淘商城(SpringMVC+Spring+Mybatis) 的学习实践总结【第四天】