1.kafka概述##1.1kafka简介ApacheKafka是一个快速、可扩展的、高吞吐的、可容错的分布式“发布-订阅”消息系统,使用Scala与Java语言编写,能够将消息从一个端点传递到另一个端点,较之传统的消息中间件(例如ActiveMQ、RabbitMQ),Kafka具有高吞吐量、内置分区、支持消息副本和高容错的特性,非常适合大规模消息处理应用程序。Kafka官网:http://kaf
分类:
其他好文 时间:
2020-03-09 13:12:17
阅读次数:
58
RabbitMQ是基于AMQP的一款消息管理系统。AMQP(Advanced Message Queuing Protocol),是一个提供消息服务的应用层标准高级消息队列协议,其中RabbitMQ就是基于这种协议的一种实现。 常见mq: ActiveMQ:基于JMS RabbitMQ:基于AMQP ...
分类:
其他好文 时间:
2020-03-08 17:55:01
阅读次数:
83
1.什么是消息队列?消息队列,英文名message queue,简称MQ。MQ是一种应用程序对应用程序的通讯方法。消息队列是分布式应用中不可或缺的组件,主要解决应用解耦、异步消息、流量削峰等问题,实现高性能、高可用、可伸缩和最终一致性的架构。常用的有RabbitMQ、Kafka、ActiveMQ、R... ...
分类:
编程语言 时间:
2020-03-06 09:16:14
阅读次数:
83
MQ简介: MQ全称为Message Queue,消息队列(MQ)是一种应用程序的通信方法。应用程序通过写和检索出入列的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技 ...
分类:
其他好文 时间:
2020-03-01 20:14:44
阅读次数:
97
点对点(P2P) 结构 创建生产者和消费者两个springboot工程 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId ...
分类:
编程语言 时间:
2020-03-01 20:14:24
阅读次数:
90
为什么要进行持久化 为了避免MQ服务器意外宕机导致数据丢失,需要做到重启后没有被消费的数据依然在消息队列中。 ActiveMQ的持久化机制包含: 1. JDBC:持久化到数据库 2. AMQ:日志文件 3. KahaBD:AMQ基础上改进,默认选择 4. LevelDB:谷歌K/V数据库 注:Act ...
分类:
其他好文 时间:
2020-03-01 20:12:10
阅读次数:
122
SpringBoot整合ActiveMQ 点对点(P2P) 创建springboot项目 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</a ...
分类:
编程语言 时间:
2020-03-01 20:05:04
阅读次数:
66
ActiveMQ消息签收机制: 客户端成功接收一条消息的标志是一条消息被签收,成功应答。 消息的签收请求分为两种: 1.带事务的session 如果session带有事务,并且事务成功提交,则消息被自动签收。如果事务回滚,则消息会被再次传送。 2.不带事务的session 不带事务的session的 ...
分类:
其他好文 时间:
2020-03-01 19:44:37
阅读次数:
58
实现点对点通讯模式 1.导入依赖 <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.7.0</version> </dependency> 2.创 ...
分类:
其他好文 时间:
2020-03-01 19:31:09
阅读次数:
69
一、消息中间件的产生的背景 1.在网络通讯中,Http请求默认采用同步请求方式,基于请求与响应模式 2.在客户端与服务器进行通讯时,客户端调用服务端接口后,必须等待服务端完成处理后返回结果给客户端才能继续执行,这种情况属于同步调用方式。 3.如果服务器端发生网络延迟、不可达的情况,可能客户端也会受到 ...
分类:
其他好文 时间:
2020-03-01 12:08:52
阅读次数:
101