av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

SpringBoot中webSocket實現即時聊天

瀏覽:90日期:2023-03-13 18:26:09
即時聊天

這個使用了websocket,在springboot下使用很簡單。前端是小程序,這個就比較坑,小程序即時聊天上線需要域名并且使用wss協議,就是ws+ssl更加安全。但是要上線這還不夠,你必須為企業主體開發者。個人開發者即時聊天屬于社交、不在服務類目內,審核會不通過!!!

功能 :我們的小程序是個二手交易小程序,即時聊天對于一個后臺服務器只是單核2g的來說有點抗不住。所以在雙方都在線的時候沒有存儲聊天消息,只是在單方不在線時存儲了離線消息。而且只能發三條離線消息。仿照了csdn的聊天。

使用:我們是點擊進入聊天之后才發起websocket,這就造成了一個問題,就是用戶退出到消息列表又重新點進入就會重新發送一個websocket請求。每次請求session都不一樣。而且微信限制一個用戶只能同時發起5個請求。一開始前端沒能退出聊天頁面就端開,就錯誤唉!!。只能后臺去斷使用sessioin.close()會調用onClose()方法 這個session是你要斷的session。不過后來前端可以自己斷了就nice了!

效果:

SpringBoot中webSocket實現即時聊天

SpringBoot中webSocket實現即時聊天

數據庫設計:

對于展示消息聊天列表使用了一張表。last_context為對方發送的最后一條消息。只要有一方點擊了私信進入聊天頁面就會往表中插入兩條記錄。方便之后刪除聊天,畢竟一方刪除不能讓另一方也看不到信息

SpringBoot中webSocket實現即時聊天

對于消息詳細離線內容,則使用了另外一張表。

SpringBoot中webSocket實現即時聊天

后臺代碼:

package com.w.wx.controller.WebSocket;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import com.w.wx.domain.ChatMessage;import com.w.wx.service.ChatService;import com.w.wx.utils.ALToHMUtil;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;import javax.websocket.*;import javax.websocket.server.PathParam;import javax.websocket.server.ServerEndpoint;import java.io.IOException;import java.util.ArrayList;import java.util.Iterator;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.atomic.AtomicInteger;@Slf4j@ServerEndpoint('/wx/{fromOpenid}/{toOpenid}')@Componentpublic class WebSocketServer { public static WebSocketServer webSocketServer; @Autowired private ChatService chatService; @PostConstruct//此注解的方法在bean加載前執行 private void init() {webSocketServer = this;//初始化時將靜態化的interFaceInfoMapper進行了實例化webSocketServer.chatService = this.chatService; } //靜態變量,用來記錄當前在線連接數。應該把它設計成線程安全的。 private static AtomicInteger onlineNum = new AtomicInteger(); //concurrent包的線程安全HashMap,用來存放每個客戶端對應的WebSocketServer對象。 private static ConcurrentHashMap<String, Session> sessionPools = new ConcurrentHashMap<>(); //發送消息 public void sendMessage(Session session, ChatMessage message) throws IOException {if(session != null){ synchronized (session) {String s = JSONObject.toJSONString(message);System.out.println('52 發送數據:' + s);session.getBasicRemote().sendText(s); }} } //給指定用戶發送信息 public void sendInfo(String to_openid, ChatMessage message){Session session = sessionPools.get(to_openid);if(session == null){ webSocketServer.chatService.addDeInfo(message);}else{ try {sendMessage(session, message); }catch (Exception e){e.printStackTrace(); }} } // 群發消息 public void broadcast(ChatMessage message){ for (Session session: sessionPools.values()) { try {sendMessage(session, message); } catch(Exception e){e.printStackTrace();continue; }} } //收到客戶端信息后,根據接收人的username把消息推下去或者群發 // to=-1群發消息 @OnMessage public void onMessage(String message) throws IOException{ChatMessage msg=JSON.parseObject(message, ChatMessage.class);sessionPools.get(msg.getToOpenid());webSocketServer.chatService.addInfo(message);if (msg.getToOpenid().equals('-1')) { broadcast(msg);} else { sendInfo(msg.getToOpenid(),msg);} } //建立連接成功調用 @OnOpen public void onOpen(Session session, @PathParam(value = 'fromOpenid') String fromOpenid,@PathParam(value = 'toOpenid') String toOpenid) throws IOException {ArrayList<ChatMessage> list = webSocketServer.chatService.getAllNotRead(fromOpenid,toOpenid);if (!list.isEmpty()) { Iterator<ChatMessage> it = list.iterator(); while (it.hasNext()) {ChatMessage chatMessage = it.next();chatMessage.setContent(ALToHMUtil.toUnicode(chatMessage.getContent()));sendMessage(session, chatMessage);log.info('115 當前用戶接收離線消息' + chatMessage.toString()); }}sessionPools.put(fromOpenid, session);addOnlineCount();System.out.println('125 '+fromOpenid + '加入webSocket!當前人數為' + onlineNum); } //關閉連接時調用 @OnClose public void onClose(@PathParam(value = 'fromOpenid') String fromOpenid) throws IOException {Session session = sessionPools.get(fromOpenid);session.close();sessionPools.remove(fromOpenid);subOnlineCount();System.out.println(fromOpenid + '斷開webSocket連接!當前人數為' + onlineNum); } //錯誤時調用 @OnError public void onError(Session session, Throwable throwable){ // System.out.println('發生錯誤');throwable.printStackTrace(); } public static void addOnlineCount(){onlineNum.incrementAndGet(); } public static void subOnlineCount() {onlineNum.decrementAndGet(); }public static AtomicInteger getOnlineNumber() {return onlineNum; }public static ConcurrentHashMap<String, Session> getSessionPools() {return sessionPools; }}

到此這篇關于SpringBoot中webSocket實現即時聊天的文章就介紹到這了,更多相關SpringBoot中webSocket實現即時聊天內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 久在线| 丝袜一区二区三区 | 精品国产乱码久久久久久影片 | 欧美一区视频在线 | 欧美无乱码久久久免费午夜一区 | 69av在线视频 | 97色在线视频 | 在线看一区二区三区 | 国产精品免费av | 综合精品久久久 | 久久99精品视频 | 男人的天堂久久 | 午夜精品一区二区三区在线视频 | 亚洲国产黄色av | 欧美成人激情 | 亚洲交性 | 最新av中文字幕 | 国产成人叼嘿视频在线观看 | 日本不卡免费新一二三区 | 中文字幕av第一页 | 久草新在线 | 国产精品视频播放 | 午夜精品在线 | 国产真实精品久久二三区 | 免费一看一级毛片 | 久久国产亚洲 | www.激情.com| 精品久久精品 | 久久小视频 | 精品国产18久久久久久二百 | 蜜桃特黄a∨片免费观看 | 亚洲国产成人av好男人在线观看 | 欧美精品成人一区二区三区四区 | 天堂免费看片 | 日本一区二区在线视频 | 欧美无乱码久久久免费午夜一区 | 欧美一区二区三区 | 国产精品自拍一区 | 日韩成人在线网站 | 成人在线观看免费爱爱 | 欧美日韩在线免费 |