From c31b9d6c2ef028d49af15cad4738e93748df436c Mon Sep 17 00:00:00 2001 From: 81041 <81041@DESKTOP-025NVD9> Date: 星期四, 20 六月 2019 15:16:06 +0800 Subject: [PATCH] 去掉问题 --- sensor/src/com/fgkj/websockets/Fbs9100_stateSocket.java | 26 ++++++++++++-------------- 1 files changed, 12 insertions(+), 14 deletions(-) diff --git a/sensor/src/com/fgkj/websockets/Fbs9100_stateSocket.java b/sensor/src/com/fgkj/websockets/Fbs9100_stateSocket.java index 863850f..974a20d 100644 --- a/sensor/src/com/fgkj/websockets/Fbs9100_stateSocket.java +++ b/sensor/src/com/fgkj/websockets/Fbs9100_stateSocket.java @@ -17,12 +17,10 @@ import com.fgkj.actions.ActionUtil; import com.fgkj.dto.ServiceModel; import com.fgkj.dto.User_inf; -import com.fgkj.dto.ram.Fbs9100_state; -import com.fgkj.services.ram.Fbs9100_stateService; @ServerEndpoint("/ws/Fbs9100_stateSocket") public class Fbs9100_stateSocket extends ActionUtil{ - private Fbs9100_stateService service = new Fbs9100_stateService(); + /*private Fbs9100_stateService service = new Fbs9100_stateService(); //闈欐�佸彉閲忥紝鐢ㄦ潵璁板綍褰撳墠鍦ㄧ嚎杩炴帴鏁般�傚簲璇ユ妸瀹冭璁℃垚绾跨▼瀹夊叏鐨勩�� static int onlineCount = 0; @@ -38,10 +36,10 @@ private HttpSession httpSession; - /** + *//** * 杩炴帴寤虹珛鎴愬姛璋冪敤鐨勬柟娉� * @param session 鍙�夌殑鍙傛暟銆俿ession涓轰笌鏌愪釜瀹㈡埛绔殑杩炴帴浼氳瘽锛岄渶瑕侀�氳繃瀹冩潵缁欏鎴风鍙戦�佹暟鎹� - */ + *//* @OnOpen public void onOpen(Session session, EndpointConfig config){ this.session = session; @@ -51,9 +49,9 @@ //System.out.println("鏈夋柊杩炴帴鍔犲叆锛佸綋鍓嶅湪绾夸汉鏁颁负" + getOnlineCount()); } - /** + *//** * 杩炴帴鍏抽棴璋冪敤鐨勬柟娉� - */ + *//* @OnClose public void onClose(){ timer.cancel(); @@ -69,32 +67,32 @@ ServiceModel model = service.serchByCondition(state); return model; } - /** + *//** * 鏀跺埌瀹㈡埛绔秷鎭悗璋冪敤鐨勬柟娉� * @param message 瀹㈡埛绔彂閫佽繃鏉ョ殑娑堟伅 * @param session 鍙�夌殑鍙傛暟 - */ + *//* @OnMessage public void onMessage(String message,Session session) { task.setMessage(message); task.run(); } - /** + *//** * 鍙戠敓閿欒鏃惰皟鐢� * @param session * @param error - */ + *//* @OnError public void onError(Session session, Throwable error){ System.out.println("鍙戠敓閿欒"); error.printStackTrace(); } - /** + *//** * 杩欎釜鏂规硶涓庝笂闈㈠嚑涓柟娉曚笉涓�鏍枫�傛病鏈夌敤娉ㄨВ锛屾槸鏍规嵁鑷繁闇�瑕佹坊鍔犵殑鏂规硶銆� * @param message * @throws IOException - */ + *//* public void sendMessage(String message) throws IOException{ this.session.getBasicRemote().sendText(message); //this.session.getAsyncRemote().sendText(message); @@ -154,5 +152,5 @@ } } - +*/ } -- Gitblit v1.9.1