56分布式电商项目 - ActiveMQ 实现运营商后台与搜索服务的零耦合(一)

简介: 56分布式电商项目 - ActiveMQ 实现运营商后台与搜索服务的零耦合(一)

运用消息中间件ActiveMQ实现运营商后台与搜索服务的零耦合。运营商执行商品审后,向 ActiveMQ 发送消息(SKU 列表),搜索服务从 ActiveMQ 接收到消息并导入到 solr 索引库。

消息生产者(运营商后台)

1)pinyougou-manager-web 的 pom.xml,引入依赖:

<dependency> 
  <groupId>org.apache.activemq</groupId> 
  <artifactId>activemq-client</artifactId> 
  <version>5.13.4</version>
</dependency>

2)pinyougou-sellergoods-service 工程添加 spring-activemq.xml内容如下:

3)代码实现:

@Autowired
private Destination queueSolrDestination;//用于发送 solr 导入的消息
@Autowired
private JmsTemplate jmsTemplate;
@RequestMapping("/updateStatus")
public Result updateStatus(Long[] ids,String status){
  try {
    goodsService.updateStatus(ids, status);
    //按照 SPU ID 查询 SKU 列表(状态为 1)
    if(status.equals("1")){
    //审核通过List<TbItem> 
    itemList = goodsService.findItemListByGoodsIdandStatus(ids, status);//调用搜索接口实现数据批量导入
    if(itemList.size()>0){
    final String jsonString = JSON.toJSONString(itemList);
    jmsTemplate.send(queueSolrDestination, new MessageCreator() {
    @Override
    public Message createMessage(Session session) throws JMSException {
    return session.createTextMessage(jsonString);
    }
    });
    }else{
    System.out.println("没有明细数据");
    }
     }return new Result(true, "修改状态成功"); 
     } catch (Exception e) {
     e.printStackTrace();return new Result(false, "修改状态失败");
     }
      }

消息消费者(搜索服务)

1)修改 pinyougou-search-service ,在 pom.xml 中添加 activemq 依赖

<dependency> 
  <groupId>org.apache.activemq</groupId> 
  <artifactId>activemq-client</artifactId> 
  <version>5.13.4</version>
</dependency>

2)添加 spring 配置文件 applicationContext-jms-consumer.xml

<!-- 真正可以产生 Connection 的 ConnectionFactory,由对应的 JMS 服务厂商提供--> 
<bean id="targetConnectionFactory"class="org.apache.activemq.ActiveMQConnectionFactory"> 
  <property name="brokerURL" value="tcp://192.168.25.135:61616"/>
</bean>
<!-- Spring 用于管理真正的 ConnectionFactory 的 ConnectionFactory -->
 <bean id="connectionFactory"class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory" ref="targetConnectionFactory"/>
  </bean>
  <!--这个是队列目的地,点对点的 文本信息--> 
  <bean id="queueSolrDestination"class="org.apache.activemq.command.ActiveMQQueue"> 
    <constructor-arg value="pinyougou_queue_solr"/>
  </bean>
<!-- 消息监听容器 --> 
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destination" ref="queueSolrDestination" />    <property name="messageListener" ref="itemSearchListener" /
   </bean>

3) 代码实现

@Component
public class ItemSearchListener implements MessageListener{
@Autowired
private ItemSearchService itemSearchService;
@Override
public void onMessage(Message message) {
  System.out.println("监听接收到消息...");
  try {
      TextMessage textMessage=(TextMessage)message;
      String text = textMessage.getText();
      List<TbItem> list = JSON.parseArray(text,TbItem.class);
      for(TbItem item:list){
      System.out.println(item.getId()+" "+item.getTitle());
      Map specMap= JSON.parseObject(item.getSpec());//将 spec 字段中的 json
      字符串转换为 map
      item.setSpecMap(specMap);//给带注解的字段赋值
    }
    itemSearchService.importList(list);//导入
    System.out.println("成功导入到索引库");
  } catch (Exception e) {
    e.printStackTrace();
  } 
} 
}


目录
打赏
0
0
0
0
253
分享
相关文章
文生图架构设计原来如此简单之分布式服务
想象一下,当成千上万的用户同时要求AI画图,如何公平高效地处理这些请求?文生图/图生图大模型的架构设计看似复杂,实则遵循简单而有效的原则:合理排队、分工明确、防患未然。
168 14
文生图架构设计原来如此简单之分布式服务
|
2月前
|
Elasticsearch Enterprise 9.0 发布 - 分布式搜索和分析引擎
Elasticsearch Enterprise 9.0 (macOS, Linux, Windows) - 分布式搜索和分析引擎
138 0
|
2月前
|
Elasticsearch Enterprise 8.18 发布 - 分布式搜索和分析引擎
Elasticsearch Enterprise 8.18 (macOS, Linux, Windows) - 分布式搜索和分析引擎
73 0
分布式锁服务深度解析:以Apache Flink的Checkpointing机制为例
【10月更文挑战第7天】在分布式系统中,多个进程或节点可能需要同时访问和操作共享资源。为了确保数据的一致性和系统的稳定性,我们需要一种机制来协调这些进程或节点的访问,避免并发冲突和竞态条件。分布式锁服务正是为此而生的一种解决方案。它通过在网络环境中实现锁机制,确保同一时间只有一个进程或节点能够访问和操作共享资源。
293 3
ElasticSearch的简单介绍与使用【进阶检索】 实时搜索 | 分布式搜索 | 全文搜索 | 大数据处理 | 搜索过滤 | 搜索排序
这篇文章是Elasticsearch的进阶使用指南,涵盖了Search API的两种检索方式、Query DSL的基本语法和多种查询示例,包括全文检索、短语匹配、多字段匹配、复合查询、结果过滤、聚合操作以及Mapping的概念和操作,还讨论了Elasticsearch 7.x和8.x版本中type概念的变更和数据迁移的方法。
ElasticSearch的简单介绍与使用【进阶检索】 实时搜索 | 分布式搜索 | 全文搜索 | 大数据处理 | 搜索过滤 | 搜索排序
git分布式版本控制系统及在码云上创建项目并pull和push
通过本文的介绍,我们详细讲解了Git的基本概念和工作流程,并展示了如何在码云上创建项目及进行pull和push操作。Git作为一种分布式版本控制系统,为开发者提供了强大的工具来管理代码变更和协作开发。希望本文能帮助您更好地理解和使用Git及码云,提高开发效率和代码质量。
135 18
git分布式版本控制系统及在码云上创建项目并pull和push
通过本文的介绍,我们详细讲解了Git的基本概念和工作流程,并展示了如何在码云上创建项目及进行pull和push操作。Git作为一种分布式版本控制系统,为开发者提供了强大的工具来管理代码变更和协作开发。希望本文能帮助您更好地理解和使用Git及码云,提高开发效率和代码质量。
102 16
分布式系统架构3:服务容错
分布式系统因其复杂性,故障几乎是必然的。那么如何让系统在不可避免的故障中依然保持稳定?本文详细介绍了分布式架构中7种核心的服务容错策略,包括故障转移、快速失败、安全失败等,以及它们在实际业务场景中的应用。无论是支付场景的快速失败,还是日志采集的安全失败,每种策略都有自己的适用领域和优缺点。此外,文章还为技术面试提供了解题思路,助你在关键时刻脱颖而出。掌握这些策略,不仅能提升系统健壮性,还能让你的技术栈更上一层楼!快来深入学习,走向架构师之路吧!
184 12
|
10月前
|
面试官:项目中如何实现分布式锁?
面试官:项目中如何实现分布式锁?
219 6
面试官:项目中如何实现分布式锁?

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等