## API数据源 [TOC] ### 1.新增数据集 * 点击`“数据集管理”`或者`“数据”`中数据集后的 均可打开数据集管理界面   * 点击`“新增分组”`可添加分组信息；点击`“新增数据集”`可添加数据集信息  ### 2.新增分组 输入分组名称，添加即可  ### 3.新增数据源 数据集名称：可随意输入 分组：选择分组信息 数据类型：选择`“Websocket”` 数据源：选择数据源 [数据源维护](多数据源配置.md)  ### **4配置接口地址** 在接口地址一栏填写我们制作的接口地址，并点击刷新应用接口，如下图 接口地址示例：ws://localhost:8080/jeecg-boot/websocket/drag https使用wss ### **5编写WebSocket服务端** 示例代码如下: 示例中使用了([redis订阅发布](https://blog.csdn.net/qq_39507276/article/details/89045275))机制解决消息集群问题 ``` package org.jeecg.modules.drag.config.websocket; import java.util.HashMap; import java.util.Map; import java.util.concurrent.CopyOnWriteArraySet; import javax.annotation.Resource; import javax.websocket.OnClose; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import org.jeecg.common.base.BaseMap; import org.jeecg.common.constant.WebsocketConst; import org.jeecg.common.modules.redis.client.JeecgRedisClient; import org.springframework.stereotype.Component; import com.alibaba.fastjson.JSONObject; import lombok.extern.slf4j.Slf4j; /** * 拖拽websocket服务端 * * @author zyf */ @Component @Slf4j @ServerEndpoint("/websocket/drag/{chartId}") public class DragWebSocket { /** * 链接会话 */ private Session session; /** * 图表ID */ private String chartId; /** * redis队列名称 */ private static final String REDIS_TOPIC_NAME = "dragSocketHandler"; @Resource private JeecgRedisClient jeecgRedisClient; /** * 缓存 webSocket连接到单机服务class中（整体方案支持集群） */ private static CopyOnWriteArraySet<DragWebSocket> webSockets = new CopyOnWriteArraySet<>(); private static Map<String, Session> sessionPool = new HashMap<String, Session>(); @OnOpen public void onOpen(Session session, @PathParam(value = "chartId") String chartId) { try { this.session = session; this.chartId = chartId; webSockets.add(this); sessionPool.put(chartId, session); log.info("【websocket消息】有新的连接，总数为:" + webSockets.size()); } catch (Exception e) { } } @OnClose public void onClose() { try { webSockets.remove(this); sessionPool.remove(this.chartId); log.info("【websocket消息】连接断开，总数为:" + webSockets.size()); } catch (Exception e) { } } /** * 服务端推送消息 * * @param chartId * @param message */ public void pushMessage(String chartId, String message) { Session session = sessionPool.get(chartId); if (session != null && session.isOpen()) { try { log.info("【websocket消息】 单点消息:" + message); session.getAsyncRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } } /** * 服务器端推送消息 */ public void pushMessage(String message) { try { webSockets.forEach(ws -> ws.session.getAsyncRemote().sendText(message)); } catch (Exception e) { e.printStackTrace(); } } @OnMessage public void onMessage(String message) { //todo 现在有个定时任务刷，应该去掉 log.debug("【websocket消息】收到客户端消息:" + message); JSONObject obj = new JSONObject(); //业务类型 obj.put(WebsocketConst.MSG_CMD, WebsocketConst.CMD_CHECK); //消息内容 obj.put(WebsocketConst.MSG_TXT, "心跳响应"); for (DragWebSocket webSocket : webSockets) { webSocket.pushMessage(message); } } /** * 后台发送消息到redis * * @param message */ public void sendMessage(String message) { log.info("【websocket消息】广播消息:" + message); BaseMap baseMap = new BaseMap(); baseMap.put("chartId", ""); baseMap.put("message", message); jeecgRedisClient.sendMessage(REDIS_TOPIC_NAME, baseMap); } /** * 此为单点消息 * * @param chartId * @param message */ public void sendMessage(String chartId, String message) { BaseMap baseMap = new BaseMap(); baseMap.put("chartId", chartId); baseMap.put("message", message); jeecgRedisClient.sendMessage(REDIS_TOPIC_NAME, baseMap); } /** * 此为单点消息(多组件) * * @param chartIds * @param message */ public void sendMessage(String[] chartIds, String message) { for (String chartId : chartIds) { sendMessage(chartId, message); } } } ``` ### **6编写消息推送测试方法** ``` package org.jeecg.modules.drag.controller; import com.alibaba.fastjson.JSONObject; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.jeecg.common.api.vo.Result; import org.jeecg.modules.drag.config.websocket.DragWebSocket; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * 测试拖拽websocket接口 * * @author zyf */ @RestController @Api(tags = "拖拽WebSocket测试") @RequestMapping("/drag/websocket") public class DragWebSocketController { @Autowired private DragWebSocket webSocket; @PostMapping("/sendData") @ApiOperation(value = "测试拖拽组件更新", notes = "测试拖拽组件更新") public Result<String> sendData() { Result<String> result = new Result<>(); //需要推送数据的组件ID String chartId = "cfb9bb9a-5d4d-4cd0-9d2e-fb9e2be1fc92"; String message = "[{\"value\":1048,\"name\":\"波导\"},{\"value\":735,\"name\":\"oppo\"},{\"value\":580,\"name\":\"华为\"},{\"value\":484,\"name\":\"小米\"},{\"value\":300,\"name\":\"魅族\"}]"; JSONObject obj = new JSONObject(); obj.put("chartId", chartId); obj.put("result", message); webSocket.sendMessage(chartId, obj.toJSONString()); result.setResult("单发"); return result; } } ```