没有合适的资源？快使用搜索试试~ 我知道了~

文库首页后端JavaSpringBoot整合ActiveMQ+websocket.docx

SpringBoot整合ActiveMQ+websocket.docx

activemq

springboot

stomp.js

需积分: 50 14 下载量 157 浏览量 2019-08-05 22:41:03 上传评论 3 收藏 31KB DOCX 举报

温馨提示

试读

24页

SpringBoot整合ActiveMQ+websocket.docx ，该文档包含于activemq整合的各个情况，springboot，js,websocket与mq整合，该资源是上传代码的word文档部分

资源推荐

资源详情

资源评论

Queue

Pom

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-

activemq</artifactId>

</dependency>

application.yml

server:

port: 7777

spring:

activemq:

broker-url: tcp://127.0.0.1:61616 # 自己的 mq 服务器地址

user: admin

password: admin

jms:

pub-sub-domain: false #fasle=queue true=topic,不写

默认是队列 queue

#自己定义队列名称

myqueue: boot-activemq-queue

队列生成者

Cong

package boot_mq_produce.config;

import javax.jms.Queue;

import org.apache.activemq.command.ActiveMQQueue;

import

org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.jms.annotation.EnableJms;

import

org.springframework.scheduling.annotation.EnableSchedulin

import org.springframework.stereotype.Component;

@Component

@EnableJms

@EnableScheduling

public class ConfigMq {

@Value("${myqueue}")

private String myQueue;

@Bean

public Queue queue() {

return new ActiveMQQueue(myQueue);

}

队列生成者代码

package boot_mq_produce.product;

import java.util.UUID;

import javax.jms.Queue;

import

org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.core.JmsMessagingTemplate;

import

org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

@Component

public class QueueProduce {

@Autowired

private JmsMessagingTemplate jmsMessagingTemplate;

@Autowired

private Queue queue;

public void produceMsg() {

jmsMessagingTemplate.convertAndSend(queue,"***"+UUID.rand

omUUID());

}

@Scheduled(fixedDelay=2000)

public void produceMsgScheduled() {

jmsMessagingTemplate.convertAndSend(queue,"***"+UUID.rand

omUUID());

System.out.println("间隔发送");

}

队列消费者

队列消费者代码

package boot_mq_consumer.cconsumer;

import javax.jms.TextMessage;

import org.springframework.jms.annotation.JmsListener;

import org.springframework.stereotype.Component;

@Component

public class QueueConsumer {

@JmsListener(destination="${myqueue}")

public void recive(TextMessage textMessage) throws

Exception {

System.out.println("消费者接到的消

息"+textMessage.getText());

}

Topic

Pom

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-

activemq</artifactId>

</dependency>

application.yml

主题生产者和消费者相同

server:

port: 6666

spring:

activemq:

broker-url: tcp://127.0.0.1:61616 # 自己的 mq 服务器地址

user: admin

password: admin

jms:

pub-sub-domain: true #fasle=queue true=topic,不写默

认是队列 queue

#自己定义队列名称

mytopic: boot-activemq-topic

主题生产者

Cong

package boot_mq_topic_produce.config;

import javax.jms.Topic;

import org.apache.activemq.command.ActiveMQTopic;

import

org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

剩余23页未读，继续阅读

评论收藏

内容反馈

资源评论

资源反馈

评论星级较低，若资源使用遇到问题可联系上传者，3个工作日内问题未解决可申请退款~

坚守己心

粉丝: 10
资源: 2

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

SpringBoot整合ActiveMQ+websocket.docx

spring boot+websocket

websocket和springboot整合实例

spring websocket在springboot中使用

springboot整合websocket相关操作

SpringBoot+WebSocket Demo

WebSocket协议接收ActiveMQ

SpringBoot+ActiveMq+MQTT实现消息的发送和接收

webchat聊天室(websocket+activemq编写)

springboot集成websocket实现消息的主动推送

websocket在springboot+vue中的使用教程

springboot与ActiveMQ整合.docx

Spring整合ActiveMQ教程.docx

SpringBoot集成ActiveMQ实例详解.docx

SpringBoot整合ActiveMQ过程解析

SpringBoot整合ActiveMQ案列

spring boot webSocket

Springboot整合ActiveMQ,实现消息的发送接收功能源码

action-monitor:使用ActiveMq和Spring WebSocket的数据库操作监视器Spring Boot应用程序

spring boot+websocket前后端简单demo

使用WebSocket协议接收ActiveMQ消息

基于SpringBoot开发的ActiveMQ虚拟主题客户端（包含发布者和订阅者）

Spring Boot ActiveMQ连接池配置过程解析

SpringBoot使用JMS的小例子（ActiveMQ实现）

SpringBoot2整合Jms超级简单攻略(基于ActiveMQ)

SpringBoot整合Mybatis WebSocket

SpringBoot JMS(ActiveMQ) 使用实践.docx

springboot-websocket:SpringBoot整合WebSocket

SpringBoot整合quartz2.2.3自定义数据源和websocket通信

ActiveMQ 入门实战(3)--SpringBoot 整合 ActiveMQ（csdn）————程序.pdf

SpringBoot整合ActiveMQ消息队列和双向队列、点对点与发布订阅

最新资源