Browse Source
* commit 'f8329a6aff5a80f88501def038de64315f3bd408': REPORT-27138 && REPORT-27137 && REPORT-27109 && REPORT-27140research/11.0
11 changed files with 404 additions and 58 deletions
|
After Width: | Height: | Size: 611 B |
|
After Width: | Height: | Size: 1.2 KiB |
@ -0,0 +1,55 @@
|
||||
package com.fr.start; |
||||
|
||||
import com.fr.process.FineProcess; |
||||
import com.fr.process.engine.FineJavaProcessFactory; |
||||
import com.fr.process.engine.core.FineProcessContext; |
||||
|
||||
/** |
||||
* @author hades |
||||
* @version 10.0 |
||||
* Created by hades on 2020/2/21 |
||||
*/ |
||||
public class DesignerLauncher { |
||||
|
||||
private static final DesignerLauncher INSTANCE = new DesignerLauncher(); |
||||
|
||||
private String[] args; |
||||
|
||||
private DesignerLauncher() { |
||||
|
||||
} |
||||
|
||||
public static DesignerLauncher getInstance() { |
||||
return INSTANCE; |
||||
} |
||||
|
||||
public void start(String[] args) { |
||||
this.args = args; |
||||
FineJavaProcessFactory.create(). |
||||
entry("com.fr.start.MainDesigner"). |
||||
javaRuntime(DesignerJavaRuntime.getInstance().getJavaExec()). |
||||
classPath(DesignerJavaRuntime.getInstance().getClassPath()). |
||||
inheritJvmSettings(). |
||||
jvmSettings(DesignerJavaRuntime.getInstance().getJvmOptions()). |
||||
arguments(args). |
||||
startProcess(DesignerProcessType.INSTANCE); |
||||
DesignerSuperListener.getInstance().start(); |
||||
} |
||||
|
||||
private void beforeExit() { |
||||
DesignerSuperListener.getInstance().stopTask(); |
||||
FineProcess process = FineProcessContext.getProcess(DesignerProcessType.INSTANCE); |
||||
process.destroy(); |
||||
} |
||||
|
||||
public void exit() { |
||||
beforeExit(); |
||||
DesignerSuperListener.getInstance().stop(); |
||||
System.exit(0); |
||||
} |
||||
|
||||
public void restart() { |
||||
beforeExit(); |
||||
start(args); |
||||
} |
||||
} |
||||
@ -0,0 +1,38 @@
|
||||
package com.fr.start; |
||||
|
||||
import com.fr.design.mainframe.DesignerContext; |
||||
import com.fr.event.Event; |
||||
import com.fr.event.Listener; |
||||
import com.fr.event.Null; |
||||
import com.fr.process.engine.core.CarryMessageEvent; |
||||
import com.fr.process.engine.core.FineProcessContext; |
||||
import com.fr.process.engine.core.FineProcessEngineEvent; |
||||
|
||||
/** |
||||
* @author hades |
||||
* @version 10.0 |
||||
* Created by hades on 2020/2/21 |
||||
*/ |
||||
public class DesignerSubListener { |
||||
|
||||
public static DesignerSubListener INSTANCE = new DesignerSubListener(); |
||||
|
||||
public static DesignerSubListener getInstance() { |
||||
return INSTANCE; |
||||
} |
||||
|
||||
private DesignerSubListener() { |
||||
|
||||
} |
||||
|
||||
public void start() { |
||||
FineProcessContext.getParentPipe().listen(FineProcessEngineEvent.READY, new Listener<Null>() { |
||||
@Override |
||||
public void on(Event event, Null param) { |
||||
if (DesignerContext.getDesignerFrame() == null || !DesignerContext.getDesignerFrame().isShowing()) { |
||||
FineProcessContext.getParentPipe().fire(new CarryMessageEvent(DesignerProcessType.INSTANCE.obtain())); |
||||
} |
||||
} |
||||
}); |
||||
} |
||||
} |
||||
@ -0,0 +1,147 @@
|
||||
package com.fr.start; |
||||
|
||||
import com.fr.concurrent.NamedThreadFactory; |
||||
import com.fr.design.dialog.ErrorDialog; |
||||
import com.fr.design.i18n.Toolkit; |
||||
import com.fr.design.mainframe.messagecollect.StartErrorMessageCollector; |
||||
import com.fr.design.mainframe.messagecollect.entity.DesignerErrorMessage; |
||||
import com.fr.design.utils.DesignUtils; |
||||
import com.fr.event.Event; |
||||
import com.fr.event.Listener; |
||||
import com.fr.event.Null; |
||||
import com.fr.process.FineProcess; |
||||
import com.fr.process.ProcessEventPipe; |
||||
import com.fr.process.engine.core.FineProcessContext; |
||||
import com.fr.process.engine.core.FineProcessEngineEvent; |
||||
import com.fr.stable.StringUtils; |
||||
|
||||
import java.util.concurrent.Executors; |
||||
import java.util.concurrent.ScheduledExecutorService; |
||||
import java.util.concurrent.ScheduledFuture; |
||||
import java.util.concurrent.TimeUnit; |
||||
|
||||
/** |
||||
* @author hades |
||||
* @version 10.0 |
||||
* Created by hades on 2020/2/21 |
||||
*/ |
||||
public class DesignerSuperListener { |
||||
|
||||
private static final DesignerSuperListener INSTANCE = new DesignerSuperListener(); |
||||
private static final int ONCE_DELAY = 90; |
||||
private static final int FIXED_DELAY = 0; |
||||
private static final int FIXED_FREQ = 2; |
||||
|
||||
private final ScheduledExecutorService service = Executors.newScheduledThreadPool(2, new NamedThreadFactory("DesignerListener")); |
||||
|
||||
private FineProcess process; |
||||
private ScheduledFuture fixedFuture; |
||||
private ScheduledFuture onceFuture; |
||||
|
||||
private DesignerSuperListener() { |
||||
|
||||
} |
||||
|
||||
public static DesignerSuperListener getInstance() { |
||||
return INSTANCE; |
||||
} |
||||
|
||||
public void start() { |
||||
process = FineProcessContext.getProcess(DesignerProcessType.INSTANCE); |
||||
startExitListener(); |
||||
startFrameListener(); |
||||
startFallBackListener(); |
||||
} |
||||
|
||||
private void startExitListener() { |
||||
process.getPipe().listen(FineProcessEngineEvent.DESTROY, new Listener<Null>() { |
||||
@Override |
||||
public void on(Event event, Null param) { |
||||
DesignerLauncher.getInstance().exit(); |
||||
} |
||||
}); |
||||
} |
||||
|
||||
private void startFrameListener() { |
||||
onceFuture = service.schedule(new Runnable() { |
||||
@Override |
||||
public void run() { |
||||
ProcessEventPipe pipe = process.getPipe(); |
||||
pipe.fire(FineProcessEngineEvent.READY); |
||||
if (StringUtils.isNotEmpty(pipe.info())) { |
||||
frameReport(); |
||||
} |
||||
} |
||||
}, ONCE_DELAY, TimeUnit.SECONDS); |
||||
|
||||
} |
||||
|
||||
private void frameReport() { |
||||
DesignUtils.initLookAndFeel(); |
||||
StartErrorMessageCollector.getInstance().record(DesignerErrorMessage.UNEXCEPTED_START_FAILED.getId(), |
||||
DesignerErrorMessage.UNEXCEPTED_START_FAILED.getMessage(), |
||||
StringUtils.EMPTY); |
||||
ErrorDialog dialog = new ErrorDialog(null, |
||||
Toolkit.i18nText("Fine-Design_Error_Start_Apology_Message"), |
||||
Toolkit.i18nText("Fine-Design_Error_Start_Report"), |
||||
Toolkit.i18nText(DesignerErrorMessage.UNEXCEPTED_START_FAILED.getMessage())) { |
||||
@Override |
||||
protected void okEvent() { |
||||
dispose(); |
||||
} |
||||
|
||||
@Override |
||||
protected void restartEvent() { |
||||
dispose(); |
||||
DesignerLauncher.getInstance().restart(); |
||||
} |
||||
}; |
||||
dialog.setVisible(true); |
||||
DesignerLauncher.getInstance().exit(); |
||||
} |
||||
|
||||
private void startFallBackListener() { |
||||
fixedFuture = service.scheduleAtFixedRate(new Runnable() { |
||||
@Override |
||||
public void run() { |
||||
if (!process.isAlive()) { |
||||
fallBackReport(); |
||||
} |
||||
} |
||||
}, FIXED_DELAY, FIXED_FREQ, TimeUnit.SECONDS); |
||||
} |
||||
|
||||
private void fallBackReport() { |
||||
DesignUtils.initLookAndFeel(); |
||||
StartErrorMessageCollector.getInstance().record(DesignerErrorMessage.UNEXCEPTED_FALL_BACK.getId(), |
||||
DesignerErrorMessage.UNEXCEPTED_FALL_BACK.getMessage(), |
||||
StringUtils.EMPTY); |
||||
ErrorDialog dialog = new ErrorDialog(null, |
||||
Toolkit.i18nText("Fine-Design_Error_Fall_Back_Apology_Message"), |
||||
Toolkit.i18nText("Fine-Design_Error_Fall_Back_Report"), |
||||
Toolkit.i18nText(DesignerErrorMessage.UNEXCEPTED_FALL_BACK.getMessage())) { |
||||
@Override |
||||
protected void okEvent() { |
||||
dispose(); |
||||
} |
||||
|
||||
@Override |
||||
protected void restartEvent() { |
||||
dispose(); |
||||
DesignerLauncher.getInstance().restart(); |
||||
} |
||||
}; |
||||
dialog.setVisible(true); |
||||
DesignerLauncher.getInstance().exit(); |
||||
} |
||||
|
||||
public void stopTask() { |
||||
onceFuture.cancel(false); |
||||
fixedFuture.cancel(false); |
||||
} |
||||
|
||||
public void stop() { |
||||
stopTask(); |
||||
service.shutdown(); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue