hades
5 years ago
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