Package com.bytedesk.kbase.llm_file.mq

Class FileChunkMessageService

java.lang.Object
com.bytedesk.kbase.llm_file.mq.FileChunkMessageService
@Service public class FileChunkMessageService extends Object
文件Chunk消息服务 使用消息队列处理文件chunk相关的异步任务

  • Field Details

    • jmsTemplate

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

  • Constructor Details

    • FileChunkMessageService

      public FileChunkMessageService()

  • Method Details

    • sendChunkProcessMessage

      public void sendChunkProcessMessage(String fileUid)
      发送文件chunk处理请求到队列
      Parameters:
      fileUid - 文件UID

    • sendChunkRetryMessage

      public void sendChunkRetryMessage(String fileUid, Integer documentIndex, String errorMessage)
      发送chunk重试消息
      Parameters:
      fileUid - 文件UID
      documentIndex - 文档索引
      errorMessage - 错误消息

    • sendChunkProcessCompleteMessage

      public void sendChunkProcessCompleteMessage(String fileUid, Integer chunkCount)
      发送chunk处理完成通知
      Parameters:
      fileUid - 文件UID
      chunkCount - 生成的chunk数量

    • batchSendChunkIndexMessages

      public void batchSendChunkIndexMessages(Iterable<String> chunkUids)
      批量发送chunk索引消息 借鉴FAQ的批量处理机制，错峰发送chunk索引请求
      Parameters:
      chunkUids - chunk UID列表

    • processBatch

      private void processBatch(List<String> batch, int totalCount, Random random)
      处理一批chunk索引请求