JSR-356 websocket - 停止容器后无法获取 return 代码

Question

我已经使用 javax websockets 构建了一个客户端服务器应用程序。虽然 JSR 356 没有停止 websocket 容器的方法，但我在投射到 jetty Lifecyle。停止我写的容器后

system.exit(1);

但是 return 来自客户端程序的代码始终为零。

代码： @ClientEndpoint

    public boolean close()
        {
            try
              {
                  if(this.container != null && this.container instanceof LifeCycle) { 
                      logger.trace("stoping container...");
                      ((LifeCycle) this.container).stop();
                  }

                  this.session.close();
        
                return true;
            }
            catch (Exception e)
            {
                logger.trace("Exception occured while closing the connection",e);
                return false;
            }
        }

代码：从另一个调用关闭方法 class

public closeConnection(){

     this.wc.close();
     System.exit(1);

}

感谢任何帮助:-)

Answer 1

您是否试图从属于容器或容器的线程池/执行器的线程调用 closeConnection 或 close？

此外，一旦容器停止，所有会话也将停止。

将@ClientEndpointclose()改为...

public void close()
{
    try
    {
        this.session.close();
    }
    catch (Exception e)
    {
        logger.trace("Exception occured while closing the connection",e);
    }
}

并使closeConnection()简单...

public closeConnection()
{
    LifeCycle.stop(this.wc.getContainer());
    System.exit(1);
}

可以在
找到一个工作示例 https://github.com/joakime/javaxwebsocket-client-returncode

其中有代码...

App.java

package org.eclipse.jetty.demo;

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

import org.eclipse.jetty.util.component.LifeCycle;

public class App
{
    private static final App MAIN_INSTANCE = new App();

    private WebSocketContainer client;

    public static void main(String[] args) throws IOException, DeploymentException, URISyntaxException
    {
        App.MAIN_INSTANCE.connect();
    }

    public static void stop(int returnCode)
    {
        // Trigger stop from thread that does not belong to Container.
        new Thread(() ->
        {
            LifeCycle.stop(App.MAIN_INSTANCE.client);
            System.exit(returnCode);
        }).start();
    }

    private WebSocketContainer getClientContainer()
    {
        if (client == null)
            client = ContainerProvider.getWebSocketContainer();
        return client;
    }

    public void connect() throws IOException, DeploymentException, URISyntaxException
    {
        URI echoUri = URI.create("wss://echo.websocket.org");

        ClientEndpointConfig clientEndpointConfig = ClientEndpointConfig.Builder.create()
            .configurator(new OriginServerConfigurator(echoUri))
            .build();

        EchoEndpoint echoEndpoint = new EchoEndpoint();
        getClientContainer().connectToServer(echoEndpoint, clientEndpointConfig, echoUri);
        System.out.printf("Connected to : %s%n", echoUri);
    }
}

EchoEndpoint.java

package org.eclipse.jetty.demo;

import javax.websocket.CloseReason;
import javax.websocket.Endpoint;
import javax.websocket.EndpointConfig;
import javax.websocket.MessageHandler;
import javax.websocket.Session;

/**
 * Basic Echo Client Endpoint
 */
public class EchoEndpoint extends Endpoint implements MessageHandler.Whole<String>
{
    private Session session;

    @Override
    public void onClose(Session session, CloseReason closeReason)
    {
        System.out.printf("Connection closed: Session.id=%s - %s%n", session.getId(), closeReason);
        this.session = null;
    }

    @Override
    public void onOpen(Session session, EndpointConfig config)
    {
        System.out.printf("Got open: Session.id=%s%n", session.getId());
        this.session = session;
        this.session.addMessageHandler(this);
        try
        {
            session.getBasicRemote().sendText("Hello");
            session.getBasicRemote().sendText("How are things?");
            session.getBasicRemote().sendText("Thanks for the conversation.");
        }
        catch (Throwable t)
        {
            t.printStackTrace();
        }
    }

    @Override
    public void onMessage(String msg)
    {
        System.out.printf("Got msg: \"%s\"%n", msg);
        if (msg.contains("Thanks"))
        {
            App.stop(1);
        }
    }

    @Override
    public void onError(Session session, Throwable cause)
    {
        cause.printStackTrace();
    }
}

JSR-356 websocket - 停止容器后无法获取 return 代码

JSR-356 websocket - cannot get return code after stopping container

java

jetty

websocket

jsr356