activemq有哪些公司在用，主要用在什么业务场景？

消息队列在大型电子商务类网站，如京东、淘宝、去哪儿等网站有这深入的应用，队列的主要作用是消除高并发访问高峰，加快网站的响应速度。在不使用消息队列的情况下，用户的请求数据直接写入数据库，在高并发的情况下，会对数据库造成巨大的压力，同时也使得系统响应延迟加剧。在使用队列后，用户的请求发给队列后立即返回（当然不能直接给用户提示订单提交成功，京东上提示：您“您提交了订单，请等待系统确认”），再由消息队列的消费者进程从消息队列中获取数据，异步写入数据库。由于消息队列的服务处理速度远快于数据库，因此用户的响应延迟可得到有效改善。

作者：王路路
链接：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连接工厂

<!-- activemq 配置 -->
<!-- 配置连接工厂 -->
<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<!-- 配置消息服务中间件地址 -->
<property name="brokerURL" value="tcp://192.168.56.101:61616"></property>
<!-- 配置用户名和密码 -->
<property name="userName" value="admin"></property>
<property name="password" value="admin"></property>
</bean>

<!-- 配置工厂连接池 -->
<bean id="pooledConnectionFactoryBean" class="org.apache.activemq.pool.PooledConnectionFactoryBean">
<!-- 注入连接工厂bean -->
<property name="connectionFactory" ref="activeMQConnectionFactory"></property>
</bean>

<!-- 使用spring来进行管理 -->
<bean id="singleConnectionFactory"
class="org.springframework.jms.connection.SingleConnectionFactory">
<!-- 注入连接工厂连接池的bean -->
<property name="targetConnectionFactory" ref="pooledConnectionFactoryBean"></property>
</bean>

<!-- 配置JmsTemplate -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<!-- 注入使用spring来进行管理的bean -->
<property name="connectionFactory" ref="singleConnectionFactory"></property>
</bean>

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<Object>();
String[] split = ids.split(",");
for (String string : split) {
arrayList.add(string);
}

// 设置批量修改的id条件
example.createCriteria().andIn("id", arrayList);

// 进行批量，选择性属性修改
productDAO.updateByExampleSelective(product, example);

// 如果是商品上架
// 需要保存的信息有：商品id、商品名称、图片地址、售价、品牌id、上架时间（可选）
if (product.getIsShow() == 1) {
// 采用消息服务模式
// 将商品信息添加到solr服务器中（发送消息（ids）到ActiveMQ中）
jmsTemplate.send("productIds", new MessageCreator() {

@Override
public Message createMessage(Session session) throws JMSException {
// TODO Auto-generated method stub
//使用session创建文本消息
return session.createTextMessage(ids);
}
});

// 后续还有CMS-生成静态商品信息页面功能

}

}

3 编写消息消费方业务代码

接口

/**
* 添加商品到solr服务器中
*
* @param ids
* @throws SolrServerException
* @throws IOException
*/
public void addProduct(String ids) throws SolrServerException, IOException;

实现类

@Autowired
private SkuDAO skuDAO;

@Autowired
private ProductDAO productDAO;

@Override
public void addProduct(String ids) throws SolrServerException, IOException {

Example example = new Example(Product.class);

// 将ids的字符串转成list集合
List arrayList = new ArrayList<Object>();
String[] split = ids.split(",");
for (String string : split) {
arrayList.add(string);
}

// 设置批量修改的id条件
example.createCriteria().andIn("id", arrayList);

// 查询ids中的所有商品
List<Product> products = productDAO.selectByExample(example);
// 遍历查询出来的商品集合
for (Product product2 : products) {

// 将商品的各个信息，添加到文档对象中
SolrInputDocument doc = new SolrInputDocument();
doc.addField("id", product2.getId());
doc.addField("name_ik", product2.getName());
doc.addField("url", product2.getImgUrl().split(",")[0]);
doc.addField("brandId", product2.getBrandId());

// 查询出某商品库存中的最低价格
// SELECT price from bbs_sku WHERE bbs_sku.product_id = 449
// ORDER BY price ASC LIMIT 1

Example example2 = new Example(Sku.class);
// 某商品的库存
example2.createCriteria().andEqualTo("productId", product2.getId());
example2.setOrderByClause("price asc");// 价格升序
// 开始分页 limit
PageHelper.startPage(1, 1);
List<Sku> skus = skuDAO.selectByExample(example2);
// 结束分页
PageHelper.endPage();

doc.addField("price", skus.get(0).getPrice());

// 将文档对象添加到solr服务器中
solrServer.add(doc);

// 提交
solrServer.commit();
}
}

4 配置消息消费方

<!-- activemq 配置 -->
<!-- 配置连接工厂 -->
<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<!-- 配置消息服务中间件地址 -->
<property name="brokerURL" value="tcp://192.168.56.101:61616"></property>
<!-- 配置用户名和密码 -->
<property name="userName" value="admin"></property>
<property name="password" value="admin"></property>
</bean>

<!-- 配置工厂连接池 -->
<bean id="pooledConnectionFactoryBean" class="org.apache.activemq.pool.PooledConnectionFactoryBean">
<!-- 注入连接工厂bean -->
<property name="connectionFactory" ref="activeMQConnectionFactory"></property>
</bean>

<!-- 使用spring来进行管理 -->
<bean id="singleConnectionFactory"
class="org.springframework.jms.connection.SingleConnectionFactory">
<!-- 注入连接工厂连接池的bean -->
<property name="targetConnectionFactory" ref="pooledConnectionFactoryBean"></property>
</bean>

<!-- 配置JmsTemplate -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<!-- 注入使用spring来进行管理的bean -->
<property name="connectionFactory" ref="singleConnectionFactory"></property>
</bean>
<!-- 配置回调消息处理类 -->
<bean id="myMessageListener" class="cn.itcast.core.message.MyMessageListener"></bean>

<!-- 配置消息消费方监听器 -->
<bean
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<!-- 注入使用spring来进行管理的bean -->
<property name="connectionFactory" ref="singleConnectionFactory"></property>
<!-- 配置回调消息处理类：当监听到消息后，该做什么 -->
<property name="messageListener" ref="myMessageListener"></property>
<!-- 监听目标名称 -->
<property name="destinationName" value="productIds"></property>
</bean>

编写自定义消息监听器类

/**
* 自定义消息监听器类
*
* @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();
}
}
}