spring-PropertyPlaceholderConfiger读取属性概述spring在读取配置文件的时候,我们时常使用@Value注解来注入配置文件中的配置,在配置文件中也可以通过${}的方式来引用已经申明的配置,这是依靠Spring提供的PropertyPlaceholderConfigure来实现的。 PropertyPlaceholderConfigure调用流程PropertyPlaceholderConfigure的父类Propert 2019-06-03 spring
kafka参数使用producer参数producer发送消息到partition的过程: 客户端先将消息写入内存缓存, 多个消息形成一个个Batch, 然后send线程将多个Batch打包成一个request发送到kafka服务器上。 acksacks参数是用来确认消息是否发送成功的。 (1) acks=0 当acks设置为0时,producer只要将消息发送出去,还未写入leader partition当磁盘 2019-05-16 中间件 #kafka
redis基本应用redis中基本数据结构redis包含五种数据结构: string,list,hash,set,zset 容器类型通用规则list/set/hash/zset 这四种数据结构是容器型数据结构,它们共享下面两条通用规则: create if not exists 如果容器不存在,那就创建一个,再进行操作。 drop if no elements 如果容器里元素没有了,那么立即删除元素,释放内 2019-05-07 中间件 #redis
elastic-job失效转移和错过补偿elastic 失效转移如果一个任务节点宕机后,则一次任务调度期间,一部分数据将不会被处理,为了解决由于任务节点宕机引起任务一个调度周期的一次任务执行部分数据未处理,可以设置开启故障失效转移,将本次任务转移到其他正常的节点上执行。 失效转移也是通过监听器来处理的,在failoverListenerManager 失效转移监听器failoverListenerManager#start: 1234p 2019-04-27 中间件 #elastic-job
elastic-job分片流程从选主的流程中可以看到,ListenManager#startAllListeners会开启所有的监听器,分片的监听器是shardingListenManager 分片监听器shardingListenManager#start: 1234public void start() { addDataListener(new ShardingTotalCountChangedJobLi 2019-04-25 中间件 #elastic-job
elastic-job选主过程elastic job 选主过程分析elastic-job 选主elastic主从服务器共同构成任务调度的分片节点。 ElasticJob的主服务器的职责是根据当前存活的任务调度服务器生成分片信息,然后拉取属于该分片的任务数据执行任务。为了避免分片信息的不统一,ElasticJob必须从所有的调度服务器中选择一台为主服务器,由该台服务器统一计算分片信息,其他服务根据该分片信息进行任务调度。 作业 2019-04-23 中间件 #elastic-job
activeMQ的producer发送和consumer消费消息发送amq消息发送中同步和异步 同步发送: producer发送消息后,会一直阻塞知道broker反馈一个确认消息,表示broker已经处理了消息 异步发送: producer不需要等待broker的反馈,性能会高一些,但是可能出现消息丢失的情况 amq中默认的消息发送策略: 非持久化的消息都是异步发送的 持久化消息在非事务模式下是同步发送的 在开启事务的情况下,消息都是异步发送 消息发 2019-04-22 中间件 #mq