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

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

SpringBoot整合ActiveMQ+websocket.docx

activemq

springboot

stomp.js

需积分: 50 14 下载量 136 浏览量 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

SpringBoot整合Mybatis WebSocket

SpringBoot整合ActiveMQ案列

springboot整合websocket相关操作

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

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

WebSocket协议接收ActiveMQ

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

webchat聊天室(websocket+activemq编写)

基于RocketMQ的MQTT消息推送服务器分布式部署方案.pdf

SpringBoot+WebSocket Demo

springboot整合mybatis+plus+avtiveMq+redis

springboot-nettysocketio +netty+activeMq在线客服系统

SpringBoot集成ActiveMQ实例详解.docx

Springboot+websocket 实现多人聊天室/单人聊天

springboot+websocket聊天室（多人聊天，单人聊天）

spring boot+websocket前后端简单demo

SpringBoot集成ActiveMQ+swagger2

php 版本 activemq+stomp.php

springboot整合activemq 消费者 ACK手动确认 &消息重发

SpringBoot + activeMQ.zip

springboot整合mybatis+activemq（activemq可以去官网下载 ）

Spring Boot + WebSocket + 广播式

springBoot2.0整合webSocket 服务器主动推送数据到前端,并且弹框提示带有音乐提醒

websocket和springboot整合实例

SpringBootwebSocket 消息发送与接收

VUE+SpringBoot实现WebSocket双工通信

最新资源

springboot整合mybatis+activemq（activemq可以去官网下载）