99偷拍视频精品区一区二,口述久久久久久久久久久久,国产精品夫妇激情啪发布,成人永久免费网站在线观看,国产精品高清免费在线,青青草在线观看视频观看,久久久久久国产一区,天天婷婷久久18禁,日韩动漫av在线播放直播

SpringBoot+WebSocket怎么實現在線聊天

本篇內容主要講解“SpringBoot+WebSocket怎么實現在線聊天”,感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷,實用性強。下面就讓小編來帶大家學習“SpringBoot+WebSocket怎么實現在線聊天”吧!

成都創新互聯公司是一家朝氣蓬勃的網站建設公司。公司專注于為企業提供信息化建設解決方案。從事網站開發,網站制作,網站設計,網站模板,微信公眾號開發,軟件開發,成都小程序開發,10年建站對成都水電改造等多個領域,擁有豐富的網站推廣經驗。

在線聊天使用了SpringBoot+WebSocket實現,為了保證用戶隱私,所有的聊天數據都保存在系統本地,服務器只進行了數據轉發。OK,那接下來,我們來看下大致的實現步驟。

服務端

服務端首先加入websocket依賴,如下:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

創建WebSocket的配置類,如下:

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
    @Override
    public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
        stompEndpointRegistry.addEndpoint("/ws/endpointChat").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/queue","/topic");
    }
}

這里我并未使用原生的websocket協議,而是使用了websocket的子協議stomp,方便一些。消息代理既使用了/queue,又使用了/topic,主要是因為我這里既有點對點的單聊(queue),也有發送系統消息的群聊(topic)。

創建websocket處理類Controller,如下:

@Controller
public class WsController {
    @Autowired
    SimpMessagingTemplate messagingTemplate;

    @MessageMapping("/ws/chat")
    public void handleChat(Principal principal, String msg) {
        String destUser = msg.substring(msg.lastIndexOf(";") + 1, msg.length());
        String message = msg.substring(0, msg.lastIndexOf(";"));
        messagingTemplate.convertAndSendToUser(destUser, "/queue/chat", new ChatResp(message, principal.getName()));
    }
}

消息協議很簡單:發送來的消息,最后一個;后面跟的是該條消息要發送到哪個用戶,這里通過字符串截取將之提取出來。響應消息包含兩個字段,一個是消息內容,一個是該條消息由誰發送。

OK,如此之后,我們的服務端就寫好了,很簡單。

前端

前端代碼稍微復雜,我這里主要和小伙伴介紹下我的大致思路和核心代碼,具體代碼小伙伴可以star源碼進行研究。

首先,當用戶登錄成功之后,我就發起websocket的連接,將ws連接起來,ws的代碼我主要寫在了store中,如下:

connect(context){
    context.state.stomp = Stomp.over(new SockJS("/ws/endpointChat"));
    context.state.stomp.connect({}, frame=> {
    context.state.stomp.subscribe("/user/queue/chat", message=> {
        var msg = JSON.parse(message.body);
        var oldMsg = window.localStorage.getItem(context.state.user.username + "#" + msg.from);
        if (oldMsg == null) {
        oldMsg = [];
        oldMsg.push(msg);
        window.localStorage.setItem(context.state.user.username + "#" + msg.from, JSON.stringify(oldMsg))
        } else {
        var oldMsgJson = JSON.parse(oldMsg);
        oldMsgJson.push(msg);
        window.localStorage.setItem(context.state.user.username + "#" + msg.from, JSON.stringify(oldMsgJson))
        }
        if (msg.from != context.state.currentFriend.username) {
        context.commit("addValue2DotMap", "isDot#" + context.state.user.username + "#" + msg.from);
        }
        //更新msgList
        var oldMsg2 = window.localStorage.getItem(context.state.user.username + "#" + context.state.currentFriend.username);
        if (oldMsg2 == null) {
        context.commit('updateMsgList', []);
        } else {
        context.commit('updateMsgList', JSON.parse(oldMsg2));
        }
    });
    }, failedMsg=> {

    });
}

連接成功之后,就可以準備接收服務端的消息了,接收到服務端的消息后,數據保存在localStorage中,保存格式是 當前用戶名#消息發送方用戶名:[{from:'消息發送方',msg:'消息內容'}],注意后面的是一個json數組,整個存儲的key之所以用當前用戶名#消息發送方用戶名是為了避免同一個瀏覽器多個用戶登錄所產生的數據紊亂,OK,這樣兩個人的聊天記錄都將保存在這個數組中。在聊天展示頁面,當數組中的數據發生變化時,自動更新。

在聊天頁面,通過stomp發送消息,如下:

this.$store.state.stomp.send("/ws/chat", {}, this.msg + ";" + this.currentFriend.username);

注意每條消息的內容除了內容本身外,還要加上當前發送者的名字。
每次發送成功后更新聊天頁面即可。更新聊天頁面代碼如下:

<template v-for="msg in msgList">
<!--發送來的消息-->
<div
    
    v-if="msg.from==currentFriend.username">
    <img :src="currentFriend.userface" class="userfaceImg">
    <div
    >
    {{msg.msg}}
    </div>
</div>
<!--發出去的消息-->
<div v-if="msg.from!=currentFriend.username"
        >
    <div
    >
    {{msg.msg}}
    </div>
    <img :src="currentUser.userface" class="userfaceImg">
</div>
</template>

如果消息中的from字段的值,就是當前聊天的用戶名,則是發送來的消息,否則就是發出去的消息,不同的消息設置不同的樣式即可。

到此,相信大家對“SpringBoot+WebSocket怎么實現在線聊天”有了更深的了解,不妨來實際操作一番吧!這里是創新互聯網站,更多相關內容可以進入相關頻道進行查詢,關注我們,繼續學習!

文章題目:SpringBoot+WebSocket怎么實現在線聊天
網站網址:http://www.yijiale78.com/article28/joohcp.html

成都網站建設公司_創新互聯,為您提供移動網站建設Google動態網站關鍵詞優化云服務器企業網站制作

廣告

聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯

微信小程序開發