ActiveMQ、Stomp、SockJS入門級應用

使用ActiveMQ、Stomp、SockJS實現實時在線聊天

 

　　ActiveMQ ： 強大的開源即時通訊和集成模式的服務器。在本項目中充當消息代理服務器，stomp協議服務端。

　　　　安裝：在官網下載，直接解壓縮，運行cmd，進入bin目錄執行 activemq.bat  start；linux中執行 ./activemq start。

　　Stomp：stomp是一個文本定向通訊協議。本項目使用stomp協議基於JavaScript的客戶端庫 stomp.js

　　　　安裝：下載stomp.js，引入項目中

　　SockJS：SockJS是WebSocket的JavaScript庫，是webSocket的實現　　

 　　　　安裝：下載SockJS.js，引入項目中

 

　　第一步 ： 創建JavaWeb項目，配置Maven依賴，依賴如下

 

<properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <spring.version>4.2.4.RELEASE</spring.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-websocket</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-messaging</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-net</artifactId>
            <version>2.0.7.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.0.33.Final</version>
        </dependency>


        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.6.4</version>
        </dependency>

        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
            <version>3.1.0</version>
            <scope>provided</scope>
        </dependency>


    </dependencies>

 

　　第二步：配置消息終端，在SpringMVC配置文件中加入如下配置

　　

<websocket:message-broker application-destination-prefix="/app">
        <websocket:stomp-endpoint path="/stomp">
            <websocket:sockjs />
        </websocket:stomp-endpoint>

        <websocket:stomp-broker-relay
            prefix="/topic,/queue"
            relay-host="localhost"
            relay-port="61613"
            heartbeat-receive-interval="20000"
            heartbeat-send-interval="20000"
        />

    </websocket:message-broker>

　　第三步：編寫消息處理代碼

package com.its.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Controller;

@Controller
public class MessageController {

    @Autowired
    private SimpMessagingTemplate template;

    @MessageMapping("channel")
    public String send(String message){

        String text = message;

        template.convertAndSend("/topic/pinkzhuang",text);

        return text;
    }

}

　　第四步：編寫頁面消息收發邏輯，頁面要引入stomp.js和SockJS.js

function connect(){
            var socket = new SockJS("http://localhost:8080/ActivityMQStomp/stomp");
            stompClient = Stomp.over(socket);
            stompClient.connect({},function(frame){
                setConnected(true);
                console.log("Connected: " + frame);
                stompClient.subscribe("/topic/pinkzhuang",function(greeting){
                    showGreeting(greeting.body);
                });
            });

        }

function disconnect(){
　　stompClient.disconnect();
}

function sendMessage(message){
　　stompClient.send("/app/vince",{},name);
}

　　第五步：管理ActiveMQ

　　　　可登錄localhost:8161進入activeMQ的管理頁面，初始賬號密碼均為admin，可以手動在管理頁面發送消息　

　　The End. （原文）