?
???????
???????
???????
???
???
???????
???????????
???????????
???????????
???????????
???????
???????
???????
???????????
???????????
???????????
???????
???????
???????????
???????????
???????? ???
???????
???????
???????
???????????
???????????
???????????
???????????
???????
???????
???????
???????????
????????? ??
???????????
???????
???????
???????????
???????????
???????????
???????????????
???????????????????
???????????????????
???????????????
???????????
???????
???????
???????
???????????
???????????
???????
?? ???
???????
???????????
???????????
???????
???????
???????????
???????????
???????
???
???
???????
???????
???????????
???????????????
???????????????
???????????
???????
???
我們提供的服務(wù)有：成都網(wǎng)站制作、網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、微信公眾號(hào)開(kāi)發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、滕州ssl等。為上1000+企事業(yè)單位解決了網(wǎng)站和推廣的問(wèn)題。提供周到的售前咨詢(xún)和貼心的售后服務(wù)，是有科學(xué)管理、有技術(shù)的滕州網(wǎng)站制作公司
用于啟動(dòng) websocket,注入處理器和攔截器
/**
?* Created by jackiechan on 2018/2/5/下午4:05
?*/
@Configuration //聲明為配置文件
@EnableWebSocket//啟用 websocket
public class WebSocketConfig implements WebSocketConfigurer {
??? @Override
??? public void registerWebSocketHandlers(WebSocketHandlerRegistry webSocketHandlerRegistry) {
??????? System.out.println("初始化路徑攔截");//指定所有/websocket開(kāi)頭的路徑會(huì)被 websocket 攔截,設(shè)置處理器和攔截器
??????? webSocketHandlerRegistry.addHandler(chatMessageHandler(),"/websocket/*").addInterceptors(new ChatHandshakeInterceptor());
??? }
??? /**
???? * 創(chuàng)建處理器
???? * @return
???? */
??? @Bean
??? public TextWebSocketHandler chatMessageHandler(){
??????? System.out.println("創(chuàng)建 handler");
??????? return new ChatMessageHandler();
??? }
}
用于每次 websocket 在握手之前進(jìn)行攔截,可以在內(nèi)部進(jìn)行校驗(yàn)
/**
?* Created by jackiechan on 2018/2/5/下午4:16
?*
?* WebSocket握手請(qǐng)求的攔截器. 檢查握手請(qǐng)求和響應(yīng), 對(duì)WebSocketHandler傳遞屬性
?*/
public class ChatHandshakeInterceptor extends HttpSessionHandshakeInterceptor {
??? /**
???? * 在握手之前執(zhí)行該方法, 繼續(xù)握手返回true, 中斷握手返回false. 通過(guò)attributes參數(shù)設(shè)置WebSocketSession的屬性
???? * @param request
???? * @param response
???? * @param wsHandler
???? * @param attributes
???? * @return
???? * @throws Exception
???? */
??? @Override
??? public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,
?????????????????????????????????? Map<String, Object> attributes) throws Exception {
??????? //為了方便區(qū)分來(lái)源,在此以用戶(hù)的名字來(lái)區(qū)分,名字我們通過(guò)要求用輸入進(jìn)行傳遞,所以在這里先從請(qǐng)求中獲取到用戶(hù)輸入的名字,因?yàn)槭鞘褂玫膔est 風(fēng)格,所以規(guī)定路徑的最后一個(gè)字符串是名字
??????? System.out.println("握手之前");
??????? String s = request.getURI().toString();
??????? String s1 = s.substring(s.lastIndexOf("/") + 1);
??????? attributes.put(Constants.WEBSOCKET_USERNAME, s1);//給當(dāng)前連接設(shè)置屬性
??????? return super.beforeHandshake(request, response, wsHandler, attributes);
??? }
??? /**
???? * 在握手之后執(zhí)行該方法. 無(wú)論是否握手成功都指明了響應(yīng)狀態(tài)碼和相應(yīng)頭.
???? * @param request
???? * @param response
???? * @param wsHandler
???? * @param ex
???? */
??? @Override
??? public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,
?????????????????????????????? Exception ex) {
??????? System.out.println("After Handshake");
??????? super.afterHandshake(request, response, wsHandler, ex);
??? }
}
用于收到消息的時(shí)候處理消息
/**
?* Created by jackiechan on 2018/2/5/下午4:11
?* 文本消息的處理器
?*/
public class ChatMessageHandler extends TextWebSocketHandler {
??? private static final Map<String,WebSocketSession> allClients;//用于緩存所有的用戶(hù)和連接之間的關(guān)系
??? private static Logger logger = Logger.getLogger(ChatMessageHandler.class);
??? static {
??????? allClients = new ConcurrentHashMap();//初始化連接
??? }
??? /**
???? * 當(dāng)和用戶(hù)成功建立連接的時(shí)候會(huì)調(diào)用此方法,在此方法內(nèi)部應(yīng)該保存連接
???? */
??? @Override
??? public void afterConnectionEstablished(WebSocketSession session) throws Exception {
??????? System.out.println("建立連接成功");
??????? String name = (String) session.getAttributes().get(Constants.WEBSOCKET_USERNAME);//將在攔截器中保存的用戶(hù)的名字取出來(lái),然后作為 key 存到 map 中
??????? if (name != null) {
??????????? allClients.put(name, session);//保存當(dāng)前的連接和用戶(hù)之間的關(guān)系
??????? }
??????? // 這塊會(huì)實(shí)現(xiàn)自己業(yè)務(wù)，比如，當(dāng)用戶(hù)登錄后，會(huì)把離線(xiàn)消息推送給用戶(hù)
??? }
??? /**
???? * 收到消息的時(shí)候會(huì)觸發(fā)該方法
???? * @param session 發(fā)送消息的用戶(hù)的 session
???? * @param message ?發(fā)送的內(nèi)容
???? * @throws Exception
???? */
??? @Override
??? protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
??????? //此處請(qǐng)根據(jù)自己的具體業(yè)務(wù)邏輯做處理
??????? JSONObject jsonObject= JSONObject.fromObject(new String(message.asBytes()));//將用戶(hù)發(fā)送的消息轉(zhuǎn)換為 json,實(shí)際開(kāi)發(fā)中請(qǐng)根據(jù)自己的需求處理
??????? String toName = jsonObject.getString("toName");//獲取數(shù)據(jù)中的收消息人的名字
??????? String content = jsonObject.getString("content");//獲取到發(fā)送的內(nèi)容
??????? String fromName = (String) session.getAttributes().get(Constants.WEBSOCKET_USERNAME);//獲取當(dāng)前發(fā)送消息的人的名字
??????? content = "收到來(lái)自:" +fromName+ "的消息,內(nèi)容是:" + content;
??????? //拼接內(nèi)容轉(zhuǎn)發(fā)給接收者,實(shí)際開(kāi)發(fā)中請(qǐng)參考自己的需求做處理
??????? TextMessage textMessage = new TextMessage(content);//將內(nèi)容轉(zhuǎn)換為 TextMessage
??????? sendMessageToUser(toName,textMessage);// 發(fā)送給指定的用戶(hù)
??????? //sendMessageToUsers(message);//給所有人發(fā)送
??????? //super.handleTextMessage(session, message);
??? }
??? /**
???? * 給某個(gè)用戶(hù)發(fā)送消息
???? *
???? * @param userName
???? * @param message
???? */
??? public void sendMessageToUser(String userName, TextMessage message) {
??????? WebSocketSession webSocketSession = allClients.get(userName);//根據(jù)接收方的名字找到對(duì)應(yīng)的連接
??????? if (webSocketSession != null&& webSocketSession.isOpen()) {//如果沒(méi)有離線(xiàn),如果離線(xiàn),請(qǐng)根據(jù)實(shí)際業(yè)務(wù)需求來(lái)處理,可能會(huì)需要保存離線(xiàn)消息
?? ?????????try {
??????????????? webSocketSession.sendMessage(message);//發(fā)送消息
??????????? } catch (IOException e) {
??????????????? e.printStackTrace();
??????????? }
??????? }
??? }
??? /**
???? * 給所有在線(xiàn)用戶(hù)發(fā)送消息,此處以文本消息為例子
???? *
???? * @param message
???? */
??? public void sendMessageToUsers(TextMessage message) {
??????? for (Map.Entry<String, WebSocketSession> webSocketSessionEntry : allClients.entrySet()) {//獲取所有的連接
??????????? WebSocketSession session = webSocketSessionEntry.getValue();//找到每個(gè)連接
??????????? if (session != null&& session.isOpen()) {
??????????????? try {
??????????????????? session.sendMessage(message);
??????????????? } catch (IOException e) {
??????????????????? e.printStackTrace();
??????????????? }
??????????? }
??????? }
??? }
??? /**
???? * 出現(xiàn)異常的時(shí)候
???? * @param session
???? * @param exception
???? * @throws Exception
???? */
??? @Override
??? public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
??????? String name = (String) session.getAttributes().get(Constants.WEBSOCKET_USERNAME);
??????? if (session.isOpen()) {
??????????? session.close();
??????? }
??????? logger.debug("連接關(guān)閉");
??????? allClients.remove(name);//移除連接
??? }
??? /**
???? * 連接關(guān)閉后
???? * @param session
???? * @param closeStatus
???? * @throws Exception
???? */
??? @Override
??? public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
??????? logger.debug("連接關(guān)閉");
??????? String name = (String) session.getAttributes().get(Constants.WEBSOCKET_USERNAME);//找到用戶(hù)對(duì)應(yīng)的連接
??????? allClients.remove(name);//移除
??? }
??? @Override
??? public boolean supportsPartialMessages() {
??????? return false;
??? }
}
注意此類(lèi)最好放在根包下
/**
?* Created by jackiechan on 2018/2/5/下午4:34
?*/
@SpringBootApplication
@Configuration
public class App {
??? public static void main(String[] args) {
??????? SpringApplication.run(App.class, args);//?? spingboot??? }
??? }
}
/**
?* Created by jackiechan on 2018/2/5/下午4:34
?用于將項(xiàng)目打包成 war 包后發(fā)布
?*/
public class SpringBootStartApplication extends SpringBootServletInitializer {
??? @Override
??? protected SpringApplicationBuilder configure(SpringApplicationBuilder builder)
??? {
??????? return builder.sources(App.class);
??? }
}
與非 springboot 的方式內(nèi)容一致
html>
???
???
???
??????? var websocket = null;
??????? function abc() {
??????????? //var username = localStorage.getItem("name");
??????????? var username=document.getElementById("me").value;
??????????? //判斷當(dāng)前瀏覽器是否支持WebSocket
??????????? if ('WebSocket' in window) {
??????????????? websocket = new WebSocket("ws://" + document.location.host + "/websocket/"+username);
??????????? } else {
??????????????? alert('當(dāng)前瀏覽器 Not support websocket')
??????????? }
??????????? //連接發(fā)生錯(cuò)誤的回調(diào)方法
??????????? websocket.onerror = function() {
??????????????? setMessageInnerHTML("WebSocket連接發(fā)生錯(cuò)誤");
??????????? };
??????????? //連接成功建立的回調(diào)方法
??????????? websocket.onopen = function() {
??????????????? setMessageInnerHTML("WebSocket連接成功");
??????????? }
??????????? //接收到消息的回調(diào)方法
??????????? websocket.onmessage = function(event) {
??????????????? setMessageInnerHTML(event.data);
??????????? }
??????????? //連接關(guān)閉的回調(diào)方法
??????????? websocket.onclose = function() {
??????????????? setMessageInnerHTML("WebSocket連接關(guān)閉");
??????????? }
??????????? //監(jiān)聽(tīng)窗口關(guān)閉事件，當(dāng)窗口關(guān)閉時(shí)，主動(dòng)去關(guān)閉websocket連接，防止連接還沒(méi)斷開(kāi)就關(guān)閉窗口，server端會(huì)拋異常。
??????????? window.onbeforeunload = function() {
??????????????? closeWebSocket();
??????????? }
??????? }
??????? /**
???????? * 發(fā)送消息
???????? */
??????? function sendmessage() {
??????????? var toName=document.getElementById("to").value;
??????????? if (websocket!=null) {
??????????????? var content=document.getElementById("content").value;
??????????????? var message='{"toName":"'+toName+'","content":"'+content+'"}';//將發(fā)送的內(nèi)容拼接為 json 字符串,服務(wù)端用于解析好處理
??????????????? websocket.send(message);
??????????? }
??????? }
??????? //關(guān)閉WebSocket連接
??????? function closeWebSocket() {
??????????? if (websocket!=null) {
??????????????? websocket.close();
??????????? }
??????? }
?? ?????function setMessageInnerHTML(data) {
??????????? document.getElementById("neirong").innerHTML = data;
??????? }
???
用戶(hù)名:
接收者:
內(nèi)容:
重慶分公司
重慶分公司