elasticsearch-3
timeout = {TimeValue@8576} “30s”masterNodeTimeout = {TimeValue@8463} “1m”
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172public class A ...
elasticsearch-3
org.elasticsearch.action.bulk.TransportBulkAction#createIndex12345678910public class a{//创建索引 void createIndex(String index, TimeValue timeout, ActionListener<CreateIndexResponse> listener) { CreateIndexRequest createIndexRequest = new CreateIndexRequest(); createIndexRequest.index(index); createIndexRequest.cause("auto(bulk api)"); createIndexRequest.masterNodeTimeout(timeout); createIndexAction.execute(createIndexRequest, listener ...
elasticsearch数据写入
https://elasticsearch.cn/article/13533
写入入口 RestIndexAction
参数
简介
version
设置文档版本号。主要用于实现乐观锁
version type
默认为internal,请求参数指定的版本号与存储的文档版本号相同则写入。其他可选值有external等类型,为external类型时,如果当前存储的文档版本号小于请求参数指定的版本号,则写入数据。version type主要控制版本号的比较机制,用于对文档进行并发更新操作时同步数据
op type
可设置为create,代表仅在文档不存在时才写入。如果文档已存在,则写请求将失败
routing
ES默认使用文档ID进行路由,指定routing可使用routing值进行路由
wait f ...
调试elasticsearch源码笔记
环境window10
版本7.11.2
源码下载https://github.com/elastic/elasticsearch.git
git@github.com:elastic/elasticsearch.git
二进制包下载https://www.elastic.co/cn/downloads/elasticsearch
下载jdk不同版本的es要求对应的jdk版本不一样,当前版本至少要jdk15,可参考以下编译文档
https://github.com/elastic/elasticsearch/blob/master/CONTRIBUTING.md
gradle 配置可以参考网上教程,我偷懒不想配置了,打开源码让他自行下载gradle,包下载嫌慢下载路径可以改到阿里云,都不配的情况下,可能要等1,2小时
build打开idea,要求2020.1版本,版本要求同样参考上面的编译文档,我是使用 project from version contr ...
极客时间-Redis核心技术与实战笔记
服务器初始化主流程(见图9-2) 可以简要分为7个步骤: ①初始化配置, 包括用户可配置的参数, 以及命令表的初始化; ②加载并解析配置文件; ③初始化服务端内部变量, 其中就包括数据库; ④创建事件循环eventLoop; ⑤创建socket并启动监听; ⑥创建文件事件与时间事件;⑦开启事件循环。 下面详细介绍步骤①~步骤④, 至于步骤⑤~步骤⑦将会在9.2.2节介绍
高性能主线,包括线程模型、数据结构、持久化、网络框架;高可靠主线,包括主从复制、哨兵机制;高可扩展主线,包括数据分片、负载均衡
Redis 能够在实际业务场景中得到广泛的应用,就是得益于支持多样化类型的 value
一般而言,内存键值数据库(例如 Redis)采用哈希表作为索引,很大一部分原因在于,其键值数据基本都是保存在内存中的,而内存的高性能随机访问特性可以很好地与哈希表O(1) 的操作复杂度相匹配。
一方面,这是因为它是内存数据库,所有操作都在内存上完成,内存的访问速度本身就很快。另一方面,这要归功于它的数据结构
为了实现从键到值的快速访问,Redis 使用了一个哈希表来保存所有键值对
因为这个哈希表保存了所有的 ...
namesrv笔记
org.apache.rocketmq.namesrv.NamesrvStartup程序入口
定时任务1234567891011121314151617//定时扫描不可用的broker,同时删除不可用的broker,同时打印相关日志 this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() { @Override public void run() { NamesrvController.this.routeInfoManager.scanNotActiveBroker(); } }, 5, 10, TimeUnit.SECONDS); //定时将kv的配置信息输出到info日志中 this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() { ...
nacos注册中心集群笔记2
nacos 版本 1.4.1
DistroProtocol12345678910111213141516@Componentpublic class DistroProtocol { private void startDistroTask() { if (EnvUtil.getStandaloneMode()) { isInitialized = true; return; } startVerifyTask(); startLoadTask(); } private void startVerifyTask() { GlobalExecutor.schedulePartitionDataTimedSync(new DistroVerifyTask(memberManager, distroComponentHolder), distroConfig.getVeri ...
nacos注册中心集群笔记1
nacos 版本 1.4.1
ServerMemberManager集群管理类
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889@Component(value = "serverMemberManager")public class ServerMemberManager implements ApplicationListener<WebServerInitializedEvent> { private final NacosAsyncRestTemplate asyncRestTemplate = HttpClientBeanHolder .getNacosAsyncRestTemplate(Loggers.CORE); ...
nacos注册中心服务发现笔记
nacos 版本 1.4.1
客户端服务发现todo 目前没搞清楚哪里调用
搜索了下spring-cloud-starter-alibaba-nacos-discovery包会调用
12ListView<String> services = namingService().getServicesOfServer(1,Integer.MAX_VALUE, group);List<Instance> instances = namingService().selectInstances(serviceId, group,true);
那就重点看下以下两个方法
1234567891011121314151617181920212223242526272829@SuppressWarnings("PMD.ServiceOrDaoClassShouldEndWithImplRule")public class NacosNamingService implements NamingService { @Override public Li ...
nacos注册中心AP模式注册笔记
nacos 版本 1.4.1
客户端非持久化注册,AP模式引入下面包,启动时会自动注册,默认非持久化注册,使用AP方式
1234567891011<dependencies> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency></dependencies>
NacosNamingService ...
