package com.example.demo;
import java.io.IOException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ConcurrentHashMap;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import org.springframework.stereotype.Component;
import net.sf.json.JSONObject;
@ServerEndpoint(value = "/websocket/{userno}")
@Component
public class MyWebSocket {
//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
private static int onlineCount = 0;
private static SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。
// private static CopyOnWriteArraySet<MyWebSocket> webSocketSet = new CopyOnWriteArraySet<MyWebSocket>();
//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识
private static ConcurrentHashMap<String, MyWebSocket> webSocketSet = new ConcurrentHashMap<String, MyWebSocket>();
//与某个客户端的连接会话，需要通过它来给客户端发送数据
private Session session;
//当前发消息的人员编号
private String userno = "";
/**
* 连接建立成功调用的方法*/
@OnOpen
public void onOpen(@PathParam(value = "userno") String param,Session session) {
System.out.println(param);
userno = param;//接收到发送消息的人员编号
this.session = session;
addOnlineCount();
webSocketSet.put(param, this);//加入map中
System.out.println("有新连接加入！当前在线人数为" getOnlineCount());
String nickname="{'nickname':'" param "','content':'上线'}";
JSONObject obj = JSONObject.fromObject(nickname);
try {
sendMessage(obj "");
} catch (IOException e) {
System.out.println("IO异常");
}
}
/**
* 连接关闭调用的方法
*/
@OnClose
public void onClose() {
webSocketSet.remove(this); //从set中删除
subOnlineCount(); //在线数减1
System.out.println("有一连接关闭！当前在线人数为" getOnlineCount());
}
/**
* 收到客户端消息后调用的方法
*
* @param message 客户端发送过来的消息*/
@OnMessage
public void onMessage(String message, Session session) {
System.out.println("来自客户端的消息:" message);
System.out.println("来自客户端的消息:" message);
// session.get
sendToUser(message);
//群发消息
/* if (1 < 2) {
sendAll(message);
} else {
//给指定的人发消息
sendToUser(message);
}*/
}
/**
* 给指定的人发送消息
* @param message
*/
private void sendToUser(String message) {
// String sendUserno = message.split("[|]")[1];
// String sendMessage = message.split("[|]")[0];
JSONObject obj = JSONObject.fromObject(message);
obj.put("date", df.format(new Date()));
String now = getNowTime();
try {
Object object2 = obj.get("nickname2");
if (webSocketSet.get(obj.get("nickname")) != null) {
obj.put("isSelf", false);
Object object = obj.get("content");
webSocketSet.get(obj.get("nickname")).sendMessage(obj.toString());
}
if(webSocketSet.get(object2) != null){
obj.put("isSelf", true);
Object object = obj.get("content");
webSocketSet.get(obj.get("nickname2")).sendMessage(obj.toString());
}
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 给所有人发消息
* @param message
*/
private void sendAll(String message) {
String now = getNowTime();
String sendMessage = message.split("[|]")[0];
//遍历HashMap
for (String key : webSocketSet.keySet()) {
try {
//判断接收用户是否是当前发消息的用户
if (userno.equals(key)) {
webSocketSet.get(key).sendMessage(now "用户" userno "发来消息：" " <br/> " sendMessage);
System.out.println("key = " key);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* 获取当前时间
*
* @return
*/
private String getNowTime() {
Date date = new Date();
DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String time = format.format(date);
return time;
}
public 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 void sendMessage(String message) throws IOException {
this.session.getBasicRemote().sendText(message);
//this.session.getAsyncRemote().sendText(message);
}
/**
* 群发自定义消息
* */
public static void sendInfo(String message) throws IOException {
}
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {
MyWebSocket.onlineCount ;
}
public static synchronized void subOnlineCount() {
MyWebSocket.onlineCount--;
}
}资源文件列表
.gitignore , 268
.mvn/wrapper/maven-wrapper.jar , 47610
.mvn/wrapper/maven-wrapper.properties , 110
.project , 970
.settings/org.eclipse.core.resources.prefs , 155
.settings/org.eclipse.jdt.core.prefs , 430
.settings/org.eclipse.m2e.core.prefs , 90
.settings/org.eclipse.wst.common.project.facet.core.prefs.xml , 172
.settings/org.eclipse.wst.common.project.facet.core.xml , 170
mvnw , 6468
mvnw.cmd , 4994
pom.xml , 1948
readme.txt , 225
readme.txt.bak , 0
src/main/java/com/example/demo/ChatServer.java , 1746
src/main/java/com/example/demo/DemoApplication.java , 304
src/main/java/com/example/demo/HelloWorldController.java , 360
src/main/java/com/example/demo/MyWebSocket.java , 6242
src/main/java/com/example/demo/WebSocketConfig.java , 402
src/main/resources/application.properties , 0
src/main/resources/MyHtml.html , 1774
src/main/resources/static/assets/css/admin.css , 4972
src/main/resources/static/assets/css/amazeui.css , 329124
src/main/resources/static/assets/css/amazeui.flat.css , 329976
src/main/resources/static/assets/css/amazeui.flat.min.css , 247799
src/main/resources/static/assets/css/amazeui.min.css , 247008
src/main/resources/static/assets/css/app.css , 23
src/main/resources/static/assets/fonts/fontawesome-webfont.eot , 70807
src/main/resources/static/assets/fonts/fontawesome-webfont.svg , 365616
src/main/resources/static/assets/fonts/fontawesome-webfont.ttf , 142072
src/main/resources/static/assets/fonts/fontawesome-webfont.woff , 83588
src/main/resources/static/assets/fonts/fontawesome-webfont.woff2 , 66624
src/main/resources/static/assets/fonts/FontAwesome.otf , 109688
src/main/resources/static/assets/i/app-icon72x72@2x.png , 7215
src/main/resources/static/assets/i/examples/admin-chrome.png , 3594
src/main/resources/static/assets/i/examples/admin-firefox.png , 4030
src/main/resources/static/assets/i/examples/admin-ie.png , 3999
src/main/resources/static/assets/i/examples/admin-opera.png , 3749
src/main/resources/static/assets/i/examples/admin-safari.png , 4055
src/main/resources/static/assets/i/examples/adminPage.png , 2702
src/main/resources/static/assets/i/examples/blogPage.png , 2581
src/main/resources/static/assets/i/examples/landing.png , 4520
src/main/resources/static/assets/i/examples/landingPage.png , 2499
src/main/resources/static/assets/i/examples/loginPage.png , 2081
src/main/resources/static/assets/i/examples/sidebarPage.png , 2365
src/main/resources/static/assets/i/favicon.png , 1024
src/main/resources/static/assets/i/startup-640x1096.png , 9599
src/main/resources/static/assets/images/other.jpg , 7928
src/main/resources/static/assets/images/xia.jpg , 4089
src/main/resources/static/assets/js/amazeui.ie8polyfill.js , 90904
src/main/resources/static/assets/js/amazeui.ie8polyfill.min.js , 27600
src/main/resources/static/assets/js/amazeui.js , 458150
src/main/resources/static/assets/js/amazeui.min.js , 206942
src/main/resources/static/assets/js/amazeui.widgets.helper.js , 35058
src/main/resources/static/assets/js/amazeui.widgets.helper.min.js , 33653
src/main/resources/static/assets/js/app.js , 372
src/main/resources/static/assets/js/handlebars.min.js , 72614
src/main/resources/static/assets/js/jquery.min.js , 85589
src/main/resources/static/assets/umeditor/dialogs/emotion/emotion.css , 2407
src/main/resources/static/assets/umeditor/dialogs/emotion/emotion.js , 15367
src/main/resources/static/assets/umeditor/dialogs/emotion/images/0.gif , 43
src/main/resources/static/assets/umeditor/dialogs/emotion/images/bface.gif , 27167
src/main/resources/static/assets/umeditor/dialogs/emotion/images/cface.gif , 8603
src/main/resources/static/assets/umeditor/dialogs/emotion/images/fface.gif , 18479
src/main/resources/static/assets/umeditor/dialogs/emotion/images/jxface2.gif , 40706
src/main/resources/static/assets/umeditor/dialogs/emotion/images/neweditor-tab-bg.png , 216
src/main/resources/static/assets/umeditor/dialogs/emotion/images/tface.gif , 19805
src/main/resources/static/assets/umeditor/dialogs/emotion/images/wface.gif , 49850
src/main/resources/static/assets/umeditor/dialogs/emotion/images/yface.gif , 28409
src/main/resources/static/assets/umeditor/dialogs/formula/formula.css , 869
src/main/resources/static/assets/umeditor/dialogs/formula/formula.html , 7353
src/main/resources/static/assets/umeditor/dialogs/formula/formula.js , 5332
src/main/resources/static/assets/umeditor/dialogs/formula/images/formula.png , 19301
src/main/resources/static/assets/umeditor/dialogs/image/image.css , 2952
src/main/resources/static/assets/umeditor/dialogs/image/image.js , 15588
src/main/resources/static/assets/umeditor/dialogs/image/images/close.png , 1042
src/main/resources/static/assets/umeditor/dialogs/image/images/upload1.png , 848
src/main/resources/static/assets/umeditor/dialogs/image/images/upload2.png , 1910
src/main/resources/static/assets/umeditor/dialogs/link/link.js , 2895
src/main/resources/static/assets/umeditor/dialogs/map/map.html , 5900
src/main/resources/static/assets/umeditor/dialogs/map/map.js , 10829
src/main/resources/static/assets/umeditor/dialogs/video/images/center_focus.jpg , 11795
src/main/resources/static/assets/umeditor/dialogs/video/images/left_focus.jpg , 11423
src/main/resources/static/assets/umeditor/dialogs/video/images/none_focus.jpg , 11546
src/main/resources/static/assets/umeditor/dialogs/video/images/right_focus.jpg , 11334
src/main/resources/static/assets/umeditor/dialogs/video/video.css , 2679
src/main/resources/static/assets/umeditor/dialogs/video/video.js , 11276
src/main/resources/static/assets/umeditor/index.html , 10693
src/main/resources/static/assets/umeditor/lang/en/en.js , 6875
src/main/resources/static/assets/umeditor/lang/en/images/addimage.png , 3373
src/main/resources/static/assets/umeditor/lang/en/images/alldeletebtnhoverskin.png , 743
src/main/resources/static/assets/umeditor/lang/en/images/alldeletebtnupskin.png , 743
src/main/resources/static/assets/umeditor/lang/en/images/background.png , 3854
src/main/resources/static/assets/umeditor/lang/en/images/button.png , 4929
src/main/resources/static/assets/umeditor/lang/en/images/copy.png , 1222
src/main/resources/static/assets/umeditor/lang/en/images/deletedisable.png , 649
src/main/resources/static/assets/umeditor/lang/en/images/deleteenable.png , 664
src/main/resources/static/assets/umeditor/lang/en/images/imglabel.png , 672
src/main/resources/static/assets/umeditor/lang/en/images/listbackground.png , 3750
src/main/resources/static/assets/umeditor/lang/en/images/localimage.png , 3083
src/main/resources/static/assets/umeditor/lang/en/images/music.png , 91561
src/main/resources/static/assets/umeditor/lang/en/images/rotateleftdisable.png , 719
src/main/resources/static/assets/umeditor/lang/en/images/rotateleftenable.png , 952
src/main/resources/static/assets/umeditor/lang/en/images/rotaterightdisable.png , 754
src/main/resources/static/assets/umeditor/lang/en/images/rotaterightenable.png , 1007
src/main/resources/static/assets/umeditor/lang/en/images/upload.png , 3941
src/main/resources/static/assets/umeditor/lang/zh-cn/images/copy.png , 4319
src/main/resources/static/assets/umeditor/lang/zh-cn/images/imglabel.png , 2973
src/main/resources/static/assets/umeditor/lang/zh-cn/images/localimage.png , 6979
src/main/resources/static/assets/umeditor/lang/zh-cn/images/music.png , 23106
src/main/resources/static/assets/umeditor/lang/zh-cn/images/upload.png , 6608
src/main/resources/static/assets/umeditor/lang/zh-cn/zh-cn.js , 7022
src/main/resources/static/assets/umeditor/themes/default/css/umeditor.css , 18505
src/main/resources/static/assets/umeditor/themes/default/css/umeditor.min.css , 14200
src/main/resources/static/assets/umeditor/themes/default/images/caret.png , 293
src/main/resources/static/assets/umeditor/themes/default/images/close.png , 291
src/main/resources/static/assets/umeditor/themes/default/images/icons.gif , 20371
src/main/resources/static/assets/umeditor/themes/default/images/icons.png , 41374
src/main/resources/static/assets/umeditor/themes/default/images/ok.gif , 866
src/main/resources/static/assets/umeditor/themes/default/images/pop-bg.png , 1003
src/main/resources/static/assets/umeditor/themes/default/images/spacer.gif , 43
src/main/resources/static/assets/umeditor/themes/default/images/videologo.gif , 1604
src/main/resources/static/assets/umeditor/third-party/jquery.min.js , 93113
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/STIXFontLicense2010.txt , 5284
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneral-webfont.eot , 461508
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneral-webfont.svg , 1074120
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneral-webfont.ttf , 461308
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneral-webfont.woff , 257836
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbol-webfont.eot , 244808
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbol-webfont.svg , 547134
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbol-webfont.ttf , 244620
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbol-webfont.woff , 135208
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbolita-webfont.eot , 215370
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbolita-webfont.svg , 425793
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbolita-webfont.ttf , 215156
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralbolita-webfont.woff , 124076
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralitalic-webfont.eot , 208604
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralitalic-webfont.svg , 407762
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralitalic-webfont.ttf , 208408
src/main/resources/static/assets/umeditor/third-party/mathquill/font/stixgeneral-bundle/stixgeneralitalic-webfont.woff , 121324
src/main/resources/static/assets/umeditor/third-party/mathquill/font/Symbola.eot , 890190
src/main/resources/static/assets/umeditor/third-party/mathquill/font/Symbola.otf , 938392
src/main/resources/static/assets/umeditor/third-party/mathquill/font/Symbola.svg , 2229089
src/main/resources/static/assets/umeditor/third-party/mathquill/font/Symbola.ttf , 890008
src/main/resources/static/assets/umeditor/third-party/mathquill/font/Symbola.woff , 474392
src/main/resources/static/assets/umeditor/third-party/mathquill/mathquill.css , 9539
src/main/resources/static/assets/umeditor/third-party/mathquill/mathquill.js , 124300
src/main/resources/static/assets/umeditor/third-party/mathquill/mathquill.min.js , 50848
src/main/resources/static/assets/umeditor/umeditor.config.js , 10180
src/main/resources/static/assets/umeditor/umeditor.js , 399039
src/main/resources/static/assets/umeditor/umeditor.min.js , 139231
最多只能显示150条信息!