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

springboot+websocket+redis搭建的實現(xiàn)

 更新時間：2021年04月09日 11:33:22   作者：我犟不過你  
這篇文章主要介紹了springboot+websocket+redis搭建的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

在多負載環(huán)境下使用websocket。

一、原因

在某些業(yè)務場景，我們需要頁面對于后臺的操作進行實時的刷新，這時候就需要使用websocket。

通常在后臺單機的情況下沒有任何的問題，如果后臺經(jīng)過nginx等進行負載的話，則會導致前臺不能準備的接收到后臺給與的響應。socket屬于長連接，其session只會保存在一臺服務器上，其他負載及其不會持有這個session，此時，我們需要使用redis的發(fā)布訂閱來實現(xiàn)，session的共享。

二、環(huán)境準備

在https://mvnrepository.com/里，查找websocket的依賴。使用springboot的starter依賴，注意對應自己springboot的版本。

<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-websocket -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
    <version>2.2.10.RELEASE</version>
</dependency>

除此之外添加redis的依賴，也使用starter版本：

        <!-- redis -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

三、代碼

redis監(jiān)聽配置：

/**
 * @description： redis監(jiān)聽配置類
 * @author：weirx
 * @date：2021/3/22 14:08
 * @version：3.0
 */
@Configuration
public class RedisConfig {

    /**
     * description: 手動注冊Redis監(jiān)聽到IOC
     *
     * @param redisConnectionFactory
     * @return: org.springframework.data.redis.listener.RedisMessageListenerContainer
     * @author: weirx
     * @time: 2021/3/22 14:11
     */
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisConnectionFactory);
        return container;
    }
}

webSocket配置：

/**
 * @description： websocket配置類
 * @author：weirx
 * @date：2021/3/22 14:11
 * @version：3.0
 */
@Configuration
public class WebSocketConfig {

    /**
     * description: 這個配置類的作用是要注入ServerEndpointExporter，
     * 這個bean會自動注冊使用了@ServerEndpoint注解聲明的Websocket endpoint。
     * 如果是使用獨立的servlet容器，而不是直接使用springboot的內置容器，
     * 就不要注入ServerEndpointExporter，因為它將由容器自己提供和管理。
     *
     * @return: org.springframework.web.socket.server.standard.ServerEndpointExporter
     * @author: weirx
     * @time: 2021/3/22 14:12
     */
    @Bean
    public ServerEndpointExporter serverEndpointExporter(){
        return new ServerEndpointExporter();
    }
}

redis工具類：

@Component
public class RedisUtil {

    @Autowired
    private StringRedisTemplate stringRedisTemplate;


    /**
     * 發(fā)布
     *
     * @param key
     */
    public void publish(String key, String value) {
        stringRedisTemplate.convertAndSend(key, value);
    }
}

WebSocket服務提供類：

/**
 * description: @ServerEndpoint 注解是一個類層次的注解，
 * 它的功能主要是將目前的類定義成一個websocket服務器端,注解的值將被用于監(jiān)聽用戶連接的終端訪問URL地址,
 * 客戶端可以通過這個URL來連接到WebSocket服務器端使用springboot的唯一區(qū)別是要@Component聲明下，
 * 而使用獨立容器是由容器自己管理websocket的，但在springboot中連容器都是spring管理的。
 *
 * @author: weirx
 * @time: 2021/3/22 14:31
 */
@Slf4j
@Component
@ServerEndpoint("/websocket/server/{loginName}")
public class WebSocketServer {

    /**
     * 因為@ServerEndpoint不支持注入，所以使用SpringUtils獲取IOC實例
     */
    private RedisMessageListenerContainer redisMessageListenerContainer =
            ApplicationContextProvider.getBean(RedisMessageListenerContainer.class);

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

    /**
     * concurrent包的線程安全Set，用來存放每個客戶端對應的webSocket對象。
     * 若要實現(xiàn)服務端與單一客戶端通信的話，可以使用Map來存放，其中Key可以為用戶標識
     */
    private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>();

    /**
     * 與某個客戶端的連接會話，需要通過它來給客戶端發(fā)送數(shù)據(jù)
     */
    private Session session;

    /**
     * redis監(jiān)聽
     */
    private SubscribeListener subscribeListener;

    /**
     * 連接建立成功調用的方法
     *
     * @param session 可選的參數(shù)。session為與某個客戶端的連接會話，需要通過它來給客戶端發(fā)送數(shù)據(jù)
     */
    @OnOpen
    public void onOpen(@PathParam("loginName") String loginName, Session session) {
        this.session = session;
        //加入set中
        webSocketSet.add(this);
        //在線數(shù)加1
        addOnlineCount();
        log.info("有新連接[" + loginName + "]加入！當前在線人數(shù)為{}", getOnlineCount());
        subscribeListener = new SubscribeListener();
        subscribeListener.setSession(session);
        //設置訂閱topic
        redisMessageListenerContainer.addMessageListener(
                subscribeListener, new ChannelTopic(Constants.TOPIC_PREFIX + loginName));

    }

    /**
     * 連接關閉調用的方法
     */
    @OnClose
    public void onClose() throws IOException {
        //從set中刪除
        webSocketSet.remove(this);
        //在線數(shù)減1
        subOnlineCount();
        redisMessageListenerContainer.removeMessageListener(subscribeListener);
        log.info("有一連接關閉！當前在線人數(shù)為{}", getOnlineCount());
    }

    /**
     * 收到客戶端消息后調用的方法
     *
     * @param message 客戶端發(fā)送過來的消息
     * @param session 可選的參數(shù)
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("來自客戶端的消息:{}", message);
        //群發(fā)消息
        for (WebSocketServer item : webSocketSet) {
            try {
                item.sendMessage(message);
            } catch (IOException e) {
                log.info("發(fā)送消息異常：msg = {}", e);
                continue;
            }
        }
    }

    /**
     * 發(fā)生錯誤時調用
     *
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error) {
        log.info("發(fā)生錯誤，{}", error);
    }

    /**
     * 這個方法與上面幾個方法不一樣。沒有用注解，是根據(jù)自己需要添加的方法。
     *
     * @param message
     * @throws IOException
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
    }

    public int getOnlineCount() {
        return onlineCount.get();
    }

    public void addOnlineCount() {
        WebSocketServer.onlineCount.getAndIncrement();
    }

    public void subOnlineCount() {
        WebSocketServer.onlineCount.getAndDecrement();
    }

}

redis消息發(fā)布：

    @Autowired
    private RedisUtil redisUtil;

    @Override
    public Result send(String loginName, String msg) {
        //推送站內信webSocket
        redisUtil.publish("TOPIC" + loginName, msg);
        return Result.success();
    }

前端vue代碼：

<template>
  <div class="dashboard-container">
    <div class="dashboard-text">消息內容: {{ responseData }}</div>
  </div>
</template>

<script>
  import {mapGetters} from 'vuex'

  export default {
    data() {
      return {
        websocket: null,
        responseData: null
      }
    },
    created() {
      this.initWebSocket();
    },
    destroyed() {
      this.websock.close() //離開路由之后斷開websocket連接
    },
    methods: {
      //初始化websocket
      initWebSocket() {
        const wsUri = "ws://127.0.0.1:21116/websocket/server/" + "admin";
        this.websock = new WebSocket(wsUri);
        this.websock.onmessage = this.websocketonmessage;
        this.websock.onopen = this.websocketonopen;
        this.websock.onerror = this.websocketonerror;
        this.websock.onclose = this.websocketclose;
      },
      websocketonopen() { //連接建立之后執(zhí)行send方法發(fā)送數(shù)據(jù)
        let actions = {"用戶賬號": "admin"};
        this.websocketsend(JSON.stringify(actions));
      },
      websocketonerror() {//連接建立失敗重連
        this.initWebSocket();
      },
      websocketonmessage(e) { //數(shù)據(jù)接收
        const redata = JSON.parse(e.data);
        this.responseData = redata;
      },
      websocketsend(Data) {//數(shù)據(jù)發(fā)送
        this.websock.send(Data);
      },
      websocketclose(e) {  //關閉
        console.log('斷開連接', e);
      },

    },
    name: 'Dashboard',
    computed: {
      ...mapGetters([
        'name',
        'roles'
      ])
    }
  }
</script>

四、測試

發(fā)送前

發(fā)送后

到此這篇關于springboot+websocket+redis搭建的實現(xiàn)的文章就介紹到這了,更多相關springboot websocket redis搭建內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • 淺談Java中的Queue家族

    淺談Java中的Queue家族

    Java中Collection集合有三大家族List，Set和Queue。當然Map也算是一種集合類，但Map并不繼承Collection接口。List，Set在我們的工作中會經(jīng)常使用，通常用來存儲結果數(shù)據(jù)，而Queue由于它的特殊性，通常用在生產者消費者模式中。今天這篇文章將帶大家進入Queue家族。
    2021-06-06
  • java開源項目jeecgboot的超詳細解析

    java開源項目jeecgboot的超詳細解析

    JeecgBoot是一款基于BPM的低代碼平臺,下面這篇文章主要給大家介紹了關于java開源項目jeecgboot的相關資料,文中通過圖文以及實例代碼介紹的非常詳細,需要的朋友可以參考下
    2022-10-10
  • JVM完全解讀之YGC來龍去脈分析

    JVM完全解讀之YGC來龍去脈分析

    YGC是JVM?GC當前最為頻繁的一種GC，一個高并發(fā)的服務在運行期間，會進行大量的YGC，發(fā)生YGC時，會進行STW，一般時間都很短，除非碰到YGC時，存在大量的存活對象需要進行拷貝
    2022-01-01
  • 詳解MyBatis特性之動態(tài)SQL

    詳解MyBatis特性之動態(tài)SQL

    動態(tài) SQL 是 MyBatis 的強大特性之一,這篇文章我們將結合動態(tài)SQL完成更加復雜的 SQL 操作,文章通過代碼示例給大家介紹的非常詳細,對大家的學習或工作有一定的幫助,需要的朋友可以參考下
    2024-01-01
  • 詳解Spring Boot中如何自定義SpringMVC配置

    詳解Spring Boot中如何自定義SpringMVC配置

    這篇文章主要給大家介紹了關于Spring Boot中如何自定義SpringMVC配置的相關資料,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2021-09-09
  • Javaweb動態(tài)開發(fā)最重要的Servlet詳解

    Javaweb動態(tài)開發(fā)最重要的Servlet詳解

    動態(tài)web的核心是Servlet，由tomcat解析并執(zhí)行，本質是Java中的一個類（面向對象）這個類的功能十分強大幾乎可以完成全部功能，在Java規(guī)范中只有Servlet實現(xiàn)類實例化的對象才能被瀏覽器訪問，所以掌握Servlet具有重要意義
    2022-08-08
  • Spring?Cloud?Gateway編碼實現(xiàn)任意地址跳轉

    Spring?Cloud?Gateway編碼實現(xiàn)任意地址跳轉

    這篇文章主要介紹了Spring?Cloud?Gateway編碼實現(xiàn)任意地址跳轉的相關資料,需要的朋友可以參考下
    2023-06-06
  • Spring事務管理中關于數(shù)據(jù)庫連接池詳解

    Spring事務管理中關于數(shù)據(jù)庫連接池詳解

    事務的作用就是為了保證用戶的每一個操作都是可靠的，事務中的每一步操作都必須成功執(zhí)行，只要有發(fā)生異常就 回退到事務開始未進行操作的狀態(tài)。事務管理是Spring框架中最為常用的功能之一，我們在使用Spring Boot開發(fā)應用時，大部分情況下也都需要使用事務
    2022-12-12
  • java-for循環(huán)問題

    java-for循環(huán)問題

    這篇文章主要介紹了java-for循環(huán)問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2023-03-03
  • SpringMVC中Controller類數(shù)據(jù)響應的方法

    SpringMVC中Controller類數(shù)據(jù)響應的方法

    這篇文章主要介紹了SpringMVC中的數(shù)據(jù)響應的問題，主要來了解 Controller 類如何進行數(shù)據(jù)響應的，本文給大家介紹的非常詳細，需要的朋友可以參考下
    2021-07-07

最新評論