Elastic8.7集群搭建（搭建elk集群）

ELK（elasticsearch+kibana）

根据操作系统选择需要的安装包

这里以windows为例（版本是8.7.1）,Linux的操作是一致的

下载压缩包，解压，先说明一下文件目录

bin:可执行程序，包括elasticsearch启动程序也在这个目录

config：配置文件，包括jvm的配置

data:数据存储的目录，该目录会在启动的时候自动生成

jdk：因为es是用java开发的，如果本机安装的jdk版本不支持当前的es的版本，那么使用该目录下的

logs：日志目录,必须有

modules:es的一些模块

plugins：插件存放的目录，初始是空的

修改es的配置，主要修改下面这几个配置项

elasticsearch.yml

#集群名称
cluster.name: my-application
#节点的名字
node.name: node-1
#节点的端口
http.port: 9201

jvm的配置，主要是修改一下内存占用，默认是4G，可以根据业务的需要，自行配置，这里设置为512mb。

jvm.options

################################################################
## IMPORTANT: JVM heap size
################################################################
##
## The heap size is automatically configured by Elasticsearch
## based on the available memory in your system and the roles
## each node is configured to fulfill. If specifying heap is
## required, it should be done through a file in jvm.options.d,
## which should be named with .options suffix, and the min and
## max should be set to the same value. For example, to set the
## heap to 4 GB, create a new file in the jvm.options.d
## directory containing these lines:
##
-Xms512m
-Xmx512m

启动

启动第一个节点，以独立节点的方式启动（-d后台执行）

.\elasticsearch -d

获取一下elastic的密码，后面可以用于登录kibana

.\elasticsearch-reset-password -u elastic

如果出现错误，重置可以通过下面的步骤实现

1、删掉config/elasticsearch.keystore、config/certs文件夹

2、config/elasticsearch.yml从

#----------------------- BEGIN SECURITY AUTO CONFIGURATION -----------------------开始，后面的全部删除

3、删除data目录

获取一下加入集群的token

 .\elasticsearch-create-enrollment-token -s node

这个是jwt的token，可以解码看一下里面的内容，可以看到token里面包含了主节点的ip和端口信息。

把一个新节点加入到集群，拷贝上一步获取到的token

.\elasticsearch --enrollment-token eyJ2ZXIiOiI4LjcuMSIsImFkciI6WyIxNzIuMTguMC44NDo5MjAxIl0sImZnciI6IjFhNzUwYjFhMDI3YTAyN2M3NTI0NzQxMjM2NmM5OWRhYTM2YjY2M2Q4NzdlYjY5NDk3MWY5Mzg1MzI0NTUxNjMiLCJrZXkiOiJzcHFOYjRnQlAtVVV6SHVXRjVWaDpmN2lUeS13VFRUQzViNnlEc0QzMVp3In0= -d

后续添加节点，均按这个步骤重复进行。

安装kibana

下载解压之后，到bin目录执行

打开http://localhost:5601/?code=391977，如果

直接通过http://localhost:5601打开，后面会要求输入验证，回到控制台，可以看到6位的验证码。

产生kibana的登录token

.\elasticsearch-create-enrollment-token -s kibana

token登录

用账号登录

登录之后，到控制台查看集群情况

.NET 使用ES(官方的例子)

using Elastic.Clients.Elasticsearch;
using Elastic.Transport;

var nodes = new Uri[]
{
    new Uri("https://localhost:9201"),
    new Uri("https://localhost:9202")
};

var pool = new StaticNodePool(nodes);

var settings = new ElasticsearchClientSettings(pool)
.CertificateFingerprint("1A:75:0B:1A:02:7A:02:7C:75:24:74:12:36:6C:99:DA:A3:6B:66:3D:87:7E:B6:94:97:1F:93:85:32:45:51:63")
 .Authentication(new BasicAuthentication("elastic", "9JUjqtpWdIXaqFP5Sn_P"));

  
var tweet = new Tweet 
{
    Id = 1,
    User = "stevejgordon",
    PostDate = new DateTime(2009, 11, 15),
    Message = "Trying out the client, so far so good?"
};
var client=new ElasticsearchClient(settings);
var response = await client.IndexAsync(tweet, "my-tweet-index"); 

if (response.IsValidResponse) 
{
    Console.WriteLine(#34;Index document with ID {response.Id} succeeded."); 
}
else{
    Console.WriteLine("err:"+response.ElasticsearchServerError);
}

public class Tweet
{
    public int Id { get; set; } 
    public string User { get; set; }
    public DateTime PostDate { get; set; }
    public string Message { get; set; }
}

产生CertificateFingerprint

asp.net core

public static class ElasticsearchExtensions
{
    public static void AddElasticsearch(this IServiceCollection services, IConfiguration configuration)
    {
        var url = configuration["elasticsearch:url"];
        var defaultIndex = configuration["elasticsearch:index"];
 
 
        var settings = new ConnectionSettings(new Uri(url))
            .DefaultIndex(defaultIndex);
 
 
        AddDefaultMappings(settings);
 
 
        var client = new ElasticClient(settings);
 
 
        services.AddSingleton(client);
 
 
        CreateIndex(client, defaultIndex);
    }
 
 
    private static void AddDefaultMappings(ConnectionSettings settings)
    {
        settings
            DefaultMappingFor<Product>(m => m
                .Ignore(p => p.Price)
                .Ignore(p => p.Quantity)
                .Ignore(p => p.Rating)
            );
    }
 
 
    private static void CreateIndex(IElasticClient client, string indexName)
    {
        var createIndexResponse = client.Indices.Create(indexName,
            index => index.Map<Product>(x => x.AutoMap())
        );
    }
}