Làm cách nào để thực hiện các ổ cắm web trong tài khoản nhúng?

Theo điều này: http://undertow.io/ nó hỗ trợ websockets. Tuy nhiên, không có tài liệu hướng dẫn về cách thực hiện. Tôi chỉ muốn một ví dụ đơn giản về cách xử lý web socket.Làm cách nào để thực hiện các ổ cắm web trong tài khoản nhúng?

Tôi không muốn lấy toàn bộ máy chủ ứng dụng jboss.

Nguồn

2013-08-06 mentics

Tôi đã đến với lớp học này. Tuy nhiên, tôi không phải là chuyên gia JBoss. Tôi đặc biệt không chắc chắn về những thứ xnio.

import io.undertow.Undertow; 
import io.undertow.servlet.api.DeploymentManager; 
import io.undertow.websockets.jsr.WebSocketDeploymentInfo; 
import org.jboss.logging.Logger; 
import org.xnio.OptionMap; 
import org.xnio.Xnio; 
import org.xnio.XnioWorker; 

import javax.servlet.ServletException; 
import javax.websocket.OnClose; 
import javax.websocket.OnMessage; 
import javax.websocket.OnOpen; 
import javax.websocket.server.ServerEndpoint; 
import java.io.IOException; 

import static io.undertow.servlet.Servlets.defaultContainer; 
import static io.undertow.servlet.Servlets.deployment; 
import static io.undertow.websockets.jsr.WebSocketDeploymentInfo.ATTRIBUTE_NAME; 

public class WebsocketServer { 

    private static final Logger LOGGER = Logger.getLogger(WebsocketServer.class); 

    @ServerEndpoint("/") 
    public static class SocketProxy { 

    @OnOpen 
    public void onOpen() { 
     LOGGER.info("onOpen"); 
    } 

    @OnClose 
    public void onClose() { 
     LOGGER.info("onClose"); 
    } 

    @OnMessage 
    public void onMessage(String message) { 
     LOGGER.info("onMessage:" + message); 
    } 

    } 

    public static void main(String[] args) throws ServletException, IOException { 
    final Xnio xnio = Xnio.getInstance("nio", Undertow.class.getClassLoader()); 
    final XnioWorker xnioWorker = xnio.createWorker(OptionMap.builder().getMap()); 
    final WebSocketDeploymentInfo webSockets = new WebSocketDeploymentInfo() 
     .addEndpoint(SocketProxy.class) 
     .setWorker(xnioWorker); 
    final DeploymentManager deployment = defaultContainer() 
     .addDeployment(deployment() 
      .setClassLoader(WebsocketServer.class.getClassLoader()) 
      .setContextPath("/") 
      .setDeploymentName("embedded-websockets") 
      .addServletContextAttribute(ATTRIBUTE_NAME, webSockets)); 

    deployment.deploy(); 
    Undertow.builder(). 
     addListener(8080, "localhost") 
     .setHandler(deployment.start()) 
     .build() 
     .start(); 
    } 

}

Nguồn

2013-09-17 10:58:29