package project.monitor.telegram.sender;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.InitializingBean;
|
|
import kernel.util.ThreadUtils;
|
import project.monitor.telegram.TelegramMessageService;
|
|
/**
|
* 短信服务类，负责从短信消息队列取出短信消息并发送
|
*/
|
public class TelegramServer implements InitializingBean, Runnable {
|
|
private static Logger logger = LoggerFactory.getLogger(TelegramServer.class);
|
|
private TelegramMessageService telegramMessageService;
|
|
/**
|
*/
|
public void run() {
|
while (true) {
|
|
try {
|
TelegramMessage item = TelegramMessageQueue.poll();
|
|
if (item != null) {
|
|
telegramMessageService.send(item.getText(),item.getParse_mode());
|
} else {
|
/*
|
* 限速，最多1秒2个
|
*/
|
ThreadUtils.sleep(500);
|
}
|
|
} catch (Throwable e) {
|
logger.error("SmsServer taskExecutor.execute() fail", e);
|
|
}
|
}
|
}
|
|
|
public void afterPropertiesSet() throws Exception {
|
|
new Thread(this, "SmsbaoServer").start();
|
if (logger.isInfoEnabled()) {
|
logger.info("启动短信(Smsbao)服务！");
|
}
|
|
}
|
|
|
|
}
|
