有间博客

timeout = {TimeValue@8576} “30s”masterNodeTimeout = {TimeValue@8463} “1m” 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172public class A ...

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 ...

https://elasticsearch.cn/article/13533 写入入口 RestIndexAction 参数 简介 version 设置文档版本号。主要用于实现乐观锁 version type 默认为internal，请求参数指定的版本号与存储的文档版本号相同则写入。其他可选值有external等类型，为external类型时，如果当前存储的文档版本号小于请求参数指定的版本号，则写入数据。version type主要控制版本号的比较机制，用于对文档进行并发更新操作时同步数据 op type 可设置为create，代表仅在文档不存在时才写入。如果文档已存在，则写请求将失败 routing ES默认使用文档ID进行路由，指定routing可使用routing值进行路由 wait f ...

环境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 ...

服务器初始化主流程（见图9-2） 可以简要分为7个步骤： ①初始化配置， 包括用户可配置的参数， 以及命令表的初始化； ②加载并解析配置文件； ③初始化服务端内部变量， 其中就包括数据库； ④创建事件循环eventLoop； ⑤创建socket并启动监听； ⑥创建文件事件与时间事件；⑦开启事件循环。 下面详细介绍步骤①～步骤④， 至于步骤⑤～步骤⑦将会在9.2.2节介绍 高性能主线，包括线程模型、数据结构、持久化、网络框架；高可靠主线，包括主从复制、哨兵机制；高可扩展主线，包括数据分片、负载均衡 Redis 能够在实际业务场景中得到广泛的应用，就是得益于支持多样化类型的 value 一般而言，内存键值数据库（例如 Redis）采用哈希表作为索引，很大一部分原因在于，其键值数据基本都是保存在内存中的，而内存的高性能随机访问特性可以很好地与哈希表O(1) 的操作复杂度相匹配。 一方面，这是因为它是内存数据库，所有操作都在内存上完成，内存的访问速度本身就很快。另一方面，这要归功于它的数据结构 为了实现从键到值的快速访问，Redis 使用了一个哈希表来保存所有键值对 因为这个哈希表保存了所有的 ...

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 版本 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.4.1 ServerMemberManager集群管理类 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889@Component(value = "serverMemberManager")public class ServerMemberManager implements ApplicationListener<WebServerInitializedEvent> { private final NacosAsyncRestTemplate asyncRestTemplate = HttpClientBeanHolder .getNacosAsyncRestTemplate(Loggers.CORE); ...

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 版本 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 ...