消息队列在大型电子商务类网站，如京东、淘宝、去哪儿等网站有这深入的应用，队列的主要作用是消除高并发访问高峰，加快网站的响应速度。在不使用消息队列的情况下，用户的请求数据直接写入数据库，在高并发的情况下，会对数据库造成巨大的压力，同时也使得系统响应延迟加剧。在使用队列后，用户的请求发给队列后立即返回（当然不能直接给用户提示订单提交成功，京东上提示：您“您提交了订单，请等待系统确认”），再由消息队列的消费者进程从消息队列中获取数据，异步写入数据库。由于消息队列的服务处理速度远快于数据库，因此用户的响应延迟可得到有效改善。
作者：王路路 链接：https://www.zhihu.com/question/36048657/answer/93692293 来源：知乎 著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。
作者：小球念珠
链接：https://www.zhihu.com/question/36048657/answer/254107608 来源：知乎 著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。activeMQ,它是消息队列，叫做messagequeen，我们是使用在电商平台上。比如当用户商品上架的时候，它将用户的商品信息，它就是一个消息服务中间件，里面保存了参数值，就是商品上架的同时，将商品的ID信息保存到消息服务的中间件中，这是这一端，然后我到另一端，solr服务端和我的freemarker服务端都会反复不断的监听，监听activeMQ中的一些相应的参数信息，就是ID，如果找到了ID信息,那么我就会相应处理，而且activeMQ可以采用一对一模式和主题订阅模式。当引用了activeMQ的时候，它将用户的商品信息保存到消息服务中间件，然后我的另外2个，一个solr，一个freemarker这2个服务器都可以同时或者很短的时间内异步监听到ID信息，同时取出这个信息，异步的进行先相关处理，这样可以节约大量的时间，这就是为什么用,activeMQ是节省时间的。
ActiveMQ消息中间件是在分布式系统中完成消息的发送和接收的基础软件ActiveMQ通信方式
第一种：队列 一对一 类似QQ私聊
第二种：主题 一对多 类似QQ群聊
JMS是Sun公司定制的标准，ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。
比如一个电商的后台系统
配置ActiveMQ的步骤
1 配置消息生产方
2编写消息生产方业务代码
3 编写消息消费方业务代码
4 配置消息消费方
5编写自定义消息监听器类
具体如下
1 配置消息生产方
1、配置连接工厂，用来连接我们的消息服务中间件ActiveMQ
2、配置连接工厂的连接池，用来优化连接，需要注入连接工厂
3、配置Spring的JMS连接工厂，作用是交由spring来进行管理，需要注入连接工厂的连接池
4、配置Spring提供的JmsTemplate，作用是可以使用spring封装好的jms api，需要注入Spring的JMS连接工厂
2 编写消息生产方业务代码
@Autowired private JmsTemplate jmsTemplate; @Override public void update(Product product, final String ids) throws SolrServerException, IOException { Example example = new Example(Product.class); // 将ids的字符串转成list集合 List arrayList = new ArrayList 3 编写消息消费方业务代码
接口
/** * 添加商品到solr服务器中 * * @param ids * @throws SolrServerException * @throws IOException */ public void addProduct(String ids) throws SolrServerException, IOException;
实现类
@Autowiredprivate SkuDAO skuDAO;@Autowiredprivate ProductDAO productDAO;@Overridepublic void addProduct(String ids) throws SolrServerException, IOException {Example example = new Example(Product.class);// 将ids的字符串转成list集合List arrayList = new ArrayList 4 配置消息消费方
编写自定义消息监听器类
/** * 自定义消息监听器类 * * @author Administrator * */public class MyMessageListener implements MessageListener { @Autowired private SolrService solrService; /** * 当监听到消息后，会自动调用此方法 */ @Override public void onMessage(Message message) { // TODO Auto-generated method stub ActiveMQTextMessage amessage = (ActiveMQTextMessage) message; try { String ids = amessage.getText(); System.out.println("消费方接收到的消息：" + ids); // 添加商品信息到solr服务器 solrService.addProduct(ids); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SolrServerException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } }}