tomcat - Apache Tomcat websockets 服务器端消息

Question

我已经成功地为 tomcat websockets 实现了一个简单的回显服务器示例。现在我需要从我的服务器向客户端发送连续的消息。我如何实现这一点？？

当前服务器端代码

package org.playjava.websocket;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import javax.servlet.http.HttpServletRequest;
import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.StreamInbound;
import org.apache.catalina.websocket.WebSocketServlet;
import org.apache.catalina.websocket.WsOutbound;

public class SimpleEchoServlet extends WebSocketServlet {

    @Override
    protected StreamInbound createWebSocketInbound(String string, HttpServletRequest hsr) {
        return new SimpleEchoInbound();
    }

    private static final class SimpleEchoInbound extends MessageInbound {

        public SimpleEchoInbound() {
            super();
        }




        @Override
        protected void onBinaryMessage(ByteBuffer message) throws IOException {
            getWsOutbound().writeBinaryMessage(message);
        }

        @Override
        protected void onTextMessage(CharBuffer message) throws IOException {
            getWsOutbound().writeTextMessage(message);
            getWsOutbound().writeTextMessage(message);
            getWsOutbound().writeTextMessage(message);
        }



    }
}

Answer 1

在 SimpleEchoInbound 的构造函数中启动一个线程，并在该线程中调用 getWsOutbound().writeTextMessage()。

顺便说一句，您正在使用 Tomcat 专有的 WebSocket API，该 API 在 Tomcat 7 中已弃用，并已在 Tomcat 8 中完全删除。您应该切换到 JSR-356 Java WebSocket API，它在 Tomcat 7 和 Tomcat 8。