欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot中webSocket實(shí)現(xiàn)即時(shí)聊天

 更新時(shí)間:2021年04月30日 08:18:51   作者:古墓派學(xué)子  
這篇文章主要介紹了SpringBoot中webSocket實(shí)現(xiàn)即時(shí)聊天,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

即時(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)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Java中的ThreadPoolExecutor線程池原理細(xì)節(jié)解析

    Java中的ThreadPoolExecutor線程池原理細(xì)節(jié)解析

    這篇文章主要介紹了Java中的ThreadPoolExecutor線程池原理細(xì)節(jié)解析,ThreadPoolExecutor是一個(gè)線程池,最多可使用7個(gè)參數(shù)來(lái)控制線程池的生成,使用線程池可以避免創(chuàng)建和銷毀線程的資源損耗,提高響應(yīng)速度,并且可以管理線程池中線程的數(shù)量和狀態(tài)等等,需要的朋友可以參考下
    2023-12-12
  • Spring Boot之搞定mongoTemplate的知識(shí)小結(jié)

    Spring Boot之搞定mongoTemplate的知識(shí)小結(jié)

    這篇文章主要介紹了Spring Boot之搞定mongoTemplate的知識(shí)小結(jié),本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-12-12
  • springboot多模塊包掃描問(wèn)題的解決方法

    springboot多模塊包掃描問(wèn)題的解決方法

    這篇文章主要介紹了springboot多模塊包掃描問(wèn)題的解決方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-09-09
  • SpringAOP如何修改請(qǐng)求參數(shù)列表

    SpringAOP如何修改請(qǐng)求參數(shù)列表

    這篇文章主要介紹了SpringAOP如何修改請(qǐng)求參數(shù)列表問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-03-03
  • Springboot?如何使用BindingResult校驗(yàn)參數(shù)

    Springboot?如何使用BindingResult校驗(yàn)參數(shù)

    這篇文章主要介紹了Springboot?如何使用BindingResult校驗(yàn)參數(shù),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-01-01
  • JAVA ArrayList詳細(xì)介紹(示例)

    JAVA ArrayList詳細(xì)介紹(示例)

    本文對(duì)JAVA ArrayList做了詳細(xì)介紹,文中學(xué)到了ArrayList源碼解析、ArrayList遍歷方式、toArray()異常,最后給出了ArrayList示例。
    2013-11-11
  • MyBatis 源碼分析 之SqlSession接口和Executor類

    MyBatis 源碼分析 之SqlSession接口和Executor類

    mybatis框架在操作數(shù)據(jù)的時(shí)候,離不開(kāi)SqlSession接口實(shí)例類的作用,下面通過(guò)本文給大家實(shí)例剖析MyBatis 源碼分析之SqlSession接口和Executor類,需要的朋友參考下吧
    2017-02-02
  • 你知道jdk竟有4個(gè)random嗎

    你知道jdk竟有4個(gè)random嗎

    這篇文章主要給大家介紹了關(guān)于jdk中4個(gè)random的相關(guān)資料,分別是Random、ThreadLocalRandom、SecureRandom以及SplittableRandom,文中通過(guò)示例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2021-06-06
  • spring-session自定義序列化方式

    spring-session自定義序列化方式

    這篇文章主要介紹了spring-session自定義序列化方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-12-12
  • Java?如何通過(guò)注解實(shí)現(xiàn)接口輸出時(shí)數(shù)據(jù)脫敏

    Java?如何通過(guò)注解實(shí)現(xiàn)接口輸出時(shí)數(shù)據(jù)脫敏

    這篇文章主要介紹了Java?如何通過(guò)注解實(shí)現(xiàn)接口輸出時(shí)數(shù)據(jù)脫敏,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-12-12

最新評(píng)論