-
kafka原理和实践（六）总结升华
目录 总结篇 1.官方介绍 2.特点 3.Kafka的设计 4.Kayka的应用场景 5.总结 正文 系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置…- 8
- 0
-
kafka原理和实践（一）原理：10分钟入门
目录 一、kafka拓扑图 二、名词解释 三、生产模型 四、消费模型 正文 系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置详解 kafka原理和实践…- 3
- 0
-
如何管理Spark Streaming消费Kafka的偏移量（一）
本篇我们先从理论的角度聊聊在Spark Streaming集成Kafka时的offset状态如何管理。 spark streaming 版本 2.1 kafka 版本0.9.0.0 在这之前，先重述下spark streaming里面管理偏移量的策略，默认的spark streaming它自带管理的offset的方式是通过checkpoint来记录每个批次的状态持久化到HDFS中，如果机器发生故障…- 18
- 0
-
rocketMq和kafka的架构区别
概述 其实一直想写一篇rocketMq和kafka在架构设计上的差别，但是一直有个问题没搞明白所以迟迟没动手，今天无意中听人点播了一下似乎明白了这个问题，所以就有了这篇对比。 这篇博文主要讲清楚kafka和rocketMq的两个不同点，1、rocketMq的namesvr和kafka的zookeeper对比；2、kafka为什么比rocketMq有更大的吞吐量。如果能够讲清楚上面两…- 10
- 0
-
Docker下RabbitMQ四部曲之三：细说java开发
本文是《Docker下RabbitMQ四部曲》系列的第三篇，实战两个基于SpringBoot的工程，分别用来生产和消费RabbitMQ消息； 本文内容简述 今天的实战由以下几部分组成： 开发SpringBoot工程rabbitmqproducer，用来生产消息； 分析docker-compose.yml中对rabbitmqproducer镜像的使用； 开发SpringBoot工程rabbitmqc…- 13
- 0
-
使用Zabbix监控RabbitMQ
一 应用场景描述 线上业务使用RabbitMQ作为消息队列中间件，那么作为运维人员对RabbitMQ的监控就很重要，本文就针对如何从头到尾使用Zabbix来监控RabbitMQ进行说明。 二 RabbitMQ监控要点 RabbitMQ官方提供两种方法来管理和监控RabbitMQ。 1.使用rabbitmqctl管理和监控 Usage: rabbitmqctl [-n <node>] […- 81
- 0
-
AMQP-RabbitMQ/1/概念/一对一简单模型
# JMS,AMQP,MQTT的区别与联系 JMS Java消息传递服务（Java Messaging Service ） AMQP 高级消息队列协议（Advanced Message Queueing Protocol ） MQTT 消息队列遥测传输（Message Queueing Telemetry Transport ） 简单理解： *JMS是专门为Java设计的一套消息服务API，像Ac…- 15
- 0
-
RabbitMQ消息队列（四）：分发到多Consumer（Publish/Subscribe）
上篇文章中，我们把每个Message都是deliver到某个Consumer。在这篇文章中，我们将会将同一个Message deliver到多个Consumer中。这个模式也被成为 "publish / subscribe"。 这篇文章中，我们将创建一个日志系统，它包含两个部分：第一个部分是发出log（Producer），第二个部分接收到并打印（Consumer）。 我们将构建…- 6
- 0
-
RabbitMQ安装
部署安装RabbitMQ前，先了解下基本概念：（RabbitMQ+Python入门经典] 兔子和兔子窝） RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连…- 22
- 0
-
rabbitMQ基础
目录 jar包 消息类型 简单模型Hello Word 工作队列模式Work Queue Round-robin （轮询分发） Fair dispatch （公平分发） 订阅 模式 Publish/Subscribe 路由模式 通配符模式Topic RabbitMQ 之消息确认机制（事务+Confirm ） 概述 事务机制 Confirm 模式 jar包 1<dependency&g…- 2
- 0
-
分布式与集群的区别是什么？
分布式：一个业务分拆多个子业务，部署在不同的服务器上 集群：同一个业务，部署在多个服务器上 单机结构 我想大家最最最熟悉的就是单机结构，一个系统业务量很小的时候所有的代码都放在一个项目中就好了，然后这个项目部署在一台服务器上就好了。整个项目所有的服务都由这台服务器提供。这就是单机结构。 那么，单机结构有啥缺点呢？我想缺点是显而易见的，单机的处理能力毕竟是有限的，当你的业务增长到一定程度的时候，单机…- 7
- 0
-
-
SpringBoot+zk+dubbo架构实践（一）：本地部署zookeeper
SpringBoot+zk+dubbo架构实践系列实现目标 本地部署zookeeper SpringBoot 集成 zookeeper Dubbo-admin管理平台安装 SpringBoot+ zookeeper +dubbo 框架搭建 架构业务实践（实现电商部分业务） 备注：本系列偏向于动手实践，不讲太多理论。 前言 本文操作都是在Mac上进行的，如果大家用的windows 可以相对应的进行修…- 1
- 0
-
JFinal 中使用 Dubbo —— 2 部署及运行
1. 部署及运行 1.1. 部署 请参见“ JFinal 教程 1部署应用到Tomcat的步骤讲得比较详细。部署后结构如下图： 可以看到， Consumer 和 Provider 都依赖 Api 项目。 1.2. 运行 Consumer 和 Provider 无论谁先启动都可以，输入 URL 后，可以看到 JFinal Demo 原装页面了： 查看管制台， Provider 输出…- 3
- 0
-
Dubbo的使用及原理浅析
Dubbo是什么？ Dubbo是阿里巴巴SOA服务化治理方案的核心框架，每天为2,000+个服务提供3,000,000,000+次访问量支持，并被广泛应用于阿里巴巴集团的各成员站点。 Dubbo[]是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。 其核心部分包含: 远程通讯: 提供对多种基于长连接的NIO框架抽象封装，包括多种线程模型，序列化，以及“…- 2
- 0
-
Java分布式锁之数据库方式实现
之前的文章《Java分布式锁实现》中列举了分布式锁的3种实现方式，分别是基于数据库实现，基于缓存实现和基于zookeeper实现。三种实现方式各有可取之处，本篇文章就详细讲解一下Java分布式锁之基于数据库的实现方式，也是最简单最易理解的实现方式。 首先，先来阐述下“锁”的概念，锁作为一种安全防御工具，既能上锁防止别人打开，又能让持有钥匙的人打开锁，这是锁的基本功能。那再来说一下“分布式锁”，分布…- 29
- 0
-
go-kit实践之1：go-kit 与 grpc 结合开发微服务（go-kit endpoint的使用）
go-kit 是一个微服务的开发工具集，微服务系统中的大多数常见问题，因此，使用者可以将精力集中在业务逻辑上。 grpc缺乏服务治理的功能，我们可以通过go-kit结合grpc来实现我们的完整需求。go-kit抽象的endpoint设计让我们可以很容易包装其它微服务框架使用的协议。 endpoint为Servers和Clients提供了基于RPC方法的构建模块。 先来看看endpoint源码： 1…- 9
- 0
-
SpringCloud微服务知识整理七：API网关服务：Spring Cloud Zuul
通过前几章形成的微服务基础架构： 在该架构中，我们的服务集群包含内部服务ServiceA和ServiceB, 它们都会向Eureka Server集群进行注册与订阅服务，而OpenService是一个对外的RESTfulAPI服务，它通过FS、 Nginx等网络设备或工具软件实现对各个微服务的路由与负载均衡，并公开给外部的客户端调用。 什么是API网关服务：Spring Cloud Zuul AP…- 22
- 0
-
SpringBoot微服务 +tomcat集群+Ngnix负载均衡+Mysql主从复制，读写分离（5）
1.启动两台tomcat服务器 在/usr/tomcat/bin/目录下 测试启动是否成功 2.启动ngnix服务器 执行 /usr/local/nginx/sbin/nginx -c /usr/local/nginx/conf/nginx.conf 命令 说明ngnix与tomcat配置成功 4.访问编辑好的静态资源 ，此处配置的地址为Ngnix的地址 然后Nginx会负载到相应的tomc…- 13
- 0
-
微服务架构核心技术二
微服务的利和弊 优势: 强模块化边界——期初使用类、组件和类库做模块化，而微服务以服务方式做模块化 可独立部署——每个团队独立开发和部署服务 技术多样性——每个团队可以自己擅长的技术栈，技术栈太多也有引入成本 弊端: 分布式复杂性——团队之间可能并不理解其他团队的具体工作 最终一致性——如果不同服务有关联数据，需要同步数据 运维复杂性——管理分布式系统，对容量、稳定性有挑战 测试复杂性——测试需要…- 0
- 0
-
ASP.NET Core微服务之基于MassTransit实现数据最终一致性（2）
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、案例结构与说明 在上一篇中，我们了解了MassTransit这个开源组件的基本用法，这一篇我们结合一个小案例来了解在ASP.NET Core中如何借助MassTransit+Quartz.Net来实现数据的最终一致性。当然，实现数据的最终一致性有很多方案，这里只是举一种我所学到的比较简单易于学习的实现方式而已。 假设我们有一个XX保…- 6
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×