发布了文章2022-01-08
{代码...}
发布了文章2022-01-08
{代码...}
发布了文章2022-01-08
{代码...}
发布了文章2021-12-26
{代码...}
发布了文章2021-07-04
1.1:bootstrap.servers:默认值:空用于建立到Kafka群集的初始连接的主机/端口对的列表。客户机将使用所有服务器而不仅仅使用这里配置的节点。因为这些服务器地址仅用于初始化连接,并通过现有配置的来发现全部的kafka集群成员(集群随时会变化),所以此列表不需要...
发布了文章2021-05-30
Kafka是最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多副本的(replica),基于zookeeper协调的分布式消息系统,它的最大的特性就是可以实时的处理大量数据以满足各种需求场景:比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式...
发布了文章2021-05-06
Hbase数据库比较适用于写多读少的场景。其查询能力并不突出。 在使用Scan扫描表的时候,很容易踩坑。踩坑1:在表数据量偏大的情况下(比如上千万数据),执行scan提示60000ms的timeout,并且出现OOM。 分析: {代码...} {代码...} 在1.x版本: {代码...} 踩坑2:在进...
发布了文章2021-03-31
1: 安装:1.1:安装所需的软件包yum install -y yum-utils device-mapper-persistent-data lvm2
发布了文章2021-03-14
1:在客户端我们使用的是注解 @GlobalTransactional。会创建代理 GlobalTransactionScanner。在代理的初始化代码中,会进行TM和RM的初始化,代码如下:
发布了文章2021-03-12
一:seata-server端 1:在seata-server 中,在 Server 类的main方法中,创建 NettyRemotingServer 对象,并添加端口。该对象创建的时候,会创建netty中的三个重要对象: ServerBootstrap,BOSS线程选择器EventLoopGroup,工作线程选择器EventLoopGroup。代码如下:
发布了文章2021-03-03
seata的1.4.1版本已经发布,目前看到的最主要的变化如下: 1: 配置不需要使用registry.conf和file.conf了。而是可以通过Spring的配置参数配置。而且提供了默认值,只需要按照业务修改自己的配置即可。 2:DataSourceProxy 实例也不需要创建,seata会自动创建。
发布了文章2021-02-28
(1): 在试用seata的1.4.1版本的时候,日志中总有 "no available service found in cluster 'default', please make sure registry config correct and keep your seata server running" 这个异常日志打印。 在网上翻阅了一下资料,然而不得要领,于是自己翻阅源码,...
发布了文章2021-02-28
关注属性公共部分server端client端
发布了文章2021-02-27
1:ribbon是提供通过serviceId访问服务的能力,而且提供了负载均衡能力。在springcloud里面,有2个自动配置加载类 LoadBalancerAutoConfiguration 和 RibbonAutoConfiguration。LoadBalancerAutoConfiguration主要完成对 RestTemplate 对象的负载均衡访问,RibbonAut...
发布了文章2021-02-27
1:在 spring-cloud-netflix-core 的 spring.factories 里面有对EnableCircuitBreaker的配置
发布了文章2021-02-27
2.Hystrix说明官方文档[[链接]]hystrix是netflix开源的一个容灾框架,解决当外部依赖故障时拖垮业务系统、甚至引起雪崩的问题。2.1为什么需要Hystrix?在大中型分布式系统中,通常系统很多依赖(HTTP,hession,Netty,Dubbo等),在高并发访问下,这些依赖的稳定性与否对系...
发布了文章2021-01-28
{代码...}
发布了文章2021-01-28
Apache Curator是一个比较完善的ZooKeeper客户端框架,通过封装的一套高级API 简化了ZooKeeper的操作。Curator主要解决了三类问题:
发布了文章2021-01-23
学习者(learner),包括跟随者(follower)和观察者(bserver),follower用于接受客户端请求并想客户端返回结果,在选主过程中参与投票