我使用 Tyrus 部署了一个 Wildfly 8.1 java 应用程序来管理 websocket 服务器,没什么太复杂的,它只是接收消息并响应消息反转,嗯,它应该可以工作,一切都按照 OpenShift 教程进行,但是在部署时,我明白了rhc 尾部消息:
2015-01-02 21:16:19,314 ERROR [io.undertow.websockets.jsr] (MSC service thread 1
-2) UT026002: Unable to instantiate server configuration class org.glassfish.tyr
us.server.TyrusServerConfiguration: java.lang.InstantiationException: org.glassf
ish.tyrus.server.TyrusServerConfiguration
at java.lang.Class.newInstance(Class.java:418) [rt.jar:1.8.0_05]
at org.wildfly.extension.undertow.deployment.UndertowJSRWebSocketDeploym
entProcessor.doDeployment(UndertowJSRWebSocketDeploymentProcessor.java:213)
at org.wildfly.extension.undertow.deployment.UndertowJSRWebSocketDeploym
entProcessor.deploy(UndertowJSRWebSocketDeploymentProcessor.java:165)
at org.jboss.as.server.deployment.DeploymentUnitPhaseService.start(Deplo
ymentUnitPhaseService.java:159)
at org.jboss.msc.service.ServiceControllerImpl$StartTask.startService(Se
rviceControllerImpl.java:1948)
at org.jboss.msc.service.ServiceControllerImpl$StartTask.run(ServiceCont
rollerImpl.java:1881)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1142) [rt.jar:1.8.0_05]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:617) [rt.jar:1.8.0_05]
at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_05]
Caused by: java.lang.NoSuchMethodException: org.glassfish.tyrus.server.TyrusServ
erConfiguration.<init>()
at java.lang.Class.getConstructor0(Class.java:2971) [rt.jar:1.8.0_05]
at java.lang.Class.newInstance(Class.java:403) [rt.jar:1.8.0_05]
... 8 more
当我尝试连接到套接字时,我可以连接,但它可以作为它的先前版本工作(没有反转)。
这是Websocket服务器源:
@ServerEndpoint(value = "/socket")
public class WebSocket {
private Logger logger = Logger.getLogger(this.getClass().getName());
private Reconhecedor reconhecedor = new Reconhecedor();
@OnOpen
public void onOpen(Session session) {
logger.info("Connected Recognizer ... " + session.getId());
}
@OnMessage
public String onMessage(String message, Session session) {
logger.info("String message arrived");
return new StringBuilder(message).reverse().toString();
}
@OnMessage
public String onMessage(ByteBuffer message, Session session) {
logger.info("byte message arrived");
String result = "";
ByteArrayInputStream baiut = new ByteArrayInputStream(message.array());
AudioInputStream ais;
try {
ais = AudioSystem.getAudioInputStream(baiut);
result = reconhecedor.Recognize(ais);
logger.info("returning: " + result);
//session.close(new CloseReason(CloseCodes.NORMAL_CLOSURE, "Game ended"));
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
@OnClose
public void onClose(Session session, CloseReason closeReason) {
logger.info(String.format("Session %s closed because of %s", session.getId(), closeReason));
}
}
而且,我的服务器来源:
public class Programa {
public static void main(String[] args) {
runServer();
}
public static void runServer() {
String ip = System.getenv("OPENSHIFT_WILDFLY_IP");
int port = 8000;
Server server = new Server(ip, port, "", WebSocket.class);
try {
server.start();
System.out.print("Please press a key to stop the server.");
System.in.read();
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
server.stop();
}
}
}
我有点迷茫,不知道还能做什么,似乎 javascript websocket 非常简单并且运行良好,但我需要它 java,因为我将使用该套接字用于 Sphinx CMU。
任何帮助表示赞赏,在此先感谢!