Zookeeper(2)---节点属性、监听和权限

之前通过客户端连接之后我们已经知道了zk相关的很多命令(Zookeeper(1) 初识)。 节点属性: 现在我们就通过stat指令来看看节点都有哪些属性,或者使用get 指令和-s参数来查看节点数据以及属性 abc 节点数据 cZxid = 0x5 创建节点的事务ID ctime = Sat Oct ... »

Zookeeper(1)---初识

一.ZK简述 Zookeeper,它是一个分布式程序的协调服务,它主要是用来解决分布式应用中的一些数据管理问题,比如集群管理,分布式应用配置,分布式锁,服务注册/发现等等。 它是一个类似于文件系统的树状结构。每个目录被称为znode,可以删除目录,添加子目录这些操作,不同的是每个znode上面都是存 ... »

RocketMQ(1)---架构原理及环境搭建

一、架构简述 RocketMQ阿里开源的一个分布式消息传递和流媒体平台,具有低延迟,高性能和可靠性, 万亿级容量和灵活的可伸缩性。跟其它中间件相比,RocketMQ的特点是纯JAVA实现,在发生宕机和其它故障时消息丢失率更低。 它由四个部分组成:nameserver,broker,生产者和消费者。它 ... »

RabbitMQ(2)---高级使用

1.ack和限流 ack也就是消息确认签收,分为自动签收和手动签收。之前的交换机demo中:channel.basicConsume(queueName,true, consumer); 第二个参数就是自动签收,如果我们要手动签收则需要改成false,再去消息处理中手动签收即可 当我们消息队列中已经 ... »

RabbitMQ 高级应用

本文是作者原创,版权归作者所有.若要转载,请注明出处. 本文RabbitMQ版本为rabbitmq-server-3.7.17,erlang为erlang-22.0.7.请各位去官网查看版本匹配和下载,也可以留言,我发安装包 过期时间TTL(Time To Live) 过期时间TTL表示可以对消息设 ... »

RabbitMQ--其他几种模式

本文是作者原创,版权归作者所有.若要转载,请注明出处. 本文RabbitMQ版本为rabbitmq-server-3.7.17,erlang为erlang-22.0.7.请各位去官网查看版本匹配和下载,也可以留言,我发安装包 首先我们看一下官网的图 上篇文章中我们介绍了第一个简单模式,本文我们来介绍 ... »

RabbitMQ安装(centos7)

本文是作者原创,版权归作者所有.若要转载,请注明出处. 本文RabbitMQ版本为rabbitmq-server-3.7.17,erlang为erlang-22.0.7.请各位去官网查看版本匹配和下载,也可以留言,我发安装包 1.安装依赖环境: yum install gcc yum install ... »

RocketMQ安装及入门

本文是作者原创,版权归作者所有.若要转载,请注明出处. 本文RocketMQ版本为rocketmq-all-4.7.0,系统为win10.请各位去官网下载,也可以留言,我发安装包 RocketMQ安装 (前置条件为已安装java并配置JAVA_HOME) 1.配置环境变量 2.切换到安装目录的bin ... »

配置单机Kafka

部署单机版的kafka消息队列,参考了网上很多的教程,发现网上的教程不是很详细,特别是kafak的配置文件相关的,于是自己搭建完成之后,重新整理并标注了配置文件。 ... »

Rabbitmq 延迟队列,消息延迟推送

[TOC] 应用场景 目前常见的应用软件都有消息的延迟推送的影子,应用也极为广泛,例如: + 淘宝七天自动确认收货。在我们签收商品后,物流系统会在七天后延时发送一个消息给支付系统,通知支付系统将款打给商家,这个过程持续七天,就是使用了消息中间件的延迟推送功能。 + 12306 购票支付确认页面。我们 ... »

kafka基础介绍

kafka基础介绍 一、kafka介绍 1.1主要功能 根据官网的介绍,kafka是一个分布式流媒体的平台,它主要有三大功能: 1.11:It lets you publish and subscribe to streams of records 发布和订阅消息流,类似消息队列的的功能,这也是将其 ... »

RabbitMQ 消费端限流、TTL、死信队列

消费端限流 1. 为什么要对消费端限流 假设一个场景,首先,我们 Rabbitmq 服务器积压了有上万条未处理的消息,我们随便打开一个消费者客户端,会出现这样情况: 巨量的消息瞬间全部推送过来,但是我们单个客户端无法同时处理这么多数据! 当数据量特别大的时候,我们对生产端限流肯定是不科学的,因为有时 ... »

RabbitMQ 消息确认机制

[TOC] 生产端 Confirm 消息确认机制 消息的确认,是指生产者投递消息后,如果 Broker 收到消息,则会给我们生产者一个应答。生产者进行接收应答,用来确定这条消息是否正常的发送到 Broker ,这种方式也是消息的可靠性投递的核心保障! Confirm 确认机制流程图 如何实现Conf ... »

Kafka 详解(三)------Producer生产者

在第一篇博客我们了解到一个kafka系统,通常是生产者Producer 将消息发送到 Broker,然后消费者 Consumer 去 Broker 获取,那么本篇博客我们来介绍什么是生产者Producer。 1、生产者概览 我们知道一个系统在运行过程中会有很多消息产生,比如前面说的对于一个购物网站, ... »

Kafka 详解(一)------简介

在前面几篇博客我们介绍过一种消息中间件——RabbitMQ,本篇博客我们介绍另外一个消息中间件——Kafka,Kafka是由LinkedIn开发的,使用Scala编写,是一种分布式,基于发布/订阅的消息系统,在介绍 kafka 之前,我们首先需要知道为什么会诞生 kafka 。 1、kafka的诞生 ... »

RocketMQ——角色与术语详解

原文地址:http://jaskey.github.io/blog/2016/12/15/rocketmq-concept/ RocketMQ——角色与术语详解 2016-12-15 THU 15:48 RocketMQ中有很多概念,其中包括一些术语和角色。 理清楚基本的概念能有效的帮助理解Rock ... »