公司的老员工很喜欢一种他们称之为“解耦”的做法： 先这么进行系统分析：把系统运行拆解为若干个环节，先执行A，再执行B，形成一个一个的步骤。 然后进行“解耦”：把每个环节变成一个服务，环节之间用 MQ 连接。环节衔接的输入输出数据形成协议规范。 “解耦”之后得到的好处是： 环节用MQ串联，当服务死掉后 ...
分类：
其他好文 时间：
2019-11-28 13:33:23
阅读次数：
81
docker快速安装kafka，zookeeper ，体验spring-boot-demo-mq-kafkaLinux先开放以下端口：2181 ，9092 搜索镜像 zookeeper ，kafkahttps://hub.docker.com/ 1.https://hub.docker.com/_/ ...
分类：
编程语言 时间：
2019-11-27 17:38:18
阅读次数：
65
Spring Cloud Stream 是消息中间件组件，它集成了 kafka 和 rabbitmq 。本篇文章以 Rabbit MQ 为消息中间件系统为基础，介绍 Spring Cloud Stream 的使用。如果你没有用过消息中间件，可以到 RabbitMQ 的官网看一下，或者参考这个 htt ...
分类：
编程语言 时间：
2019-11-25 18:37:44
阅读次数：
69
MQ消息事务 RocketMQ 先说说MQ的分布式事务，RocketMq在4.3版本已经正式宣布支持分布式事务，在选择Rokcetmq做分布式事务请务必选择4.3以上的版本。 事务消息作为一种异步确保型事务， 将两个事务分支通过 MQ 进行异步解耦，RocketMQ 事务消息的设计流程同样借鉴了两阶 ...
分类：
其他好文 时间：
2019-11-23 16:42:17
阅读次数：
79
最近我们有个服务经常出现存储的数据出现重复，首先上一个系统流程图： 用户通过http请求可以通知任务中心结束掉自己发送的任务，这时候任务中心会通过MQ通知结束服务去结束任务保存数据，由于任务结束数据计算保存有一定延时，所以存在用户短时间内多次结束同一个任务，这时候就会导致我们结束服务对同一个任务保存 ...
分类：
其他好文 时间：
2019-11-22 19:22:45
阅读次数：
80
RabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。它遵循Mozilla Public License开源协议，采用Erlang语音实现的工业级的消息队列(MQ)服务器，Rabbi MQ是建立在Erlang OTP平台上，所以安装需要先安装Erlang语言包。 RabbitM ...
分类：
其他好文 时间：
2019-11-22 16:41:00
阅读次数：
119
数据源Source RPC异构流数据交换 Avro Source Thrift Source 文件或目录变化监听 Exec Source Spooling Directory Source Taildir Source MQ或队列订阅数据持续监听 JMS Source SSL and JMS Sou ...
分类：
Web程序 时间：
2019-11-22 10:48:12
阅读次数：
84
生产者代码 package com.active.mq.service; import javax.jms.Destination; /** * 消息生产 * * @author kql * */ public interface ProducerService { /** * 使用指定消息队列发送 ...
分类：
编程语言 时间：
2019-11-21 18:36:36
阅读次数：
83
Rabbit MQ 的初步使用 一、先来说说 Java 代码中的初步集成吧 0. 业务场景模拟 1. 在默认的虚拟主机（virtual host） 下，创建一个名为 的`Topic`类型的交换机（exchange），并设置其属性为不持久化（durable）、不自动删除（autoDelete）。 2. ...
分类：
其他好文 时间：
2019-11-20 21:41:52
阅读次数：
74
一、消息队列概述消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ 二、消息队列应用场景以下介绍消息队列在 ...
分类：
其他好文 时间：
2019-11-20 19:18:21
阅读次数：
62
