Package com.bytedesk.kbase.llm_faq.mq

Class FaqIndexConsumer

java.lang.Object

com.bytedesk.kbase.llm_faq.mq.FaqIndexConsumer

@Component
public class FaqIndexConsumer
extends Object

FAQ索引消费者 用于处理FAQ索引队列中的消息

Field Summary

Fields

Modifier and Type	Field	Description
private final FaqElasticService	faqElasticService
private final FaqRestService	faqRestService
private FaqVectorService	faqVectorService
private final Random	random

Constructor Summary

Constructors

Constructor	Description
FaqIndexConsumer(FaqElasticService faqElasticService, FaqRestService faqRestService)

Method Summary

Modifier and Type	Method	Description
private void	acknowledgeMessage(jakarta.jms.Message message)	安全地确认消息 只有在消息处理成功后才调用此方法
Boolean	deleteFaqVector(FaqEntity faq)	在完全独立事务中删除向量索引
private void	handleDeleteOperation(FaqEntity faq, FaqIndexMessage message)	处理删除操作 将全文索引和向量索引的删除操作分开处理
private void	handleIndexOperation(FaqEntity faq, FaqIndexMessage message)	处理索引操作 将全文索引和向量索引的操作分开处理，避免一个操作失败影响另一个操作
Boolean	processElasticDelete(String faqUid)	在单独事务中处理全文索引删除
void	processElasticIndex(FaqEntity faq)	在单独事务中处理全文索引
void	processIndexMessage(jakarta.jms.Message jmsMessage, FaqIndexMessage message)	处理FAQ索引队列中的消息 使用客户端确认模式，只有成功处理后才确认消息 增强了对乐观锁冲突的处理
Boolean	processVectorDelete(FaqEntity faq)	在单独事务中处理向量索引删除
void	processVectorIndex(FaqEntity faq)	在单独事务中处理向量索引 删除向量索引后，更新实体状态

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

faqElasticService

private final FaqElasticService faqElasticService

faqVectorService

@Autowired(required=false)
private FaqVectorService faqVectorService

faqRestService

private final FaqRestService faqRestService

random

private final Random random

Constructor Details

FaqIndexConsumer

public FaqIndexConsumer(FaqElasticService faqElasticService,
 FaqRestService faqRestService)

Method Details

processIndexMessage

@JmsListener(destination="bytedesk.queue.faq.index",
             containerFactory="jmsArtemisQueueFactory",
             concurrency="3-10")
public void processIndexMessage(jakarta.jms.Message jmsMessage,
 FaqIndexMessage message)

处理FAQ索引队列中的消息 使用客户端确认模式，只有成功处理后才确认消息 增强了对乐观锁冲突的处理

Parameters:

jmsMessage - JMS原始消息

message - FAQ索引消息

handleIndexOperation

private void handleIndexOperation(FaqEntity faq,
 FaqIndexMessage message)

处理索引操作 将全文索引和向量索引的操作分开处理，避免一个操作失败影响另一个操作

processElasticIndex

@Transactional(propagation=REQUIRES_NEW)
public void processElasticIndex(FaqEntity faq)

在单独事务中处理全文索引

processVectorIndex

public void processVectorIndex(FaqEntity faq)

在单独事务中处理向量索引 删除向量索引后，更新实体状态

deleteFaqVector

@Transactional(propagation=REQUIRES_NEW)
public Boolean deleteFaqVector(FaqEntity faq)

在完全独立事务中删除向量索引

handleDeleteOperation

private void handleDeleteOperation(FaqEntity faq,
 FaqIndexMessage message)

处理删除操作 将全文索引和向量索引的删除操作分开处理

processElasticDelete

@Transactional(propagation=REQUIRES_NEW)
public Boolean processElasticDelete(String faqUid)

在单独事务中处理全文索引删除

processVectorDelete

@Transactional(propagation=REQUIRES_NEW)
public Boolean processVectorDelete(FaqEntity faq)

在单独事务中处理向量索引删除

acknowledgeMessage

private void acknowledgeMessage(jakarta.jms.Message message)

安全地确认消息 只有在消息处理成功后才调用此方法

Parameters:

message - JMS消息