Package com.bytedesk.kbase.llm_webpage.mq

Class WebpageMessageService

java.lang.Object
com.bytedesk.kbase.llm_webpage.mq.WebpageMessageService
@Service public class WebpageMessageService extends Object
网页消息服务 使用Artemis JMS将网页索引操作发送到消息队列进行异步处理
Author:
jackning

  • Field Details

    • jmsTemplate

      @Autowired private org.springframework.jms.core.JmsTemplate jmsTemplate

  • Constructor Details

    • WebpageMessageService

      public WebpageMessageService()

  • Method Details

    • sendToIndexQueue

      public void sendToIndexQueue(String webpageUid)
      发送网页到索引队列，用于创建或更新索引 增加了延迟发送机制和重试机制，避免同时大量索引导致冲突
      Parameters:
      webpageUid - 网页的唯一标识

    • sendToDeleteQueue

      public void sendToDeleteQueue(String webpageUid)
      发送网页删除消息到队列
      Parameters:
      webpageUid - 网页的唯一标识

    • sendToElasticIndexQueue

      public void sendToElasticIndexQueue(String webpageUid)
      发送仅更新全文索引的消息
      Parameters:
      webpageUid - 网页的唯一标识

    • sendToVectorIndexQueue

      public void sendToVectorIndexQueue(String webpageUid)
      发送仅更新向量索引的消息
      Parameters:
      webpageUid - 网页的唯一标识