pig cloud框架中引入websocket
一、依赖添加(Maven)
<!-- websocket依赖--><dependency><groupId>com.pig4cloud.plugin</groupId><artifactId>websocket-spring-boot-starter</artifactId><version>3.0.0</version></dependency>
二、开箱即用websocket
创建service服务层,实现websock推送
package com.wxzx.scheduling.zk.controller;@Slf4j
@RestController
@RequestMapping("/websocket")
public class WebSocketTestController {@Autowiredprivate CanalConnector canalConnector;@GetMapping("/test")public void getCanalStatus() {// 业务代码实现String jsonResult = JSONObject.toJSONString(checkInOutVoWebSocketVos);try {log.info("websocket推送成功");// 这里直接使用WebSocketMessageSender.broadcast(jsonResult);} catch (Exception e) {log.error("websocket推送数据失败:"+e.getMessage(),e);}}}