我正在尝试使用java-websocketapi实现两个html页面之间的简单视频传输。网络摄像头服务器捕获网络摄像头并发送到服务器端点,该端点向每个连接的客户端广播。网络摄像头服务器代码
<video autoplay id="vid" style="display: none;"></video>
<canvas id="canvas" width="640" height="480" style="border: 1px solid #d3d3d3;"></canvas>
<div id="data1"></div>
<script>
var video = document.querySelector("#vid");
var canvas = document.querySelector('#canvas');
var ctx = canvas.getContext('2d');
var localMediaStream = null;
var ws = new WebSocket("ws://127.0.0.1:8080/WebApplication5/endpointwcv");
ws.onopen = function () {
console.log("Openened connection to websocket");
};
ws.onerror = function (evt) {
writeToScreen('<span style="color: red;">ERROR:</span> ' + evt.data);
};
var onCameraFail = function (e) {
console.log('Camera did not work.', e);
};
timer = setInterval(function () {
ctx.drawImage(video, 0, 0, 640, 480);
var data = canvas.toDataURL('image/jpeg', 1.0);
ws.send(data);
}, 255);
navigator.getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia || navigator.msGetUserMedia;
window.URL = window.URL || window.webkitURL;
navigator.getUserMedia({ video: true }, function (stream) {
video.src = window.URL.createObjectURL(stream);
}, onCameraFail);
服务器终结点的代码/*在此处导入*/
@ServerEndpoint("/endpointwcv")
public class NewWSEndpoint {
private static Set<Session> peers = Collections.synchronizedSet(new HashSet<Session>());
@OnMessage
public String onMessage( Session session,byte[] data) {
try {
System.out.println(data);
for(Session s:peers){
s.getBasicRemote().sendObject(data);
}
} catch (IOException | EncodeException e) {
System.out.println("Error in facedetection, ignoring message:" + e.getMessage());
}
return null;
}
public String onMessage( Session session,String data) {
try {
System.out.println(data);
for(Session s:peers){
s.getBasicRemote().sendText(data);
}
} catch (IOException e) {
System.out.println("Error in facedetection, ignoring message:" + e.getMessage());
}
return null;
}
@OnOpen
public void onOpen(Session session) throws IOException {
peers.add(session);
session.getBasicRemote().sendText("hiiiiiii");
}
@OnClose
public void onClose() {
System.out.println("Closed");
}
@OnError
public void onError(Session s, Throwable t) {
System.out.println("error");
}
}
还有一个接收客户端访问网络摄像头
<div id="d1"></div>
<canvas id="target" width="640" height="480" style="border: 1px solid #d3d3d3;"></canvas>
<script>
var ws = new WebSocket("ws://127.0.0.1:8080/WebApplication5/endpointwcv");
var myURL = window.URL || window.webkitURL;
ws.onopen = function () {
console.log("Openened connection to websocket");
};
ws.onmessage=function (msg) {
var target = document.getElementById("target");
url=myURL.createObjectURL(msg);
target.src = url;
};
</script>
在使用javaee7api在GlassFish 4.0上运行项目时,没有发生任何事情。请帮帮我。控制台上有一个警告
WARNING: Class 'javax.ejb.PostActivate' not found, interception based on it is not enabled
WARNING: Class 'javax.ejb.PrePassivate' not found, interception based on it is not enabled
Exception starting filter WebSocket filter
java.lang.InstantiationException
at org.apache.catalina.core.ApplicationFilterConfig.(ApplicationFilterConfig.java:135)
at org.apache.catalina.core.StandardContext.filterStart(StandardContext.java:5297)
...
这是下载项目的链接
我在这里看到您的项目有几个问题。首先,Struts和WebSocket之间有一个URL映射重叠。您的WebSocket URL是/endpointwcv
。Struts映射是/*
。当我最终部署您的应用程序时,我从Struts中收到了关于如何没有操作/endpointwcv
的映射的错误。
如果您更改Struts过滤器servlet到/struts/*
的映射(并且我不得不将filter-class
更改为org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter
以避免关于FilterDispatcher
如何被弃用的错误消息),那么您可以通过转到http://localhost:8080/WebApplication5/Conference.html
来访问WebSocket端点。在GlassFish4 server.log中,我看到了NewWSEndpoint
:的输出
INFO: aaaa
INFO: error
INFO: error
INFO: error
...
INFO: Closed
转到http://localhost:8080/WebApplication5/ConferenceClient.html
,我在server.log中看到:
INFO: aaaa
我不是Struts专家,但看起来你需要修复你的端点,然后想办法实现Struts前端,这样它就不会干扰你的WebSocket端点URL。