Tomcat客户端的websocket一直处于关闭状态

Question

对于tomcat 7.0.53中的websocket，我有以下clientendpoint类。它是基于一个网站上的这个例子https://blog.openshift.com/how-to-build-java-websocket-applications-using-the-jsr-356-api/

import java.io.IOException;
import java.net.URI;
import java.util.ArrayList;
import javax.websocket.ClientEndpoint;
import javax.websocket.CloseReason;
import javax.websocket.ContainerProvider;
import javax.websocket.DeploymentException;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
@ClientEndpoint
public class connect {
    private static ArrayList<Session> sessionList = new ArrayList<Session>();
    public connect(URI endpointURI) throws DeploymentException, IOException
    {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        container.connectToServer(this, endpointURI);
    }
    @OnOpen
    public void onOpen(Session session) throws IOException
    {
        sessionList.add(session);
        System.out.println(session.getId());
        session.getBasicRemote().sendText("hello");
    }
    public void sendMessage(String message) throws IOException
    {
        for(Session session : sessionList){
            //asynchronous communication
            session.getBasicRemote().sendText(message);
        }
    }
    @OnClose
    public void onClose(Session session){
        sessionList.remove(session);
        System.out.println("here");
    }
    @OnError
    public void onError(Throwable t, Session session){
        System.out.println("tedt");  
    }
}

然后我有以下代码来启动客户端端点

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import javax.websocket.DeploymentException;

public class test {
    public static void main(String[] args) throws DeploymentException, IOException, URISyntaxException {
        // TODO Auto-generated method stub
        connect connect = new connect(new URI("ws://localhost:8080/example/talk"));
        connect.sendMessage("now");
    }
}

客户端确实成功地连接到了websocket服务器，但是当我尝试发送消息或做任何事情时，它会立即断开连接，我知道这一点，因为当我尝试从onOpen函数发送消息时，会调用onError函数。为什么websocket在连接到服务器后立即关闭？

Answer 1

由于客户端应用程序中的主线程即将结束，您将被断开连接。在您发送"现在"之后，您的程序将简单地退出。如果你想做其他事情（比如等待服务器的响应），那么你必须阻止主线程退出。在main方法的末尾尝试这样的方法：

System.in.read();

这将导致您的流程坐着等待来自标准输入的输入。只需等待测试完成，然后按命令行上的ENTER键即可终止客户端。

当然，您需要注册一个处理程序来接收从服务器返回到客户端的消息。现在，您只能将消息从客户端发送到服务器。