From df80448fbd1bccdba131d797c0c7e93274ed6ba1 Mon Sep 17 00:00:00 2001 From: ZhuDongming <773644075@qq.com> Date: Sun, 28 Jun 2020 16:51:44 +0800 Subject: [PATCH] update离线去除风向图标 --- src/main/java/com/moral/webSocketServer/WebSocketServer.java | 20 +++++++++++++++----- 1 files changed, 15 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/moral/webSocketServer/WebSocketServer.java b/src/main/java/com/moral/webSocketServer/WebSocketServer.java index e019555..59a9783 100644 --- a/src/main/java/com/moral/webSocketServer/WebSocketServer.java +++ b/src/main/java/com/moral/webSocketServer/WebSocketServer.java @@ -2,6 +2,7 @@ import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet; +import java.util.concurrent.TimeoutException; import javax.websocket.OnClose; import javax.websocket.OnError; @@ -38,6 +39,10 @@ private String regionCode; + private Connection connection; + + private Channel channel; + // ������session��������������������������� private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>(); @@ -64,8 +69,8 @@ factory.setUsername("guest"); factory.setPassword("guest_pass"); String routingKey = orgId+".*"; - Connection connection = factory.newConnection(); - Channel channel = connection.createChannel(); + connection = factory.newConnection(); + channel = connection.createChannel(); //��������������������������������������������������������������������������������������������������������� channel.queueDeclare(QUEUE_NAME, false, false, true, null); channel.queueBind(QUEUE_NAME,"screens_data",routingKey); @@ -82,7 +87,6 @@ sendMessage(message); } }catch (Exception e){ - e.printStackTrace(); log.error(e.getMessage()); } } @@ -94,6 +98,12 @@ public void onClose() { /**���������Set��� ������������������������*/ webSocketSet.remove(this); + try { + channel.close(); + connection.close(); + }catch (IOException | TimeoutException e){ + log.error(e.getMessage()); + } } @OnMessage @@ -127,7 +137,7 @@ this.session.getBasicRemote().sendText(message); } } catch (IOException e) { - e.printStackTrace(); + log.error(e.getMessage()); } } @@ -139,7 +149,7 @@ */ @OnError public void onError(Session session, Throwable error) { - error.printStackTrace(); + log.error(error.getMessage()); } } -- Gitblit v1.8.0