1、背景引入:很多同学看不懂kafka参数 今天给大家聊一个很有意思的话题,大家知道很多公司都会基于Kafka作为MQ来开发一些复杂的大型系统。 而在使用Kafka的客户端编写代码与服务器交互的时候,是需要对客户端设置很多的参数的。 所以我就见过很多年轻的同学,可能刚刚加入团队,对Kafka这个技术 ...
分类:
其他好文 时间:
2019-05-20 17:15:39
阅读次数:
103
一、消息队列概述消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ 二、消息队列应用场景以下介绍消息队列在 ...
分类:
其他好文 时间:
2019-05-19 23:31:29
阅读次数:
260
1.安装运行环境 erlang rpm -Uvh http://www.rabbitmq.com/releases/erlang/erlang-18.1-1.el7.centos.x86_64.rpm 2.安装 rabbitmq-server rpm -Uvh http://www.rabbitmq ...
分类:
其他好文 时间:
2019-05-18 15:47:11
阅读次数:
130
package com.mq; import java.util.Arrays; import java.util.HashMap; import java.util.Map; public enum ChannelEnum { WEBB("15","威客巴巴"), CMM("19","菜嬷嬷");... ...
分类:
其他好文 时间:
2019-05-14 19:23:20
阅读次数:
209
本篇将介绍RabbitMq的一个简单使用例子,分别介绍生产者如何发送消息,消费者如何接收和处理消息 关于RabbitMQ的知识背景的文章非常多。我对它的总结是,解决高并发请求的瓶颈,将应用程序真正处理请求的担子推送给一个处理消息的中心,以减轻应用程序本身处理请求的压力。 这个处理中心也即Rabbit ...
分类:
其他好文 时间:
2019-05-11 18:22:23
阅读次数:
142
RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链 ...
分类:
其他好文 时间:
2019-05-11 00:04:41
阅读次数:
197
背景 电商中有这样的一个场景: 1. 下单成功之后送积分的操作,我们使用mq来实现 2. 下单成功之后,投递一条消息到mq,积分系统消费消息,给用户增加积分 我们主要讨论一下,下单及投递消息到mq的操作,如何实现?每种方式优缺点? 方式一 step1:start transaction step2: ...
分类:
其他好文 时间:
2019-05-05 15:59:08
阅读次数:
142
为什么要使用MQ消息中间件?它解决了什么问题?关于为什么要使用消息中间件?消息中间件是如何做到同步变异步、流量削锋、应用解耦的?网上已经有很多说明,我这里就不再说明了,读者可以参考(https://www.jianshu.com/p/2820561158c4)。我在接下来的RabbitMq系列博客里 ...
分类:
其他好文 时间:
2019-04-27 23:58:08
阅读次数:
264
1. 分类: 获取消息方式:A. push(推)方式:优点——可以尽可能快地将消息发送给消费者,缺点——如果消费者处理能力跟不上,消费者的缓冲区可能会溢出; B. pull(拉)方式:优点——消费端可以按处理能力进行拉去,缺点——会增加消息延迟; 能否重复消费:A. 点对点(Queue):不可重复消 ...
分类:
其他好文 时间:
2019-04-27 19:33:17
阅读次数:
177
数据库事务: ACID 分布式理论: CAP定理 BASE理论 分布式事务解决方案: 两阶段提交(2PC) 补偿事务(TCC) 本地消息表(异步确认) MQ事务消息 https://www.cnblogs.com/savorboard/p/distributed-system-transaction ...
分类:
其他好文 时间:
2019-04-27 13:29:34
阅读次数:
137