-
Notifications
You must be signed in to change notification settings - Fork 975
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #180 from rememberber/develop
Develop
- Loading branch information
Showing
45 changed files
with
1,308 additions
and
272 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
178 changes: 178 additions & 0 deletions
178
src/main/java/com/fangxuele/tool/push/logic/BoostPushRunThread.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,178 @@ | ||
| package com.fangxuele.tool.push.logic; | ||
|
|
||
| import cn.hutool.core.date.BetweenFormater; | ||
| import cn.hutool.core.date.DateUtil; | ||
| import cn.hutool.core.io.FileUtil; | ||
| import cn.hutool.core.thread.ThreadUtil; | ||
| import cn.hutool.cron.pattern.CronPattern; | ||
| import cn.hutool.cron.pattern.CronPatternUtil; | ||
| import cn.hutool.log.Log; | ||
| import cn.hutool.log.LogFactory; | ||
| import com.fangxuele.tool.push.App; | ||
| import com.fangxuele.tool.push.logic.msgsender.IMsgSender; | ||
| import com.fangxuele.tool.push.logic.msgsender.MsgSenderFactory; | ||
| import com.fangxuele.tool.push.logic.msgthread.MsgAsyncSendThread; | ||
| import com.fangxuele.tool.push.ui.form.BoostForm; | ||
| import com.fangxuele.tool.push.util.ConsoleUtil; | ||
| import org.apache.commons.compress.utils.Lists; | ||
| import org.apache.commons.lang3.time.DateFormatUtils; | ||
| import org.apache.http.HttpResponse; | ||
|
|
||
| import javax.swing.*; | ||
| import java.io.IOException; | ||
| import java.util.Date; | ||
| import java.util.List; | ||
| import java.util.concurrent.Future; | ||
|
|
||
| /** | ||
| * <pre> | ||
| * 性能模式推送执行控制线程 | ||
| * </pre> | ||
| * | ||
| * @author <a href="https://github.com/rememberber">RememBerBer</a> | ||
| * @since 2019/7/7. | ||
| */ | ||
| public class BoostPushRunThread extends Thread { | ||
|
|
||
| private static final Log logger = LogFactory.get(); | ||
|
|
||
| public static List<Future<HttpResponse>> futureList = Lists.newArrayList(); | ||
|
|
||
| @Override | ||
| public void run() { | ||
| BoostForm.boostForm.getProcessedProgressBar().setIndeterminate(true); | ||
| BoostForm.boostForm.getCompletedProgressBar().setIndeterminate(true); | ||
| // 准备推送 | ||
| preparePushRun(); | ||
| BoostForm.boostForm.getProcessedProgressBar().setIndeterminate(false); | ||
| BoostForm.boostForm.getCompletedProgressBar().setIndeterminate(false); | ||
| ConsoleUtil.boostConsoleWithLog("推送开始……"); | ||
| // 消息数据分片以及线程纷发 | ||
| shardingAndMsgThread(); | ||
| // 时间监控 | ||
| timeMonitor(); | ||
| } | ||
|
|
||
| /** | ||
| * 准备推送 | ||
| */ | ||
| private void preparePushRun() { | ||
| // 按钮状态 | ||
| BoostForm.boostForm.getScheduledRunButton().setEnabled(false); | ||
| BoostForm.boostForm.getStartButton().setEnabled(false); | ||
| BoostForm.boostForm.getStopButton().setEnabled(true); | ||
|
|
||
| BoostForm.boostForm.getStopButton().setText("停止"); | ||
| // 初始化 | ||
| BoostForm.boostForm.getProcessedCountLabel().setText("0"); | ||
| BoostForm.boostForm.getSuccessCountLabel().setText("0"); | ||
| BoostForm.boostForm.getFailCountLabel().setText("0"); | ||
|
|
||
| // 设置是否空跑 | ||
| PushControl.dryRun = BoostForm.boostForm.getDryRunCheckBox().isSelected(); | ||
|
|
||
| // 执行前重新导入目标用户 | ||
| PushControl.reimportMembers(); | ||
|
|
||
| // 重置推送数据 | ||
| PushData.reset(); | ||
| PushData.startTime = System.currentTimeMillis(); | ||
|
|
||
| // 拷贝准备的目标用户 | ||
| PushData.toSendList.addAll(PushData.allUser); | ||
| PushData.toSendCount.set(PushData.allUser.size()); | ||
| // 总记录数 | ||
| PushData.totalRecords = PushData.toSendList.size(); | ||
|
|
||
| BoostForm.boostForm.getMemberCountLabel().setText("消息总数：" + PushData.totalRecords); | ||
| BoostForm.boostForm.getProcessedProgressBar().setMaximum((int) PushData.totalRecords); | ||
| BoostForm.boostForm.getCompletedProgressBar().setMaximum((int) PushData.totalRecords); | ||
| ConsoleUtil.boostConsoleWithLog("消息总数：" + PushData.totalRecords); | ||
| // 可用处理器核心数量 | ||
| BoostForm.boostForm.getProcessorCountLabel().setText("可用处理器核心：" + Runtime.getRuntime().availableProcessors()); | ||
| ConsoleUtil.boostConsoleWithLog("可用处理器核心：" + Runtime.getRuntime().availableProcessors()); | ||
|
|
||
| // 准备消息构造器 | ||
| PushControl.prepareMsgMaker(); | ||
| } | ||
|
|
||
| /** | ||
| * 消息数据分片以及线程纷发 | ||
| */ | ||
| private static void shardingAndMsgThread() { | ||
|
|
||
| MsgAsyncSendThread msgAsyncSendThread; | ||
|
|
||
| IMsgSender msgSender = MsgSenderFactory.getMsgSender(); | ||
| msgAsyncSendThread = new MsgAsyncSendThread(msgSender); | ||
|
|
||
| ThreadUtil.execute(msgAsyncSendThread); | ||
| ConsoleUtil.boostConsoleWithLog("线程启动完毕……"); | ||
| } | ||
|
|
||
| /** | ||
| * 时间监控 | ||
| */ | ||
| private void timeMonitor() { | ||
| long startTimeMillis = System.currentTimeMillis(); | ||
| // 计时 | ||
| while (true) { | ||
| if (PushData.toSendCount.get() <= PushData.successRecords.longValue() + PushData.failRecords.longValue()) { | ||
| if (!PushData.fixRateScheduling) { | ||
| BoostForm.boostForm.getStopButton().setEnabled(false); | ||
| BoostForm.boostForm.getStopButton().updateUI(); | ||
| BoostForm.boostForm.getStartButton().setEnabled(true); | ||
| BoostForm.boostForm.getStartButton().updateUI(); | ||
| BoostForm.boostForm.getScheduledRunButton().setEnabled(true); | ||
| BoostForm.boostForm.getScheduledRunButton().updateUI(); | ||
| BoostForm.boostForm.getScheduledTaskLabel().setText(""); | ||
| String finishTip = "发送完毕！\n"; | ||
| JOptionPane.showMessageDialog(BoostForm.boostForm.getBoostPanel(), finishTip, "提示", | ||
| JOptionPane.INFORMATION_MESSAGE); | ||
| BoostForm.boostForm.getScheduledTaskLabel().setVisible(false); | ||
| } else { | ||
| if (App.config.isRadioCron()) { | ||
| Date nextDate = CronPatternUtil.nextDateAfter(new CronPattern(App.config.getTextCron()), new Date(), true); | ||
| BoostForm.boostForm.getScheduledTaskLabel().setText("计划任务执行中，下一次执行时间：" + DateFormatUtils.format(nextDate, "yyyy-MM-dd HH:mm:ss")); | ||
| } | ||
| BoostForm.boostForm.getStopButton().setText("停止计划任务"); | ||
| } | ||
|
|
||
| PushData.endTime = System.currentTimeMillis(); | ||
|
|
||
| // 保存停止前的数据 | ||
| try { | ||
| // 空跑控制 | ||
| if (!BoostForm.boostForm.getDryRunCheckBox().isSelected()) { | ||
| ConsoleUtil.boostConsoleWithLog("正在保存结果数据……"); | ||
| BoostForm.boostForm.getCompletedProgressBar().setIndeterminate(true); | ||
| PushControl.savePushData(); | ||
| ConsoleUtil.boostConsoleWithLog("结果数据保存完毕！"); | ||
| } | ||
| } catch (IOException e) { | ||
| logger.error(e); | ||
| } finally { | ||
| BoostForm.boostForm.getCompletedProgressBar().setIndeterminate(false); | ||
| } | ||
| break; | ||
| } | ||
|
|
||
| long currentTimeMillis = System.currentTimeMillis(); | ||
| long lastTimeMillis = currentTimeMillis - startTimeMillis; | ||
| long leftTimeMillis = (long) ((double) lastTimeMillis / (PushData.sendSuccessList.size() + PushData.sendFailList.size()) * (PushData.allUser.size() - PushData.sendSuccessList.size() - PushData.sendFailList.size())); | ||
|
|
||
| // 耗时 | ||
| String formatBetweenLast = DateUtil.formatBetween(lastTimeMillis, BetweenFormater.Level.SECOND); | ||
| BoostForm.boostForm.getLastTimeLabel().setText("".equals(formatBetweenLast) ? "0s" : formatBetweenLast); | ||
|
|
||
| // 预计剩余 | ||
| String formatBetweenLeft = DateUtil.formatBetween(leftTimeMillis, BetweenFormater.Level.SECOND); | ||
| BoostForm.boostForm.getLeftTimeLabel().setText("".equals(formatBetweenLeft) ? "0s" : formatBetweenLeft); | ||
|
|
||
| BoostForm.boostForm.getJvmMemoryLabel().setText("JVM内存占用：" + FileUtil.readableFileSize(Runtime.getRuntime().totalMemory()) + "/" + FileUtil.readableFileSize(Runtime.getRuntime().maxMemory())); | ||
|
|
||
| ThreadUtil.safeSleep(100); | ||
| } | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.