文章

ActiveMq消息推送

利用ActiveMQ提供的WebSTOMP插件，让浏览器能够使用WebSocket和ActiveMQ接收或者发送消息。由服务端向ActiveMQ发送STOMP消息，而浏览器作为客户端基于stomp.js利用WebSocket与之通信，订阅并接收消息。_activemq websocket

发表于 更新于
作者 贾永琪
4 分钟阅读
ActiveMq消息推送

文章信息

  • 原文链接：https://jiayq.blog.csdn.net/article/details/96888152
  • 发布时间：2019-07-22 19:52:25
  • 阅读量：2
  • 分类：ActiveMQ专栏收录该内容, 订阅专栏
  • 标签：#ActiveMq, #stomp, #推送, #socket, #发布/订阅

摘要

文章浏览阅读2.2k次。利用ActiveMQ提供的WebSTOMP插件，让浏览器能够使用WebSocket和ActiveMQ接收或者发送消息。由服务端向ActiveMQ发送STOMP消息，而浏览器作为客户端基于stomp.js利用WebSocket与之通信，订阅并接收消息。_activemq websocket

ActiveMq消息推送

  • 1.原理
  • 2.实例
    • 2.1创建项目
      • 2.2添加依赖
      • 2.3创建包结构及文件
      • 2.4创建生产者
      • 2.5创建生产者启动入口
      • 2.6创建消息消费者
      • 2.7启动消费者
      • 2.8启动生产者
  • 3.总结

1.原理

利用ActiveMQ提供的WebSTOMP插件，让浏览器能够使用WebSocket和ActiveMQ接收或者发送消息。由服务端向ActiveMQ发送STOMP消息，而浏览器作为客户端基于stomp.js利用WebSocket与之通信，订阅并接收消息。

2.实例

2.1创建项目

首先创建一个gradle项目
在这里插入图片描述

2.2添加依赖

在这里插入图片描述

1
2
3
4
5

compile group: 'org.apache.activemq', name: 'activemq-all', version: '5.15.9'
    compile group: 'org.springframework', name: 'spring-jms', version: '5.1.8.RELEASE'
    compile group: 'org.apache.activemq', name: 'activemq-pool', version: '5.15.9'
    compile group: 'org.springframework', name: 'spring-beans', version: '5.1.8.RELEASE'
    compile group: 'org.springframework', name: 'spring-context', version: "5.1.8.RELEASE"

2.3创建包结构及文件

在这里插入图片描述

2.4创建生产者

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

package com.study.produce;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.jms.Destination;
import java.util.Random;

/**
 * @author jiayq
 */
@Service("produce")
public class Produce {
    @Resource(name = "jmsTemplate")
    private JmsTemplate jmsTemplate;

    @Resource(name = "testQueue")
    private Destination testQueue;

    public void sendMessage(String messageContent) {
        jmsTemplate.send(testQueue, session -> session.createTextMessage(new Random().nextDouble() + "queue produce"));
    }
}

2.5创建生产者启动入口

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

package com.study.client;

import com.study.produce.Produce;
import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;
import org.springframework.context.ApplicationContext;

import java.util.Random;

/**
 * @author jiayq
 */
public class Client {

    public static void main(String[] args) throws InterruptedException {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("beans.xml");
        Produce produce = applicationContext.getBean("produce",Produce.class);
        while (true) {
            produce.sendMessage(new Random().nextDouble() + "");
            Thread.sleep(3 * 1000);
        }
    }

}

2.6创建消息消费者

在这里插入图片描述

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>ActiveMqPush:This is the consume.</title>
    <!--<link rel="stylesheet" type="text/css" href="default.css">-->
    <!--<link rel="stylesheet" type="text/css" href="jquery.notify.jcss">-->
    <script type="text/javascript" src="stomp.js"></script>
    <script type="text/javascript" src="jquery.min.js"></script>
</head>
<script type="text/javascript">
    $(document).ready(function () {
        //创建客户端
        var client = Stomp.client("ws://localhost:61614/");
        //定义连接成功回调函数
        var onConnect = function () {
            //订阅商品折扣主题的消息
            client.subscribe("/queue/spring_queue", function (message) {
                //弹出业务消息提醒
                $("#body").append("\t" + message.body + "<br/>");
            });

        };
        //定义错误时回调函数
        var onError = function (msg) {
            $("#body").html(msg);
        };
        //连接服务器
        client.connect("guest", "guest", onConnect, onError);
        client.heartbeat.incoming = 5000;
        client.heartbeat.outgoing = 5000;
    });
</script>
<body>
<div id="body"></div>
</body>
</html>

2.7启动消费者

在这里插入图片描述
在这里插入图片描述

2.8启动生产者

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

3.总结

客户端连接时的URL地址取决于ActiveMQ服务器的配置，因为实例中浏览器与ActiveMQ之间采用WebSocket通信的，而在ActiveMQ中WebSocket的传输连接器默认配置端口是61614,所以连接的URL是ws://localhost:61614/.
ActiveMQ中默认的传输连接器配置如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

 <!--
            The transport connectors expose ActiveMQ over a given protocol to
            clients and other brokers. For more information, see:

            http://activemq.apache.org/configuring-transports.html
        -->
        <transportConnectors>
            <!-- Create a TCP transport that is advertised on via an IP multicast
              group named default. -->
            <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
            <!-- Create a SSL transport. Make sure to configure the SSL options
              via the system properties or the sslContext element. -->
            <transportConnector name="ssl" uri="ssl://localhost:61617"/>
            <!-- Create a STOMP transport for STOMP clients. -->
            <transportConnector name="stomp" uri="stomp://localhost:61613"/>
            <!-- Create a Websocket transport for the websocket dmeo -->
            <transportConnector name="ws" uri="ws://localhost:61614/" />
        </transportConnectors>

apache-activemq-5.15.9-bin\apache-activemq-5.15.9\examples\conf
activemq-demo.xml
在这里插入图片描述

ActiveMq, stomp, 推送, socket
本文由作者按照 CC BY 4.0 进行授权