-
kafka原理和实践(五)spring-kafka配置详解
目录 一、官方配置 二、实践中的配置 1、生产者配置 2、消费者配置 使用规范 正文 系列目录 kafka原理和实践(一)原理:10分钟入门 kafka原理和实践(二)spring-kafka简单实践 kafka原理和实践(三)spring-kafka生产者源码 kafka原理和实践(四)spring-kafka消费者源码 kafka原理和实践(五)spring-kafka配置详解 kafka…- 7
- 0
-
Kafka、RabbitMQ、RocketMQ等消息中间件的对比 —— 消息发送性能和区别
Kafka、RabbitMQ、RocketMQ等消息中间件的对比 —— 消息发送性能和区别 那么,消息中间件性能究竟哪家强? 带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做了性能比较。 Kafka是 LinkedIn开源的分布式发布-订阅消息系统 ,目前归属于Apache顶级项目。Kafka主要特点是 基于Pull的模式来处理消息消费,追求高…- 15
- 0
-
kafka读写速度快的原因
KAFKA是分布式发布-订阅消息系统,是一个分布式的,可划分的,冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。 现在被广泛地应用于构建实时数据管道和流应用的场景中,具有横向扩展,容错,快等优点,并已经运行在众多大中型公司的生产环境中,成功应用于大数据领域,本文分享一下我所了解的KAFKA。 【KAFKA高吞吐率性能揭秘】 KAFKA的第一个突出特定就是“快”,而且是那种变态的“…- 3
- 0
-
Flume+Kafka+SparkStreaming整合
SparkStream整合Flume&Kafka打造通用的流处理平台 整个流程如图所示: 使用下面这段简单的代码模拟日志产生: 1import org.apache.log4j.Logger; 2 3/** 4 * Created by Zhaogw&Lss on 2019/11/27. 5 */ 6public class LoggerGenerator { 7 private …- 3
- 0
-
Docker下RabbitMQ四部曲之二:细说RabbitMQ镜像制作
本章是《Docker下RabbitMQ四部曲》系列的第二篇,将详细简述Docker下制作RabbitMQ镜像的技术细节,包括以下内容: 列举制作RabbitMQ镜像时用到的所有材料; 编写Dockerfile; 编写容器启动时执行的脚本startrabbit.sh; 单机版RabbtiMQ环境的docker-compose.yml说明; 集群版RabbitMQ环境的docker-compose.y…- 4
- 0
-
.Net下RabbitMQ的使用(7) — 远程过程调用RPC
RPC是在计算中是一种常见的模式,是通常我要用消息队列来实现RPC有3个关键点: 服务的寻址 消息的接收 消息的关联 在RabbitMQ的.net客户端里,提供了2个类:SimpleRpcClient 和 SimpleRpcServer 来让我们方便的开发RPC应用。 因为RabbitMQ的RPC一定是基于队列的,所以在客户端和服务端都需要要一个各自的队列,客户端的队列用来接收服务回复的数据,服务…- 2
- 0
-
.Net下RabbitMQ的使用(1) — 初识RabbitMQ
1. 什么是RabbitMQ MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应用…- 9
- 0
-
RabbitMQ+HAProxy
原本打算直接用nginx反向代理,发现不好用,默认不支持长连接,见很多推荐HAProxy的,就试试吧~ [plain] wget http://haproxy.1wt.eu/download/1.4/src/haproxy-1.4.21.tar.gz tar -zxvf haproxy-1.4.21.tar.gz cd haproxy-1.4.21 make TARGET=linux26…- 3
- 0
-
Couchbase 中的分布式储存
概述 Couchbase 是一个具有高性能、可扩展性和可 用性强的数据库引擎。它可以让开发人员通过 NoSQL 的键值存储(二进制或者JSON)或者使用 N1QL 的形式对数据进行操作(N1QL 是非常类似于 SQL 的一种语法操作 JSON 数据的方式)。以现在整体架构来看,Couchbase 是往分布式数据库的方向发展下去。 分布式数据库一般是从单机关系数据库扩展而来,用于存储结构化数据。分布…- 11
- 0
-
分布式开放消息系统(RocketMQ)的原理与实践
分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件,需要具有高吞吐量、高可用等特点。而谈到消息系统的设计,就回避不了两个问题: 消息的顺序问题 消息的重复问题 RocketMQ作为阿里开源的一款高性能、高吞吐量的消息中间件,它是怎样来解决这两个问题的?RocketMQ 有哪些关键特性?其实现原理是怎样的? 关键特性以及其实现原理 一、顺序消息 消息有序指的是可以按照消息的发送顺序来消费。例…- 0
- 0
-
12. Dubbo原理解析-注册中心之基于dubbo协议的简单注册中心实现
基于dubbo协议开源只是给出了默认一个注册中心实现SimpleRegistryService, 它只是一个简单实现,不支持集群,就是利用Map<String/*ip:port*/, Map<String/*service*/, URL>来存储服务地址, 具体不在啰嗦了,请读者翻看源代码,可作为自定义注册中的参考。 注册中心启动 SimpleRegistryService本身也是…- 5
- 0
-
6. Dubbo原理解析-代理之Javassist生成的伪代码
下面我们以伪代码来展示下生成的代理类 比如我们要对如下接口生成代理 public interface DemoService { String sayHello(String name); String sayHelloAgain(Stringname); } 生成的代理对象 public class DemoService.proxy10001implements DemoS…- 5
- 0
-
JFinal 中使用 Dubbo —— 1 改造JFinal Demo
很多人认为,既然有了JFinal,为什么还要Spring。殊不知一些基于Spring的很牛X的东东集成到JFinal中能够事半功倍。比如Dubbo这个高性能优秀的服务框架,它基于Spring,于是JFinal提供的Spring插件就能更方便地将Dubbo集成进咱们的程序中,成为高大上的程序。 1. Dubbo Demo概述 此Demo实际在2014年上半年就已经完成了,只是到最近才有时间和心…- 6
- 0
-
多节点,多线程下发订单,使用zookeeper分布式锁机制保证订单正确接入oms系统
假设订单下发, 采用单机每分钟从订单OrderEntry接口表中抓100单, 接入订单oms系统中. 由于双十一期间, 订单量激增, 导致订单单机每分钟100单造成, 订单积压. 所以采用多节点多线程处理三方商家的订单接入系统. 流程图: 如图所示: 采用多节点, 多线程, 使用curator操作zk的方式实现, 订单的下发. 以前的方式每分钟下发100单, 之后采用现在的方式可以每分钟2000…- 5
- 0
-
Lua在Redis中的应用—分布式锁,限制访问次数
Lua在Redis中的应用—分布式锁,限制访问次数 Lua是一个高效的轻量级脚本语言。它是开源的,非常小巧,整个源码也才五百来K,可以很方便地嵌入到程序中(无论是桌面端还是移动端) 1.分布式锁 分布式锁可以用多种方式来实现常用为以下方式: 1、基于数据库表做乐观锁,用于分布式锁。 2、memcached 3、redis 4、zookeeper 我们本次只说一下redis(r2m)的实现方式,并由…- 4
- 0
-
ETCD分布式锁实现选主机制(Golang实现)
ETCD分布式锁实现选主机制(Golang) 为什么要写这篇文章 做架构的时候,涉及到系统的一个功能,有一个服务必须在指定的节点执行,并且需要有个节点来做任务分发,想了半天,那就搞个主节点做这事呗,所以就有了这篇文章的诞生,我把踩的坑和收获记录下来,方便未来查看和各位兄弟们参考。 选主机制是什么 举个例子,分布式系统内,好几台机器,总得分个三六九等,发号施令的时候总得有个带头大哥站出来,告诉其他小…- 38
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day08 页面静态化
文章目录 静态化优化方案设计 为什么要使用页面静态化 静态化好处 分析 静态页面生成时机 * 单体项目方案分析 * 集群项目架构分析 实现准备 数据库 * 生成代码 * 技术准备 * Fastdfs * Velocity 准备模板 1 * 准备前端页面 2 页面静态化的整体流程 后端代码 前端准备 静态化优化方案设计 为什么要使用页面静态化 课程主页的访问人数非常多, 以不发请求静态页面代替要发请…- 9
- 0
-
SpringBoot微服务 +tomcat集群+Ngnix负载均衡+Mysql主从复制,读写分离(1)
**一:SpringBoot微服务部署 ** 1.有两个maven的SpringBoot项目,一个是是base项目(放一些公共的代码与公共maven配置文件),一个是test(业务逻辑代码),也就是test依赖base项目,如下图: 2.在base项目的pom.xml配置文件中配置scope标签使得SpringBoot内嵌的tomcat向下没有传递性,如下图: …- 17
- 0
-
SpringBoot微服务 +tomcat集群+Ngnix负载均衡+Mysql主从复制,读写分离(4)
四:mysql主从复制,读写分离 1.首先把mysql源码包文件拷到两台linux服务器上,然后在两台服务器上安装Mysql数据库 1安装 MySQL 2 1 安装 ncurses 3 Ncurses 提供字符终端处理库,包括面板和菜单。它提供了一套控制光标,建立 4 窗口,改变前景背景颜色以及处理鼠标操作的函数。使用户在字符终端下编写应 5 用程序时绕过了那些恼人的底层机制。简而言之,他是一个可…- 6
- 0
-
微服务分布式事务实战(二)redis的安装与启动
Redis 的安装和启动 (1)下载redis 解压缩 (2) 启动和测试redis 1进入redis 目录 2双击redis-server.exe 程序即可启动 3 启动客户端测试 启动:双击redis-cli.exe 测试:输入命令 本篇博客视频地址: https://v.youku.com/v_show/id_XMzg5OTg1Njc3Mg==.html?spm=a2hzp.8244740.…- 4
- 0
-
ASP.NET Core微服务之开源事件总线CAP的初步使用
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、CAP简介 *下面的文字来自CAP的Wiki文档:*https://github.com/dotnetcore/CAP/wiki CAP 是一个在分布式系统中(SOA,MicroService)实现事件总线及最终一致性(分布式事务)的一个开源的 C# 库,她具有轻量级,高性能,易使用等特点。我们可以轻松的在基于 .NET Core …- 4
- 0
-
Spring Cloud构建微服务架构:服务注册与发现(Eureka、Consul)【Dalston版】
已经有非常长的时间没有更新《Spring Cloud构建微服务架构》系列文章了,自从开始写Spring Cloud的专题内容开始就获得了不少的阅读量和认可,当然也有一些批评,其中也不乏一些很中肯的意见和深度的问题,对我来说也是进一步提高的契机,在此感谢所有关注我博客的读者们。 由于之前主要精力都花在的编写《Spring Cloud微服务实战》一书上,所以该系列文章就没有得到持续的维护和更新。由于漫…- 0
- 0
幸运之星正在降临...
点击领取今天的签到奖励!
恭喜!您今天获得了{{mission.data.mission.credit}}积分
我的优惠劵
-
¥优惠劵使用时效:无法使用使用时效:
之前
使用时效:永久有效优惠劵ID:×
没有优惠劵可用!