/**
* 连接建立成功调用的方法
*/
@OnOpen
public void onOpen(Session session,@PathParam("userName") String userName){
//=session;
(userName,session);
(session,userName);
//上线通知由客户端自主发起
onlineCount++; //在线数加1
("用户"+userName+"进入wsll！当前在线人数为" + onlineCount);
}
/**
* 连接关闭调用的方法
*/
@OnClose
public void onClose(Session session){
String userName=(session);
if(userName!=null&&userName!=""){
//下线通知
JSONObject jsonObject=new JSONObject();
("type", 3);
("userName", userName);
("contentType", "offline");
("to", "all");
String jsonString=();
for(Session s:()){//循环发给所有在线的人
().sendText(jsonString);
}
onlineCount--; //在线数减1
("用户"+userName+"退出wsll！当前在线人数为" + onlineCount);
(userName);
(session);
}
}
/**
* 收到客户端消息后调用的方法
*/
static Map offLineDB = new HashMap();
@OnMessage
public void onMessage(String message,Session session) {
//("来自客户端的消息:" + message);
JSONObject jsonObject=(message);
int type = ("type");
String to=("to");
("to");
//if(type==0||to==null||to==""){return ;}
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式
String time=(new Date());// new Date()为获取当前系统时间
("time", time);
Session socketoffline_to=(to);
if(socketoffline_to==null||"".equals(socketoffline_to))
{
//离线消息，A给B发的消息格式
//以下内容来自message这个代码
//{"type":1,"userName":"贤心_100001","contentType":"online","to":"纸飞机_100000","from":{"username":"贤心","avatar":"/upload/2016_6/1465575923433_33812.jpg","id":"100001","mine":true,"content":"4444444444444444"}}
//离线表：ID 内容 就是上面那个message 接收人就是 to 状态未读
//当B进入页面在线的时候，通过ajax获取自己的维度消息表，这时候吧状态改成已读
//ajax未读消息返回 格式如上寸的那个{"type":1,"userName":"....
/* ("username":鲁涛，内容：123，to：小黄，state：1)
("username":鲁涛，内容：456，to：小黄)
("username":鲁涛，内容：444，to：小黄)
("username":123，内容：456，to：ZZ黄)
*/
List offcontentList =null;
String userName = ("userName");
String from = ("from");
JSONObject fromObject=(from);
String content=("content");
offcontentList=(List) (userName);
if(offcontentList==null)
{
offcontentList=new ArrayList<String>();
}
(content);
(userName, offcontentList);
return;
}
switch (type) {
case 1://单聊
Session session_to=(to);
if(session_to!=null){
session_to.getAsyncRemote().sendText(());
//("发给"+to+"："+());
}
break;
case 2://群聊
String[] members=(",");
//发送到在线用户
for(String member:members){
session=(member);
if(session!=null){
().sendText(());
//("发给群里所有在线的人"+member+"："+());
}
}
break;
case 3:
//所有人
for(Session s:()){//循环发给所有在线的人
().sendText(());
//("发给系统所有在线的人"+()+"："+());
}
break;
default:
break;
}
}
/**
* 发生错误时调用
* @param session
* @param error
*/
@OnError
public void onError(Throwable error){
("llws发生错误");
();
}