WebSocket.之.基礎入門-斷開連接處理

ebSocket.之.基礎入門-斷開連接處理

在《WebSocket.之.基礎入門-后端響應消息》的代碼基礎之上，繼續更新代碼。代碼只改動了：TestSocket.java 和 index.jsp 兩個文件。

先說問題：

　　當前后端建立連接之后，如果此時關閉瀏覽器，或者點擊瀏覽器的回退。只要退出了建立連接的頁面。后台程序是會報錯的。分別如下圖所示：

　　正常建立連接頁面：

　　

　　

 

　　

　　

　　現在退出當前建立連接的頁面，后台日志如下所示：

當前session的id是：0
從前端頁面傳過來的數據是：早上好..
 3 十月 14, 2018 8:52:41 上午 org.apache.tomcat.websocket.pojo.PojoEndpointBase onError
 4 嚴重: No error handling configured for [com.charles.socket.TestSocket] and the following error occurred
 5 java.io.IOException: java.util.concurrent.ExecutionException: java.net.SocketException: Software caused connection abort: socket write error
 6     at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.startMessageBlock(WsRemoteEndpointImplBase.java:286)
 7     at org.apache.tomcat.websocket.WsSession.sendCloseMessage(WsSession.java:572)
 8     at org.apache.tomcat.websocket.WsSession.onClose(WsSession.java:495)
 9     at org.apache.tomcat.websocket.WsFrameBase.processDataControl(WsFrameBase.java:348)
10     at org.apache.tomcat.websocket.WsFrameBase.processData(WsFrameBase.java:290)
11     at org.apache.tomcat.websocket.WsFrameBase.processInputBuffer(WsFrameBase.java:131)
12     at org.apache.tomcat.websocket.server.WsFrameServer.onDataAvailable(WsFrameServer.java:67)
13     at org.apache.tomcat.websocket.server.WsHttpUpgradeHandler$WsReadListener.onDataAvailable(WsHttpUpgradeHandler.java:204)
14     at org.apache.coyote.http11.upgrade.AbstractServletInputStream.onDataAvailable(AbstractServletInputStream.java:203)
15     at org.apache.coyote.http11.upgrade.AbstractProcessor.upgradeDispatch(AbstractProcessor.java:93)
16     at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:635)
17     at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:316)
18     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
19     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
20     at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
21     at java.lang.Thread.run(Thread.java:748)
22 Caused by: java.util.concurrent.ExecutionException: java.net.SocketException: Software caused connection abort: socket write error
23     at org.apache.tomcat.websocket.FutureToSendHandler.get(FutureToSendHandler.java:120)
24     at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.startMessageBlock(WsRemoteEndpointImplBase.java:281)
25     ... 15 more
26 Caused by: java.net.SocketException: Software caused connection abort: socket write error
27     at java.net.SocketOutputStream.socketWrite0(Native Method)
28     at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111)
29     at java.net.SocketOutputStream.write(SocketOutputStream.java:155)
30     at org.apache.coyote.http11.upgrade.BioServletOutputStream.doWrite(BioServletOutputStream.java:38)
31     at org.apache.coyote.http11.upgrade.AbstractServletOutputStream.writeInternal(AbstractServletOutputStream.java:153)
32     at org.apache.coyote.http11.upgrade.AbstractServletOutputStream.write(AbstractServletOutputStream.java:121)
33     at org.apache.tomcat.websocket.server.WsRemoteEndpointImplServer.onWritePossible(WsRemoteEndpointImplServer.java:94)
34     at org.apache.tomcat.websocket.server.WsRemoteEndpointImplServer.doWrite(WsRemoteEndpointImplServer.java:81)
35     at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.writeMessagePart(WsRemoteEndpointImplBase.java:456)
36     at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.startMessage(WsRemoteEndpointImplBase.java:344)
37     at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.startMessageBlock(WsRemoteEndpointImplBase.java:276)
38     ... 15 more

　　

 

　　現在開始處理上面的異常

TestSocket.java

package com.charles.socket;

import java.io.IOException;

import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint(value = "/helloSocket")
public class TestSocket {

    /***
     * 當建立鏈接時，調用的方法.
     * @param session
     */
    @OnOpen
    public void open(Session session) {
        
        System.out.println("開始建立了鏈接...");
        System.out.println("當前session的id是：" + session.getId());
    }
    
    /***
     * 處理消息的方法.
     * @param session
     */
    @OnMessage
    public void message(Session session, String data) {
        
        System.out.println("開始處理消息...");
        System.out.println("當前session的id是：" + session.getId());
        System.out.println("從前端頁面傳過來的數據是：" + data);
        
        
        String message = "你好，我是后端程序...";
        try {
            session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }
    
    /***
     * 處理斷開連接的方法.
     * @param session
     */
    @OnClose
    public void close(Session session) {
        System.out.println("Session-ID是："+session.getId() + ",退出了系統...歡迎下次再來...");
    }
    
}

 

index.jsp 代碼

<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Charles-WebSocket</title>

<script type="text/javascript">
    
    var websocket = null;
    var target = "ws://localhost:8080/websocket/helloSocket";
    
    function buildConnection() {
        
        if('WebSocket' in window) {
            websocket = new WebSocket(target);        
        } else if('MozWebSocket' in window) {
            websocket = MozWebSocket(target);
        } else {
            window.alert("瀏覽器不支持WebSocket");
        }
        
        // 添加監聽消息的方法
        websocket.onmessage = function(event) {
             console.log(event)
             console.log(event.data)
             document.getElementById("serverMsg").innerHTML = "<p>后端消息 ："+ event.data +"</p>"
        }
        
        // 監聽斷開連接的方法.
        websocket.onclose = function(event) {
            // 如沒有業務需求，可以不寫這個關閉監聽的方法.
            // 業務需求，例如：聊天室，當某人退出的時候，會給出提示，xxx退出了...
        }
    }
    
    // 退出系統時, 關閉建立的WebSocket鏈接
    window.onbeforeunload = function () {
        websocket.close();
    }
    
    
    // 往后台服務器發送消息.
    function sendMessage() {
        
        var sendmsg = document.getElementById("sendMsg").value;
        console.log("發送的消息：" + sendmsg);
        
        // 發送至后台服務器中.
        websocket.send(sendmsg);
    }
    
</script>
</head>
<body>
    
    <button onclick="buildConnection();">開始建立鏈接</button>
    <hr>
    <input id="sendMsg" /> <button onclick="sendMessage();">消息發送</button>
    <div id="serverMsg"></div>

</body>
</html>

 

 

訪問瀏覽器，輸入地址：http://localhost:8080/websocket

建立連接，發送消息，然后在退出，在發送消息，在退出

 

 

在次訪問系統..並退出...

 

系統正常運行，異常信息（... Caused by: java.net.SocketException: Software caused connection abort: socket write error.. ）解決.

 

 

如有問題，歡迎糾正！！！

如有轉載，請標明源處：https://www.cnblogs.com/Charles-Yuan/p/9785147.html