lion/lionwebsite-backend
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

子节点恢复时发送未完成任务

Browse Source
This commit is contained in:
chuzhongzai 2025-03-22 23:47:21 +08:00
parent c1ff2938bf
commit d7ba01be2d
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/com/lion/lionwebsite/Service/RemoteService.java
View File

@ -87,6 +87,8 @@ public class RemoteService {
if(pushService != null) if(pushService != null)
pushService.storageNodeOnline(); pushService.storageNodeOnline();
//子节点上线时，发送未完成的任务
resetUndone();
channel = channelFuture.channel(); channel = channelFuture.channel();
channel.writeAndFlush(new IdentityMessage("lionwebsite")); channel.writeAndFlush(new IdentityMessage("lionwebsite"));
return true; return true;
@ -101,6 +103,18 @@ public class RemoteService {
return channelFuture.channel() == null || !channelFuture.channel().isActive(); return channelFuture.channel() == null || !channelFuture.channel().isActive();
} }
public void resetUndone(){
if (channelFuture.channel() == null || !channelFuture.channel().isActive())
return;
Gallery[] galleries = galleryMapper.selectUnDoneGalleries();
if(galleries != null && galleries.length != 0) {
log.info("发送未下载完成图片至节点,{}本", galleries.length);
for (Gallery gallery : galleries)
addGalleryToQueue(gallery);
}
}
public byte addGalleryToQueue(Gallery gallery){ public byte addGalleryToQueue(Gallery gallery){
GalleryTask galleryTask = new GalleryTask(); GalleryTask galleryTask = new GalleryTask();
galleryTask.setGid(gallery.getGid()); galleryTask.setGid(gallery.getGid());