SpringBoot中webSocket實(shí)現(xiàn)即時(shí)聊天
即時(shí)聊天
這個(gè)使用了websocket,在springboot下使用很簡(jiǎn)單。前端是小程序,這個(gè)就比較坑,小程序即時(shí)聊天上線需要域名并且使用wss協(xié)議,就是ws+ssl更加安全。但是要上線這還不夠,你必須為企業(yè)主體開(kāi)發(fā)者。個(gè)人開(kāi)發(fā)者即時(shí)聊天屬于社交、不在服務(wù)類目?jī)?nèi),審核會(huì)不通過(guò)!?。?br />
功能 :我們的小程序是個(gè)二手交易小程序,即時(shí)聊天對(duì)于一個(gè)后臺(tái)服務(wù)器只是單核2g的來(lái)說(shuō)有點(diǎn)抗不住。所以在雙方都在線的時(shí)候沒(méi)有存儲(chǔ)聊天消息,只是在單方不在線時(shí)存儲(chǔ)了離線消息。而且只能發(fā)三條離線消息。仿照了csdn的聊天。
使用:我們是點(diǎn)擊進(jìn)入聊天之后才發(fā)起websocket,這就造成了一個(gè)問(wèn)題,就是用戶退出到消息列表又重新點(diǎn)進(jìn)入就會(huì)重新發(fā)送一個(gè)websocket請(qǐng)求。每次請(qǐng)求session都不一樣。而且微信限制一個(gè)用戶只能同時(shí)發(fā)起5個(gè)請(qǐng)求。一開(kāi)始前端沒(méi)能退出聊天頁(yè)面就端開(kāi),就錯(cuò)誤唉?。?。只能后臺(tái)去斷使用sessioin.close()會(huì)調(diào)用onClose()方法
這個(gè)session是你要斷的session。不過(guò)后來(lái)前端可以自己斷了就nice了!
效果:
數(shù)據(jù)庫(kù)設(shè)計(jì):
對(duì)于展示消息聊天列表使用了一張表。last_context為對(duì)方發(fā)送的最后一條消息。只要有一方點(diǎn)擊了私信進(jìn)入聊天頁(yè)面就會(huì)往表中插入兩條記錄。方便之后刪除聊天,畢竟一方刪除不能讓另一方也看不到信息
對(duì)于消息詳細(xì)離線內(nèi)容,則使用了另外一張表。
后臺(tái)代碼:
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}") @Component public class WebSocketServer { public static WebSocketServer webSocketServer; @Autowired private ChatService chatService; @PostConstruct //此注解的方法在bean加載前執(zhí)行 private void init() { webSocketServer = this; //初始化時(shí)將靜態(tài)化的interFaceInfoMapper進(jìn)行了實(shí)例化 webSocketServer.chatService = this.chatService; } //靜態(tài)變量,用來(lái)記錄當(dāng)前在線連接數(shù)。應(yīng)該把它設(shè)計(jì)成線程安全的。 private static AtomicInteger onlineNum = new AtomicInteger(); //concurrent包的線程安全HashMap,用來(lái)存放每個(gè)客戶端對(duì)應(yīng)的WebSocketServer對(duì)象。 private static ConcurrentHashMap<String, Session> sessionPools = new ConcurrentHashMap<>(); //發(fā)送消息 public void sendMessage(Session session, ChatMessage message) throws IOException { if(session != null){ synchronized (session) { String s = JSONObject.toJSONString(message); System.out.println("52 發(fā)送數(shù)據(jù):" + s); session.getBasicRemote().sendText(s); } } } //給指定用戶發(fā)送信息 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(); } } } // 群發(fā)消息 public void broadcast(ChatMessage message){ for (Session session: sessionPools.values()) { try { sendMessage(session, message); } catch(Exception e){ e.printStackTrace(); continue; } } } //收到客戶端信息后,根據(jù)接收人的username把消息推下去或者群發(fā) // to=-1群發(fā)消息 @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); } } //建立連接成功調(diào)用 @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 當(dāng)前用戶接收離線消息" + chatMessage.toString()); } } sessionPools.put(fromOpenid, session); addOnlineCount(); System.out.println("125 "+fromOpenid + "加入webSocket!當(dāng)前人數(shù)為" + onlineNum); } //關(guān)閉連接時(shí)調(diào)用 @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 + "斷開(kāi)webSocket連接!當(dāng)前人數(shù)為" + onlineNum); } //錯(cuò)誤時(shí)調(diào)用 @OnError public void onError(Session session, Throwable throwable){ // System.out.println("發(fā)生錯(cuò)誤"); 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; } }
到此這篇關(guān)于SpringBoot中webSocket實(shí)現(xiàn)即時(shí)聊天的文章就介紹到這了,更多相關(guān)SpringBoot中webSocket實(shí)現(xiàn)即時(shí)聊天內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- springboot結(jié)合websocket聊天室實(shí)現(xiàn)私聊+群聊
- SpringBoot整合websocket實(shí)現(xiàn)即時(shí)通信聊天
- SpringBoot+WebSocket實(shí)現(xiàn)多人在線聊天案例實(shí)例
- Springboot+WebSocket實(shí)現(xiàn)一對(duì)一聊天和公告的示例代碼
- Springboot基于websocket實(shí)現(xiàn)簡(jiǎn)單在線聊天功能
- SpringBoot+WebSocket搭建簡(jiǎn)單的多人聊天系統(tǒng)
- SpringBoot+Websocket實(shí)現(xiàn)一個(gè)簡(jiǎn)單的網(wǎng)頁(yè)聊天功能代碼
- SpringBoot結(jié)合WebSocket實(shí)現(xiàn)聊天功能
相關(guān)文章
Java中的ThreadPoolExecutor線程池原理細(xì)節(jié)解析
這篇文章主要介紹了Java中的ThreadPoolExecutor線程池原理細(xì)節(jié)解析,ThreadPoolExecutor是一個(gè)線程池,最多可使用7個(gè)參數(shù)來(lái)控制線程池的生成,使用線程池可以避免創(chuàng)建和銷毀線程的資源損耗,提高響應(yīng)速度,并且可以管理線程池中線程的數(shù)量和狀態(tài)等等,需要的朋友可以參考下2023-12-12Spring Boot之搞定mongoTemplate的知識(shí)小結(jié)
這篇文章主要介紹了Spring Boot之搞定mongoTemplate的知識(shí)小結(jié),本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-12-12SpringAOP如何修改請(qǐng)求參數(shù)列表
這篇文章主要介紹了SpringAOP如何修改請(qǐng)求參數(shù)列表問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-03-03Springboot?如何使用BindingResult校驗(yàn)參數(shù)
這篇文章主要介紹了Springboot?如何使用BindingResult校驗(yàn)參數(shù),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-01-01MyBatis 源碼分析 之SqlSession接口和Executor類
mybatis框架在操作數(shù)據(jù)的時(shí)候,離不開(kāi)SqlSession接口實(shí)例類的作用,下面通過(guò)本文給大家實(shí)例剖析MyBatis 源碼分析之SqlSession接口和Executor類,需要的朋友參考下吧2017-02-02Java?如何通過(guò)注解實(shí)現(xiàn)接口輸出時(shí)數(shù)據(jù)脫敏
這篇文章主要介紹了Java?如何通過(guò)注解實(shí)現(xiàn)接口輸出時(shí)數(shù)據(jù)脫敏,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-12-12