Springboot+Activemq整合 1 导入整合所需要的依赖： <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </d ...
分类：
编程语言 时间：
2020-02-16 16:24:21
阅读次数：
73
1.生产者 1.1 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <!-- spring boot we ...
分类：
编程语言 时间：
2020-02-16 16:21:06
阅读次数：
85
ActiveMQ的消息事务 消息事务，是保证消息传递原子性的一个重要特性，和JDBC的事务特征类似。 一个事务性发送，其中一组消息要么能够全部保证到达服务器，要么都不到达服务器。生产者，消费者与消息服务器都支持事务性。ActiveMQ得事务主要偏向在生产者得应用。 ActiveMQ消息事务流程图： ...
分类：
其他好文 时间：
2020-02-16 12:38:59
阅读次数：
95
〇、什么是消息队列 参考：新手也能看懂，消息队列其实很简单 RabbitMQ运行模型与名词解释 一、应答模式 1.什么是应答？ 消息投递到交换器（exchange）中，交换器给我们的反馈，是保障消息投递成功的一种机制。 2.测试 配置： 1 #选择确认类型为交互 2 spring.rabbitmq. ...
分类：
编程语言 时间：
2020-02-15 23:39:01
阅读次数：
660
1.开启队列持久化 只需要添加三行代码 jmsTemplate.setDeliveryMode(2); jmsTemplate.setExplicitQosEnabled(true); jmsTemplate.setDeliveryPersistent(true); 2. 开启主题持久化,启动类添加 ...
分类：
编程语言 时间：
2020-02-15 22:06:07
阅读次数：
138
一、概述 1. 大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力 2. 消息服务中两个重要概念： 消息代理（message broker）和目的地（destination）当消息发送者发送消息以后，将由消息代理接管，消息代理保证消息传递到指定目的地。 3. 消息队列主要有两种形式的目 ...
分类：
编程语言 时间：
2020-02-15 22:05:36
阅读次数：
114
步骤一:创建一个数据库 步骤二：配置activemq.xml配置文件 1.在persistenceAdapter加入如下配置 <!--createTablesOnStartup 启动是否创建表 第一次为true 后续为false--> <jdbcPersistenceAdapter dataSour ...
分类：
数据库 时间：
2020-02-15 17:08:50
阅读次数：
118
消息持久化 消息持久化是保证消息不丢失的重要方式。 ActiveMQ提供了以下三种的消息存储方式： 1. Memory消息存储-基于内存的消息存储。 2. 基于日志消息存储方式，KahaDB是ActiveMQ的默认日志存储方式，它提供了容量的提升和恢复能力。 3. 基于JDBC的消息存储方式-数据存 ...
分类：
其他好文 时间：
2020-02-15 15:08:30
阅读次数：
67
消息队列的基本原理 消息队列是基于队列实现的，存储具有特定格式的消息数据。消息队列包括生产者，消息队列以及消费者。 RocketMQ的原理与工作机制 架构图 NameServer Cluster：名字服务器集群，类似于kafka中的zookeeper，提供分布式协调与管理的功能 Producer C ...
分类：
其他好文 时间：
2020-02-15 11:46:33
阅读次数：
63
点对点（P2P） 结构 创建生产者和消费者两个springboot工程 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId ...
分类：
编程语言 时间：
2020-02-14 20:21:17
阅读次数：
72
