SpringBoot中webSocket如何實現(xiàn)即時聊天

這篇文章主要介紹了SpringBoot中webSocket如何實現(xiàn)即時聊天，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

springboot是什么

springboot一種全新的編程規(guī)范，其設(shè)計目的是用來簡化新Spring應用的初始搭建以及開發(fā)過程，SpringBoot也是一個服務于框架的框架，服務范圍是簡化配置文件。

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

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

效果：

數(shù)據(jù)庫設(shè)計：

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

對于消息詳細離線內(nè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;
        //初始化時將靜態(tài)化的interFaceInfoMapper進行了實例化
        webSocketServer.chatService = this.chatService;
    }


	 //靜態(tài)變量，用來記錄當前在線連接數(shù)。應該把它設(shè)計成線程安全的。
    private static AtomicInteger onlineNum = new AtomicInteger();

    //concurrent包的線程安全HashMap，用來存放每個客戶端對應的WebSocketServer對象。
    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 當前用戶接收離線消息" + chatMessage.toString());
            }
        }

        sessionPools.put(fromOpenid, session);

        addOnlineCount();
        System.out.println("125 "+fromOpenid + "加入webSocket！當前人數(shù)為" + onlineNum);


    }

    //關(guān)閉連接時調(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 + "斷開webSocket連接！當前人數(shù)為" + onlineNum);

    }
    //錯誤時調(diào)用
    @OnError
    public void onError(Session session, Throwable throwable){
       // System.out.println("發(fā)生錯誤");
        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如何實現(xiàn)即時聊天”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識等著你來學習!