IBM WebSphere 应用程序服务器上的 Web 文档支持 9.0.5.6

Question

我正在使用 WebSocket 服务包将一个基于 JBOSS EAP 7.3 的企业级应用程序迁移到 IBM WebSphere 应用程序服务器 9.0.5.6 （WAS）。问题是，当我尝试连接到WebSocketendpoint时，它什么都不做。在 WebSphere 中，我相应地配置了所有虚拟主机和端口，我的 WebSocket endpoint类如下所示。

@ServerEndpoint("/WebSocketServices")
public class ClientConnectorWebSocketCore {

    private static final OMSLogHandlerI logger = new Log4j2HndlAdaptor("ClientConnectorWebSocketCore");
    private ClientConnectorFacadeWrapperRemote clientConnectorFacadeRemote;
    private EJBServiceLocatorI ejbServiceLocatorI;

    @OnOpen
    public void onConnectionOpen(Session session) {
        session.setMaxIdleTimeout(120000); //todo //milli seconds
        getEjbServiceLocatorI();
        logger.elkLog("29", LogEventsEnum.WSOCKET_SESSION_CONNECT, " Session Create:" + session.getId());
    }

    @OnMessage
    public String onMessage(String message) {
        return handleJSONRequest(message);
    }

    @OnClose
    public void onConnectionClose(Session session) {
        logger.elkLog("42", LogEventsEnum.WSOCKET_SESSION_CLOSE, " Session Close:" + session.getId());
    }

    @OnError
    public void onConnectionError(Session session, Throwable t) {
//        logger.info("LN:47", session.getId(), LogEventsEnum.WEB_SOCKET_ONERROR, "WebSocket OnException" + t.getMessage());
        logger.elkLog("48", LogEventsEnum.WEB_SOCKET_ONERROR, " Session error:" + session.getId() + ", Msg:" + t.getMessage());
    }

    public void msgBroadCast(Session session, String msg) {
        for (Session session1 : session.getOpenSessions()) {
            if (session1.isOpen()) {
                session1.getAsyncRemote().sendText(msg);
            }
        }
    }

    private EJBServiceLocatorI getEjbServiceLocatorI(){
        if (ejbServiceLocatorI == null){
            ejbServiceLocatorI =
                    (EJBServiceLocatorI) SpringBeanFactoryLoader.getInstance().getBeanLoader().getBean(EJBServiceLocatorI.class);
        }
        return ejbServiceLocatorI;
    }

    private ClientConnectorFacadeWrapperRemote getClientConnectFacade() {
        if (clientConnectorFacadeRemote == null) {
            try {
                ejbServiceLocatorI = getEjbServiceLocatorI();
                clientConnectorFacadeRemote =
                       (ClientConnectorFacadeWrapperRemote) ejbServiceLocatorI.contextLookupConnectorFacadeRemote(ClientConnectorFacadeWrapperRemote.class);
            } catch (Exception e) {
                logger.error("LN:66", "Error in Creating Client connector   " + e.getMessage(), e);
            }
        }
        return clientConnectorFacadeRemote;
    }

    private String handleJSONRequest(String jsonRequest) {
        ClientConnectorFacadeWrapperRemote clientConnector = getClientConnectFacade();
        String response = null;
        if (clientConnector != null) {
            response = clientConnector.processMessage(jsonRequest);
        }
        return response;
    }

    @OnMessage
    public void pongMessage(Session session, PongMessage msg) {
        msg.getApplicationData().toString();
    }


    public void setEjbServiceLocatorI(EJBServiceLocatorI ejbServiceLocatorI) {
        this.ejbServiceLocatorI = ejbServiceLocatorI;
    }
}

非常感谢您的任何建议。

Answer 1

如果您的请求流经带有WebSphere插件的Web服务器，您需要确保插件处于9.0.5.6或更高级别，因为可能会阻止websocket流量的错误（PH27966）。