package com.product.file.util;
|
|
import java.util.HashSet;
|
import java.util.LinkedList;
|
import java.util.Set;
|
|
import org.apache.poi.openxml4j.exceptions.OLE2NotOfficeXmlFileException;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.spring.context.SpringBeanUtil;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.file.service.FileManagerService;
|
import com.product.lucene.service.LuceneService;
|
|
|
/**
|
* 消息服务，添加消息，读取消息
|
*
|
* @author shicf
|
*/
|
@Component
|
public class CreateDocumentIndexThread {
|
/**
|
* 自已实例
|
**/
|
private static CreateDocumentIndexThread createDocumentIndexThread;
|
@Autowired
|
public FileManagerService fileManagerService;
|
/**
|
* 内部线程
|
**/
|
private SendMailThread sendMailThread = null;
|
@Autowired
|
public LuceneService luceneService;
|
/**
|
* 生成的新消息队列
|
**/
|
private static LinkedList<FieldSetEntity> documentIndexs = new LinkedList<>();
|
|
/**
|
* 静态工厂方法 获取当前对象实例 多线程安全单例模式(使用双重同步锁)
|
*/
|
public static synchronized CreateDocumentIndexThread getInstance() {
|
|
if (createDocumentIndexThread == null) {
|
synchronized (CreateDocumentIndexThread.class) {
|
if (createDocumentIndexThread == null) {
|
createDocumentIndexThread = (CreateDocumentIndexThread) SpringBeanUtil.getBean("createDocumentIndexThread");
|
}
|
}
|
}
|
createDocumentIndexThread.start();
|
return createDocumentIndexThread;
|
}
|
|
/**
|
* 启动缓存的刷新线程
|
*/
|
public void start() {
|
if (sendMailThread == null || sendMailThread.getState() == Thread.State.TERMINATED) {
|
sendMailThread = new SendMailThread();
|
sendMailThread.start();
|
SpringMVCContextHolder.getSystemLogger().info("Thread Of Refresh Cache Is Starting.............");
|
}
|
}
|
|
/**
|
* 把附件信息添加对列中
|
*
|
* @param user
|
*/
|
|
public synchronized void appendAttaInfo(FieldSetEntity documentIndex) {
|
if (documentIndex != null) {
|
documentIndexs.add(documentIndex);
|
}
|
}
|
|
//重试文件的uuid集合
|
private Set<String> retryFileUuids = new HashSet<>();
|
|
/**
|
* 取刷新表队表的第一个
|
*
|
* @return
|
*/
|
public synchronized void pop() {
|
while (!documentIndexs.isEmpty()) {
|
FieldSetEntity ff = documentIndexs.pop();
|
if (luceneService == null) {
|
luceneService = (LuceneService) SpringBeanUtil.getBean("luceneService");
|
}
|
try {
|
ff.setValue("file", fileManagerService.getFile(ff.getString("attachment_uuid")));
|
} catch (Exception e) {
|
if (retryFileUuids.contains(ff.getString("attachment_uuid"))) {
|
//重试过的文件不再重试,删除队列中的文件
|
retryFileUuids.remove(ff.getString("attachment_uuid"));
|
continue;
|
} else {
|
retryFileUuids.add(ff.getString("attachment_uuid"));
|
//添加到队列的最后
|
appendAttaInfo(ff);
|
continue;
|
}
|
}
|
try {
|
|
luceneService.createdIndex(ff);
|
} catch (OLE2NotOfficeXmlFileException e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 内部线程，定时刷新缓存
|
*
|
* @author shicf
|
*/
|
class SendMailThread extends Thread {
|
@Override
|
public void run() {
|
try {
|
while (true) {
|
sleep(2000);// 执行间隔2s
|
pop();
|
}
|
} catch (InterruptedException e) {
|
e.getStackTrace();
|
}
|
}
|
}
|
|
}
|
