tomcat websocket:无法连接到tomcat服务器

我试图在tomcat 7.0.29上使用websocket来实现pub/sub系统，但不知何故，我不知道为什么，每次打开浏览器时，它总是提醒"关闭"。。env是tomcat-7.0.29，Eclipse Juno，用scala编写。。如果有人能帮忙，我将不胜感激。。。

我的servlet如下：

[PubServlet]：

  class PubServlet extends WebSocketServlet {
 override def createWebSocketInbound (subProtocol: String, request: HttpServletRequest): StreamInbound = {
        println("create#############################################")
        new WebSocketHandler()
    }
}

[InittServlet]：

public class InitServlet extends HttpServlet {
    private static final long serialVersionUID = -3163557381361759907L;
    private static List<MessageInbound> socketList;  
    public void init(ServletConfig config) throws ServletException {  
        InitServlet.socketList = new ArrayList<MessageInbound>();  
        super.init(config);  
        System.out.println("Server start============");  
    }  
    public static synchronized List<MessageInbound> getSocketList() {  
        return InitServlet.socketList;  
    }  
}

[WebsocketHandler]：

class WebSocketHandler extends MessageInbound{
    protected override def onBinaryMessage(arg0: ByteBuffer)  {  
        // TODO Auto-generated method stub  
    }   
    protected override def onTextMessage(msg: CharBuffer)  {
    }
    protected override def onClose(status: Int) {
        println(status)
        super.onClose(status)
    }
    protected override def onOpen(outbound: WsOutbound) {
        super.onOpen(outbound)
        InitServlet.getSocketList().add(this)
    }
}

我的客户代码在这里：

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Index</title>
<script type="text/javascript">
var ws = null;
function startWebSocket() {
    if ('WebSocket' in window){
        ws = new WebSocket("ws://localhost:8080/PubSub_Web/index.do");
        alert(ws);
    }
    else if ('MozWebSocket' in window)
        ws = new MozWebSocket("ws://localhost:8080/PubSub_Web/index.do");
    else
        alert("not support");

    ws.onmessage = function(evt) {
        alert(evt.data);
    };
    ws.onclose = function(evt) {
        alert("close");
    };
    ws.onopen = function(evt) {
        alert("open");
    };
}
function sendMsg() {
    ws.send(document.getElementById('writeMsg').value);
}
</script>
</head>
<body onload="startWebSocket();">
<input type="text" id="writeMsg"></input>
<input type="button" value="send" onclick="sendMsg()"></input>
</body>
</html>

看看这个答案。您最好使用标准jaxax-websocket api，该api在Tomcat 7.0.47

中可用

您需要覆盖getReadTimeout方法，该方法用于设置以毫秒为单位的套接字超时。例如，如果您想将套接字超时设置为2分钟（2*60*1000），则可以使用以下代码。

@Override
public int getReadTimeout() {
    return 2*60*1000;
}

注意：您可以通过返回-1来设置无穷大（始终打开）。

相关内容

最新更新

热门标签：