文档章节

ActiveMQ的在实际项目中的简单使用

阳光黑马
 阳光黑马
发布于 2015/04/22 09:32
字数 1027
阅读 12332
收藏 9
点赞 2
评论 0

简介

本文达到的目的是会用。

安装服务器:

官网下载win版的,也可是linux版的;

启动服务器:win版的执行activemq.bat

看看是否安装成功:http://localhost:8161/

 

activeMQ是一个消息服务器,

2中模式:点对点、广播

点对点:消息进入队列后,只会被接收一次,接收完了就在消息队列里消失了。

广播:采用的是广播订阅的方式,所有的订阅了此主题的,当此主题有消息时,都会接收到

 

可靠性:

mq会将信息存储

 

/*

                   * 消息的类型(消息体)

                   * TextMessage

                   * ObjectMessage: Java中的可序列化对象

                   * StreamMessage: Java中的输入输出流

                   * BytesMessage: 字节流

                   * MapMessage: /值对的集合,名是String对象,值类型可以是Java任何基本类型

                   */

                 

                  /*

                   * 术语:

                   * ConnectionFactory:连接工厂,JMS 用它创建连接;

                   * Destination:消息的目的地;

                   * Session:会话,一个发送或接收消息的线程;

                   */

 

发送消息到消息队列:

场景:程序中记录日志,异步的把日志输出等。

配置文件:

Spring-context.xml:

 

配置jmsConnectionFactory

<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

//value的值就是mq服务器的地址

    <property name="brokerURL" value=" tcp://10.128.11.128:61616 " />

<property name="useAsyncSend" value="true" />//表示异步传送,默认是false,同步

</bean>

配置pooledJmsConnectionFactory:池

<bean id="pooledJmsConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"

    destroy-method="stop">

    <property name="connectionFactory" ref="jmsConnectionFactory" />

    <property name="maxConnections" value="100" />

    <property name="maximumActive" value="50" />

  </bean>

配置jmsTemplate:模板,这是核心

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">

    <property name="connectionFactory" ref="pooledJmsConnectionFactory" />

  </bean>

定义发送消息的队列:

<bean id="sendGSMMessageQueue" class="org.apache.activemq.command.ActiveMQQueue">

    <constructor-arg value="gsm.message.push.queue" />//队列的名字是任意写的,只要不重复

  </bean>

定义生产者:将消息发送到这个队列

<bean id="notificationSender" class="com.gome.gsm.jms.NotificationSender">

<property name="jmsTemplate" ref="jmsTemplate"></property>

//将消息发送到这个队列

    <property name="queue" ref="sendGSMMessageQueue"></property>

  </bean>

 

NotificationSender.java:

就是普通的类,注入jmsTemplatequeue,并且有个send方法,并调用jmsTemplatesend方法

//这里发送的是String型的数据

public void send(final String message){

                  this.jmsTemplate.send(queue, new MessageCreator() {

                         

                          @Override

                          public Message createMessage(Session session) throws JMSException {

                                   return session.createTextMessage(message);

                          }

                  });

                  logger.info("-------发送消息到消息服务器通知队列成功--" + message + "-------");

}

以上,便实现了将消息发送到消息队列。

既然有了生产者,那么也应该有消费者,否则消息将一直阻塞。

从消息队列接收消息

注:这里不是在那个队列里接收的消息

------------------------------------分割线-----------------------------------------

进行消息的接收

配置receiveMessageQueue:接收消息队列(是否需要定义接收消息队列与项目需求有关,比如我就是接收我前面已经定义的消息发送队列的消息,那么这里也就没有必要定义这个队列了)

<bean id="receiveMessageQueue" class="org.apache.activemq.command.ActiveMQQueue">

    <constructor-arg value="gsm.message.receiver.queue" />//要在这个消息队列接收消息

  </bean>

配置消息监听器:

<bean id="notificationListener" class="com.gome.gsm.jms.NotificationListener">

         //这里需要根据系统具体写,因为监听器类里面注入了这个资源

    <property name="notificationService" ref="notificationService" />

  </bean>

配置消息接收客户端:

<bean id="notificationConsumer"

    class="org.springframework.jms.listener.DefaultMessageListenerContainer">

    <property name="connectionFactory" ref="pooledJmsConnectionFactory" />

    <property name="destination" ref="receiveMessageQueue" />

    <property name="messageListener" ref="notificationListener" />

  </bean>

其中bean idnotificationService的类:(项目时注解开发)

编写监听器类:(消息队列里接收消息的)

public class NotificationListener implements MessageListener {

 

         private static final Logger logger = LoggerFactory.getLogger(NotificationListener.class);

         private NotificationService notificationService;

        

         public NotificationService getNotificationService() {

                  return notificationService;

         }

 

         public void setNotificationService(NotificationService notificationService) {

                  this.notificationService = notificationService;

         }

 

         @Override

         public void onMessage(Message message) {

                  try {

                          if(message instanceof TextMessage){

                                   TextMessage receiveMessage = (TextMessage) message;

                                   String jsonStr = receiveMessage.getText();

                                   logger.info("----接收到通知消息: " + jsonStr + "--------------------");

                                   Map map = JsonUtil.jsonStringToMap(jsonStr);

                                   //根据接收到的消息具体做些事情即可。。。

                          }

                  } catch (Exception e) {

                          e.printStackTrace();

                  }

         }

}

注意:

因为项目中只用到了这种点对点的方式队列,所以这里只有这个。

发送的消息队列可以使可接受的消息队列是一个。具体看需求。

mq就是一个消息服务器,有生产者将消息放到队列里面,至于是谁接收消息,谁是消费者,并不清楚;

 

参考:http://yinbinhome.iteye.com/blog/1273228

© 著作权归作者所有

共有 人打赏支持
阳光黑马
粉丝 9
博文 20
码字总数 11705
作品 0
海淀
程序员
ActiveMQ集群方案(下)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/51205822 目...

yunlielai ⋅ 04/15 ⋅ 0

提高ActiveMQ工作性能(上)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/50955502 目...

yunlielai ⋅ 04/15 ⋅ 0

ActiveMQ集群方案(上)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/51124749 目...

yunlielai ⋅ 04/15 ⋅ 0

消息队列篇—详谈ActiveMQ消息队列模式的分析及使用

消息队列(Message Queue)是分布式系统中重要的组件,通用使用场景可以简单地描述为当不需要立即获得结果,但是并发量需控制时就需要使用消息队列。消息列队有两种消息模式,一种是点对点的...

afreon ⋅ 04/22 ⋅ 0

爬虫架构 | 消息队列应用场景及ActiveMQ、RabbitMQ、RocketMQ、Kafka对比

前言:在之前的业务中,使用了Kafka和RabbitMQ两种消息队列,这篇文章来做一个总结。 消息队列中间件是分布式系统中重要的组件,主要实现异步消息,应用解耦,流量削峰及消息通讯等功能。 下...

小怪聊职场 ⋅ 04/26 ⋅ 0

提高ActiveMQ工作性能(中)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/50991443 目...

yunlielai ⋅ 04/15 ⋅ 0

提高ActiveMQ工作性能(下)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/51064242 目...

yunlielai ⋅ 04/15 ⋅ 0

ActiveMQ初探(2)——与Spring整合

在上一章:ActiveMQ(1)——介绍与基本使用中,我们通过测试方法熟悉了ActiveMQ的流程,本章将ActiveMQ与Spring进行整合。 与Spring整合,除了原本的外,还需导入和包,如果Spring为5.0+,需...

yuanlaijike ⋅ 05/08 ⋅ 0

activeMQ发送邮件小例子

先安装apache-activemq-5.11.1 ,然后启动activemq.bat 启动activeMQ的控制台:http://localhost:8161/admin/,展示图如下: 解释:Number Of Pending Messages :等待消费的消息,这个是当前...

zhouyuzhoujing ⋅ 05/07 ⋅ 0

ActiveMQ初探(1)——介绍与基本使用

一、ActiveMQ 1.1 什么是ActiveMQ 是Apache出品,最流行的,能力强劲的。ActiveMQ是一个完全支持和规范的 实现,尽管规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊...

yuanlaijike ⋅ 04/15 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

浅谈springboot Web模式下的线程安全问题

我们在@RestController下,一般都是@AutoWired一些Service,由于这些Service都是单例,所以并不存在线程安全问题。 由于Controller本身是单例模式 (非线程安全的), 这意味着每个request过来,...

算法之名 ⋅ 今天 ⋅ 0

知乎Java数据结构

作者:匿名用户 链接:https://www.zhihu.com/question/35947829/answer/66113038 来源:知乎 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。 感觉知乎上嘲讽题主简...

颖伙虫 ⋅ 今天 ⋅ 0

Confluence 6 恢复一个站点有关使用站点导出为备份的说明

推荐使用生产备份策略。我们推荐你针对你的生产环境中使用的 Confluence 参考 Production Backup Strategy 页面中的内容进行备份和恢复(这个需要你备份你的数据库和 home 目录)。XML 导出备...

honeymose ⋅ 今天 ⋅ 0

JavaScript零基础入门——(九)JavaScript的函数

JavaScript零基础入门——(九)JavaScript的函数 欢迎回到我们的JavaScript零基础入门,上一节课我们了解了有关JS中数组的相关知识点,不知道大家有没有自己去敲一敲,消化一下?这一节课,...

JandenMa ⋅ 今天 ⋅ 0

火狐浏览器各版本下载及插件httprequest

各版本下载地址:http://ftp.mozilla.org/pub/mozilla.org//firefox/releases/ httprequest插件截至57版本可用

xiaoge2016 ⋅ 今天 ⋅ 0

Docker系列教程28-实战:使用Docker Compose运行ELK

原文:http://www.itmuch.com/docker/28-docker-compose-in-action-elk/,转载请说明出处。 ElasticSearch【存储】 Logtash【日志聚合器】 Kibana【界面】 答案: version: '2'services: ...

周立_ITMuch ⋅ 今天 ⋅ 0

使用快嘉sdkg极速搭建接口模拟系统

在具体项目研发过程中,一旦前后端双方约定好接口,前端和app同事就会希望后台同事可以尽快提供可供对接的接口方便调试,而对后台同事来说定好接口还仅是个开始、设计流程,实现业务逻辑,编...

fastjrun ⋅ 今天 ⋅ 0

PXE/KickStart 无人值守安装

导言 作为中小公司的运维,经常会遇到一些机械式的重复工作,例如:有时公司同时上线几十甚至上百台服务器,而且需要我们在短时间内完成系统安装。 常规的办法有什么? 光盘安装系统 ===> 一...

kangvcar ⋅ 昨天 ⋅ 0

使用Puppeteer撸一个爬虫

Puppeteer是什么 puppeteer是谷歌chrome团队官方开发的一个无界面(Headless)chrome工具。Chrome Headless将成为web应用自动化测试的行业标杆。所以我们很有必要来了解一下它。所谓的无头浏...

小草先森 ⋅ 昨天 ⋅ 0

Java Done Right

* 表示难度较大或理论性较强。 ** 表示难度更大或理论性更强。 【Java语言本身】 基础语法,面向对象,顺序编程,并发编程,网络编程,泛型,注解,lambda(Java8),module(Java9),var(...

风华神使 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部