1. Zookeeper的基本操作 zookeeper中的节点可以持久化/有序的两个维度分为四种类型： PERSIST：持久化无序（保存在磁盘中） PERSIST_SEQUENTIAL：持久化有序递增 EPHEMERAL：非持久化的无序的，保存在...
1. Zookeeper的基本操作 zookeeper中的节点可以持久化/有序的两个维度分为四种类型： PERSIST：持久化无序（保存在磁盘中） PERSIST_SEQUENTIAL：持久化有序递增 EPHEMERAL：非持久化的无序的，保存在...
1. 添加依赖 pom.xml如下： <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>......
1. 事务消息原理图 RocketMQ除了支持普通消息，...以上是百度百科的解释，简单的说，就是一次大的操作由不同的小操作组成，这些小的操作分布在不同的服务器上，且属于不同的应用，分布式事务需要保证这些小操...
1. 添加依赖 spring 提供了对JMS的支持，需要添加Spring支持jms的包和Spring的核心包，如下： <dependency> <groupId>org.apache.activemq</groupId> .../artifact...
1. 启动多个Broker 在win10下同一台服务器启动多个Broker, 步骤如下： 1.... 2.... 3.修改数据存放的名称，如下： 4. 修改所有的transportConnectors端口，都要跟之前的不一样 ...
1. 什么Docker? Docker是一个能把开发的应用程序自动部署到容器的引擎，... 在2013年初由dotCloud开发的基于Apache 2.0 开源授权协发行的引擎。提供一个轻量高效的应用测试，部署环境。 2. Docker的目标 ... 1....
1. 概念 Producer端重试： 生产者端的消息失败，也就是Producer往MQ上发消息没有发送成功，比如网络抖动导致生产者发送消息到MQ失败。这种消息失败重试我们可以手动设置发送失败重试的次数。...
只有以上两个条件都满足情况下，才能认为消息是“Exactly Only Once”，而要实现以上两点，在分布式系统环 境下，不可避免要产生巨大的开销。所以RocketMQ 为了追求高性能，并不保证此特性，要求在业务上进行...
临界区是用来表示一种公共的资源（共享数据），它可以被多个线程使用，但是在每次只能有一个线程能够使用它，当临界区资源正在被一个线程使用时，其他的线程就只能等待当前线程执行完之后才能使用该临界区资源。...
前言： 上一节中，我们使用Hystrix Dashboard，只能看到单个应用内的... 作用：汇总系统内的多个服务的数据并显示到Hystrix Dashboard上。 1. 新建Turbine项目 添加依赖，pom文件 <dependency> ...
Broker:相当于一个ActiveMQ服务器实例，在实际的开发中我们可以启动多个Broker. 命令行启动参数示例如下： 1. activemq start 使用默认的activemq.xml来启动。 2. activemq start xbean:file../conf/... 3....
1. 顺序消息原理图 2. 什么是顺序消息？ 消费消息的顺序要求同发送消息的顺序一致，在RocketMQ中，主要指的是局部顺序，即一类消息为满足顺序性，必须Producer单线程顺序发送，并且发送给到同一队列，这样...
1. JMS 的基本概念 1. JMS是什么？ JMS Java Message Service,Java消息服务，是Java EE中的一种技术。 2.... JMS定义了Java中访问消息中间件的接口，并没有给予实现，实现JMS接口的消息中间件称为JMS ...
1. Eureka监控配置 Eureka的客户端需要加入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artif...
1. 什么是RocketMQ？ 是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点。 Producer、Consumer、队列都可以分布式。 Producer 吐一些队列轮流収送消息，队列集合称为Topic，...
在前面学习ActiveMQ时，看到ActiveMQ可以是队列消息模式，也可以是订阅发布模式。 同样，在RocketMQ中，也存在两种消息模式，即是集群消费模式和广播消费模式。 1. 集群消费模式 跟AciiveMQ一样，当存在多个...
今天介绍三种配置文件手动取值的方式： springboot配置文件信息保存在application.properties中，默认可以spring.开头的进行spring进行一些常用参数的配置，但是很多时候我们需要手动配置一些配置，这就需要我们...
而AMQP协议则是指：即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息...
IP Multicast是一个被用于网络中传输数据到其他一组接收者的技术。 Ip muiticast传统的概念称为组地址，组地址是ip地址在ActiveMQ broker使用multicast协议去建立服务与远程的broker的服务的网络...
1. 消息接收确认 JMS消息只有在被确认之后，才认为已经被成功的消费了，消息成功消费通常包含三个阶段：客户接收消息，客户处理消息和消息被确认。 在事务性会话中，当一个事务被提交的时候，确认自动发生。...
Swagger 是一个规范和完整的框架，用于生成，描述，调用和可视化RESTful风格的web服务 ... Springfox的前身是swagger-springmvc,是一个开源的API doc框架，可以将我们的Controller接口的方法以文档的形式展现，基于...
前面所有的线程都是独立运行的，几个线程之间只会存在竞争锁和资源的管理，但是在多线程的环境下可能会需要多个线程同时协作完成，当某个线程执行一定操作之后，需要其他线程的帮助才能执行完成，此时该线程该如何...