关于websocket的实现

liuyong · 发表于 2016-4-13 15:40:13

Model.prototype.socket = function(event){
var me = this;
var inputElement = document.getElementById(me.getIDByXID("chatInput")).value;
var url = "ws://"+ window.location.host+"/baas/websockets";
var ws = new WebSocket(url);
ws.onopen = function(){
$("#"+me.getIDByXID('showDiv')+"").append("online...");
};
ws.onmessage = function(evt){
$("#"+me.getIDByXID('showDiv')+"").innerHTML = evt.data;
};
ws.onclose = function(evt) {
console.log("WebSocketClosed");
};
ws.onerror = function(evt) {
console.log("WebScoketError");
};
$("#"+me.getIDByXID("sendBtn")+"").click(function() {
ws.send(inputElement);
});
};
Model.prototype.sendBtnClick = function(event){
var me = this;
if($.trim(me.comp("chatInput").val()) !== ""){
me.socket(event);
}

复制代码

这是我写的js部分。图片是执行后的header；

import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@ServerEndpoint("/websockets")
public class WebSocketService {
private static int onlineCount = 0;
private static CopyOnWriteArraySet<WebSocketService> webSocketSet = new CopyOnWriteArraySet<WebSocketService>();
private Session session;
@OnOpen
public void onOpen(Session session){
this.session = session;
webSocketSet.add(this);
addOnlineCount();
System.out.println("有人上线了");
}
@OnClose
public void onClose(){
webSocketSet.remove(this);
subOnlineCount();
System.out.println("有人退出了");
}
@OnMessage
public void onMessage(String message, Session session){
System.out.println("来自客户端的消息:" + message);
//群发消息
for(WebSocketService item: webSocketSet){
try {
item.sendMessage(message);
} catch (IOException e) {
e.printStackTrace();
continue;
}
}
}
private void sendMessage(String message) throws IOException {
this.session.getBasicRemote().sendText(message);
//this.session.getAsyncRemote().sendText(message);
}
@OnError
public void onError(Session session,Throwable error) {
System.out.println("发生错误");
error.printStackTrace();
}
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {
WebSocketService.onlineCount++;
}
public static synchronized void subOnlineCount() {
WebSocketService.onlineCount--;
}

复制代码

这个是java代码。
下面是错误提示消息。
WebSocket connection to 'ws://localhost:8080/baas/websockets' failed: Error during WebSocket handshake: Unexpected response code: 500

真心不会搞这玩意了。哪位大神来帮帮忙啊？能远程最好了，非常感谢。

hecr · 发表于 2016-4-13 17:10:22

建议先上网找找标准的html中，如何在js中使用websocket

liuyong · 发表于 2016-4-14 15:01:11

hecr 发表于 2016-4-13 17:10
建议先上网找找标准的html中，如何在js中使用websocket

我照着他们的服务写了一遍，但不知道这个服务是该怎么去使用的，请问您知道吗？

liangyongfei · 发表于 2016-4-14 16:13:40

liuyong 发表于 2016-4-14 15:01
我照着他们的服务写了一遍，但不知道这个服务是该怎么去使用的，请问您知道吗？ ...

你是看的那个文档？？
你先在浏览器的地址栏输入：
ws://localhost:8080/baas/websockets
保证这个服务是可以正常访问的才可以！！
这个应该是个sevlet ,具体tomcat 如果使用websockets 服务，你还是上网查下吧！

		自动登录	找回密码
密码			注册

[处理中2] 关于websocket的实现