2

我看到很多关于如何使用某种嵌入式 Web 服务器设置 JSR356 websockets 的教程。

但是我想将一些 websocket 添加到部署到独立码头安装的现有 WAR 中，jetty jetty-9.2.3.v20140905，我可以找到很少的信息。我无法弄清楚是什么阻止它工作。据我了解，带注释的服务器端点应该由码头自动处理。

服务器端点：

    @ServerEndpoint(value = "/myendpoint")
public class MyServerEndpoint {     
    private Logger logger = Logger.getLogger(this.getClass().getName());     

    @OnOpen 
    public void onOpen(Session s) {
        logger.info("Server Connected ... " + s.getId());
        s.getAsyncRemote().sendText("You are connected to the websocket server");   
    }        

    @OnMessage  
    public void onMessage(String message, Session session) {

        // Sent the message back to all connected users             
        logger.info("Server Session " + session + " Received string message " + message);

        for(Session s: session.getOpenSessions()) {     
            if (s.isOpen()) { 
                s.getAsyncRemote().sendText(message + " server response");
            }       
        }   
    }        

    @OnClose    
    public void onClose(Session session, CloseReason reason) {
        logger.info("Server Session " + session + " closed for reason " + reason);
    }   
}

客户端端点：

    @ClientEndpoint
public class MyClientEndpoint {     
    private Logger logger = Logger.getLogger(this.getClass().getName());     

    @OnOpen 
    public void onOpen(Session s) {
        logger.info("Client Connected ... " + s.getId());
        s.getAsyncRemote().sendText("hello from the client!");  
    }        

    @OnMessage  
    public void onMessage(String message, Session session) {

        logger.info("Client Session " + session + " Received string message " + message);       

    }        

    @OnClose    
    public void onClose(Session session, CloseReason reason) {
        logger.info("Client Session " + session + " closed for reason " + reason);
    }   
}

这是将客户端连接到服务器的代码（在一些现有方法中运行）

    WebSocketContainer container = ContainerProvider.getWebSocketContainer();
    String uri = "ws://localhost:8080/myWar/myendpoint"; 
    container.connectToServer(MyClientEndpoint.class, URI.create(uri));

然而，旋转码头会在 connectToServer 线上出现错误

2014-10-30 12:26:58.658:WARN:oeja.ServletContainerInitializersStarter:main: 
org.eclipse.jetty.websocket.api.InvalidWebSocketException: Unable to instantiate websocket: class java.lang.Class
at   org.eclipse.jetty.websocket.jsr356.ClientContainer.newClientEndpointInstance(ClientContainer.java:311)
    at org.eclipse.jetty.websocket.jsr356.ClientContainer.connectToServer(ClientContainer.java:172)

我能想到的只是 URI 不正确。如果码头在 8080 上运行并且我的 .war 被命名为 myWar，而我的终点被命名为 myendpoint...这不是正确的 URI 吗？

是否必须执行一些额外的步骤来“激活”服务器端点以侦听连接？我一定遗漏了一些明显的东西。

4

2 回答 2

2

奇怪的是，你的错误信息。

org.eclipse.jetty.websocket.api.InvalidWebSocketException: 
  Unable to instantiate websocket: class java.lang.Class

意味着 websocket 实现被传递了一个原始的 java.lang.Class 来实例化。那是行不通的。

这也意味着没有尝试连接，因为 WebSocket 类本身非常糟糕，以至于无法连接。

这是一个简短（有效且有效）的示例，展示了它的用法。

package jetty.jsr356;

import java.io.IOException;
import java.net.URI;
import java.util.concurrent.CountDownLatch;

import javax.websocket.ClientEndpoint;
import javax.websocket.CloseReason;
import javax.websocket.CloseReason.CloseCodes;
import javax.websocket.ContainerProvider;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;

@ClientEndpoint
public class TestClientAnnotatedClass
{
    private static CountDownLatch closeLatch = new CountDownLatch(1);

    @OnOpen
    public void onOpen(Session session)
    {
        System.out.println("@OnOpen - " + session);
        try
        {
            session.getBasicRemote().sendText("Rock it with Java WebSocket");
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
    }

    @OnMessage
    public void onMessage(Session session, String msg)
    {
        System.out.println("@OnMessage - ["+msg+"]");
        try
        {
            session.close(new CloseReason(CloseCodes.NORMAL_CLOSURE,"Thanks"));
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
    }

    @OnClose
    public void onClose(CloseReason close)
    {
        System.out.println("@OnClose - " + close);
        closeLatch.countDown();
    }

    public static void main(String[] args)
    {
        try
        {
            WebSocketContainer ws = ContainerProvider.getWebSocketContainer();

            ws.connectToServer(TestClientAnnotatedClass.class,new URI("ws://echo.websocket.org/?encoding=text"));
            closeLatch.await();
        }
        catch (Throwable t)
        {
            t.printStackTrace();
        }
    }
}

您将看到与此类似的输出

2014-10-30 11:34:19.197:INFO::main: Logging initialized @71ms
@OnOpen - WebSocketSession[websocket=JsrAnnotatedEventDriver[websocket=jetty.jsr356.TestClientAnnotatedClass@5cca5f2c],behavior=CLIENT,connection=WebSocketClientConnection@6a2e714b{IDLE}{f=Flusher[queueSize=0,aggregateSize=0,failure=null],g=Generator[CLIENT,validating],p=Parser@55465b1f[ExtensionStack,s=START,c=0,len=0,f=null,p=WebSocketPolicy@7e087bf5[behavior=CLIENT,maxTextMessageSize=65536,maxTextMessageBufferSize=32768,maxBinaryMessageSize=65536,maxBinaryMessageBufferSize=32768,asyncWriteTimeout=60000,idleTimeout=300000,inputBufferSize=4096]]},remote=WebSocketRemoteEndpoint@5f025277[batching=true],incoming=JsrAnnotatedEventDriver[websocket=jetty.jsr356.TestClientAnnotatedClass@5cca5f2c],outgoing=ExtensionStack[queueSize=0,extensions=[],incoming=org.eclipse.jetty.websocket.jsr356.JsrSession,outgoing=org.eclipse.jetty.websocket.client.io.WebSocketClientConnection]]
@OnMessage - [Rock it with Java WebSocket]
@OnClose - CloseReason[1000,Thanks]
于 2014-10-30T18:35:16.160 回答
0

Jetty 使用反射创建带注释的客户端端点的实例（请参阅/jetty/websocket/jsr356/ClientContainer#newClientEndpointInstance()），但 Java 无法以这种方式实例化非静态内部类。实际原因异常类似于java.lang.NoSuchMethodException: <pkg>.OuterClass$InnerClass.<init>()但被吞下。

解决方案：带注释的端点类不应嵌套或嵌套静态（内部）类。

于 2015-01-25T17:29:01.903 回答