36 lines
1.0 KiB
Java
36 lines
1.0 KiB
Java
package com.cnbm.websocket.task;
|
||
|
||
import com.cnbm.scheduletask.task.ITask;
|
||
import com.cnbm.websocket.server.WebSocketServer;
|
||
import lombok.extern.log4j.Log4j2;
|
||
import org.springframework.stereotype.Component;
|
||
|
||
import java.io.IOException;
|
||
import java.util.Date;
|
||
import java.util.Iterator;
|
||
import java.util.Map;
|
||
/**
|
||
* @Author weihongyang
|
||
* @Date 2022/6/29 2:01 PM
|
||
* @Version 1.0
|
||
*/
|
||
@Log4j2
|
||
@Component("sendMessageTask")
|
||
public class SendMessageTask implements ITask {
|
||
public void run(String params) {
|
||
|
||
Iterator<Map.Entry<String, WebSocketServer>> socketIt = WebSocketServer.webSocketMap.entrySet().iterator();
|
||
|
||
|
||
while (socketIt.hasNext()) {
|
||
Map.Entry<String, WebSocketServer> socketServerEntry = socketIt.next();
|
||
try {
|
||
socketServerEntry.getValue().sendMsg("定时发送："+new Date().toString());
|
||
} catch (IOException e) {
|
||
throw new RuntimeException(e);
|
||
}
|
||
}
|
||
log.info("sendMessageTask定时任务正在执行，参数为：{}", params);
|
||
}
|
||
}
|