ActiveMQ添加商品接收消息

Destination

配置信息

<!-- 配置消息的Destination对象 -->
<bean id="test-queue" class="org.apache.activemq.command.ActiveMQQueue"><constructor-arg name="name" value="test-queue"></constructor-arg>
</bean>
<bean id="itemAddTopic" class="org.apache.activemq.command.ActiveMQTopic"><constructor-arg name="name" value="item-add-topic"></constructor-arg>
</bean>

添加监听器

ItemAddMessageListener
监听添加商品事件

public class ItemAddMessageListener implements MessageListener {@Autowiredprivate SearchItemMapper searchItemMapper;@Autowiredprivate SolrServer solrServer;@Overridepublic void onMessage(Message message) {try {// 从消息中取商品idTextMessage textMessage = (TextMessage) message;String text = textMessage.getText();long itemId = Long.parseLong(text);// 根据商品id查询数据，取商品信息// 等待事务提交Thread.sleep(1000);SearchItem searchItem = searchItemMapper.getItemById(itemId);// 创建文档对象SolrInputDocument document = new SolrInputDocument();// 向文档对象中添加域document.addField("id", searchItem.getId());document.addField("item_title", searchItem.getTitle());document.addField("item_sell_point", searchItem.getSell_point());document.addField("item_price", searchItem.getPrice());document.addField("item_image", searchItem.getImage());document.addField("item_category_name", searchItem.getCategory_name());document.addField("item_desc", searchItem.getItem_desc());// 把文档对象写入索引库solrServer.add(document);// 提交solrServer.commit();} catch (Exception e) {e.printStackTrace();}}}

配置监听器

ItemAddMessageListener

<!-- 配置消息的接收者 -->
<!-- 配置监听器 -->
<bean id="myMessageListener" class="com.taotao.search.listener.MyMessageListener"/>
<!-- 消息监听容器 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="test-queue" /><property name="messageListener" ref="myMessageListener" />
</bean>
<bean id="itemAddMessageListener" class="com.taotao.search.listener.ItemAddMessageListener"/>
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="itemAddTopic" /><property name="messageListener" ref="itemAddMessageListener" />
</bean>

ActiveMQ添加商品接收消息相关推荐

ActiveMQ添加商品发送消息
添加商品需要同步索引库,同步缓存,生成静态页面等等很多地方,都需要监听添加商品的事件,所以,这里使用Topic模式方案选择方案一:直接写业务逻辑在商品服务模块,添加商品的业务逻辑中,添加同步 ...
ActiveMQ 发送和接收消息
一.添加 jar 包 <dependency><groupId>org.apache.activemq</groupId><artifactId>act ...
activeMQ高并发发送消息异常解决方法
高并发发送消息异常解决方法: 现象:使用10个线程每100ms发送一条消息,大约3000多条后,出现异常,所有线程停止: javax.jms.JMSException:Could not conne ...
Spring整合ActiveMQ接收消息
操作步骤第一步:把Activemq相关的jar包,添加到工程中第二步:创建一个MessageListener的实现类,负责监听第三步:配置MessageListener监听器第四步:初始化Sp ...
ActiveMQ 部署及发送接收消息
ActiveMQ 部署及发送接收消息一. 下载下载地址:http://activemq.apache.org/ 我这里使用的版本为当前最新5.8.0. 下载版本有Windows ...
ActiveMQ中消费者是如何接收消息的（二）
上篇文章大致讲述了同步消费者和异步消费者接收消息的异同(详见<ActiveMQ中消费者是如何接收消息的(一)>http://manzhizhen.iteye.com/blog/209413 ...
微信小程序添加全局 socket 并接收消息通知
最近小程序中有使用到socket,来建立长连接,实现消息通知.总结一下实现思路. 首先,在app.js中初始化socket,并处理消息,添加心跳检测. App({globalData: {suppli ...
17 个方面，综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列
点击上方"方志朋",选择"置顶公众号" 技术文章第一时间送达! 作者:28cm不含头(来自:知乎) 原文链接: https://www.zhihu.com/qu ...
实战05_SSM整合ActiveMQ支持多种类型消息
接上一篇:实战04_SSM整合ActiveMQ支持多种类型消息https://blog.csdn.net/weixin_40816738/article/details/100572124 1.Str ...

ActiveMQ添加商品接收消息

Destination

添加监听器

配置监听器

ActiveMQ添加商品接收消息相关推荐

最新文章

热门文章