?? sendthread.java
字號:
package com.wireless.sms.ismp.global;
import java.util.Timer;
import java.util.TimerTask;
import com.wireless.sms.ismp.InitHandler;
import com.wireless.sms.pub.entity.MO;
import com.wireless.sms.pub.entity.Monitor;
import com.wireless.sms.pub.net.MOClientSocket;
import com.wireless.sms.pub.net.MonitorClientSocket;
public class SendThread {
private static SendThread _instance = new SendThread();
private Timer timer = null;
public MOClientSocket moClientSocket = null;
public static SendThread getInstance() {
return _instance;
}
private SendThread() {
}
public void start() {
if (timer == null) {
LoggerConstant.mo_log.info("Start mo sender !");
moClientSocket = new MOClientSocket(InitHandler.ROUTERHOST,
InitHandler.ROUTERPORTS);
timer = new Timer();
timer.schedule(new TimerTask() {
public void run() {
MO mo = (MO) InitHandler.MOQUEUE.removeNoWait();
if (mo != null) {
boolean sendFlag = moClientSocket.sendMO(mo);
if (sendFlag) {
LoggerConstant.mo_log.info("發送 MO 成功 !");
} else {
InitHandler.MOQUEUE.add(mo);
sendmonitor("R000101");
}
}
}
}, 5000, 500);
}
}
public void stop() {
if (timer != null) {
timer.cancel();
timer = null;
LoggerConstant.mo_log.info("Stop mo sender !");
}
}
public void sendmonitor(String code) {
Monitor monitor = new Monitor();
monitor.setErrorCode(code);
monitor.setIp(InitHandler.PROCESSHOST);
monitor.setPeriod("");
monitor.setProcessName(InitHandler.switch_name);
MonitorClientSocket errorsocket = new MonitorClientSocket(
InitHandler.MONITORHOST, InitHandler.MONITORPORT);
errorsocket.sendMonitor(monitor);
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -