websocket定时推送

后端代码&＃xff1a;

public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {public void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/daoshu/socket").setAllowedOrigins("*")//添加允许跨域访问.withSockJS() ;}public void configureMessageBroker(MessageBrokerRegistry registry) {registry.enableSimpleBroker("/daoshu/socket/send","/user/");//推送消息前缀registry.setApplicationDestinationPrefixes("/daoshu/socket/req");//应用请求前缀registry.setUserDestinationPrefix("/user");//推送用户前缀}&＃64;Overridepublic void addArgumentResolvers(List arg0) {}&＃64;Overridepublic void addReturnValueHandlers(List arg0) {}&＃64;Overridepublic void configureClientInboundChannel(ChannelRegistration arg0) {}&＃64;Overridepublic void configureClientOutboundChannel(ChannelRegistration arg0) {}&＃64;Overridepublic boolean configureMessageConverters(List arg0) {return false;}&＃64;Overridepublic void configureWebSocketTransport(WebSocketTransportRegistration arg0) {}}

public class WebSocketController {&＃64;Resourceprivate SimpMessagingTemplate messagingTemplate;private Timer timer;private static int imgIndex &＃61; 0;private final String[] imgList &＃61; { "0.png", "1.png", "2.png", "3.png", "4.png", "5.png", "6.png" };&＃64;RequestMapping("/index")public String index() {return "index";}&＃64;MessageMapping("/message")public ResponseMessage toUser(RequestMessage msg) {timer &＃61; new Timer(true);long delay &＃61; 0;OrderTimeTask orderTimeTask &＃61; new OrderTimeTask(msg.getMessage());timer.schedule(orderTimeTask, delay, 2000);// 设定指定的时间time,此处为5sreturn new ResponseMessage("欢迎使用webScoket&＃xff1a;" &＃43; msg.getMessage());}&＃64;ResponseBody&＃64;RequestMapping("/cancel")public ResponseMessage cancelTimer(HttpServletRequest request) {if (null !&＃61; timer) {imgIndex &＃61; 0;timer.cancel();}return new ResponseMessage("关闭成功");}class OrderTimeTask extends TimerTask {private String message;public OrderTimeTask(String message) {this.message &＃61; message;}&＃64;Overridepublic void run() {try {String imgPath &＃61; imgList[imgIndex];TextMessage textMessage;if (imgIndex &＃61;&＃61; 0) {textMessage &＃61; new TextMessage(message);} else {textMessage &＃61; new TextMessage(imgPath);}messagingTemplate.convertAndSendToUser("gis", "/message", textMessage.getPayload());imgIndex&＃43;&＃43;;if (imgIndex &＃61;&＃61; imgList.length)imgIndex &＃61; 0;} catch (Exception e) {e.printStackTrace();}}}}

前端代码&＃xff1a;

<%&＃64; page contentType&＃61;"text/html;charset&＃61;UTF-8" language&＃61;"java"%>







连接断开连接