WordPress与Elasticsearch整合2026

WordPress原生搜索：
SELECT * FROM wp_posts WHERE post_content LIKE '%keyword%'
→ 全表扫描（100万篇文章 → 5秒+）

Elasticsearch：
倒排索引（Inverted Index）
→ 100万篇文章 → < 100ms

# Ubuntu/Debian
sudo apt update
sudo apt install openjdk-17-jdk -y

# 验证
java -version
# 输出：openjdk 17.0.x

# 导入GPG密钥
wget -qO - https://artifacts.elastic.co/GPG-KEY-elasticsearch | sudo gpg --dearmor -o /usr/share/keyrings/elasticsearch-keyring.gpg

# 添加软件源
echo "deb [signed-by=/usr/share/keyrings/elasticsearch-keyring.gpg] https://artifacts.elastic.co/packages/8.x/apt stable main" | sudo tee /etc/apt/sources.list.d/elastic-8.x.list

# 安装
sudo apt update
sudo apt install elasticsearch -y

# 启动
sudo systemctl enable elasticsearch
sudo systemctl start elasticsearch

# 验证
curl http://localhost:9200
# 输出：{ "name" : "node-1", "version" : { "number" : "8.12.0" } }

# 安装IK插件（匹配ES版本）
sudo /usr/share/elasticsearch/bin/elasticsearch-plugin install https://get.infini.cloud/elasticsearch/plugins/ik/8.12.0

# 重启ES
sudo systemctl restart elasticsearch

# 验证分词
curl -X POST "localhost:9200/_analyze" -H 'Content-Type: application/json' -d'
{
  "analyzer": "ik_max_word",
  "text": "WordPress与Elasticsearch整合实战"
}'
# 输出：["WordPress", "与", "Elasticsearch", "整合", "实战"]

curl -X PUT "localhost:9200/wordpress" -H 'Content-Type: application/json' -d'
{
  "settings": {
    "number_of_shards": 1,
    "number_of_replicas": 0,
    "analysis": {
      "analyzer": {
        "chinese_analyzer": {
          "type": "custom",
          "tokenizer": "ik_max_word",
          "filter": ["lowercase"]
        }
      }
    }
  },
  "mappings": {
    "properties": {
      "post_id":    { "type": "integer" },
      "title":      { "type": "text", "analyzer": "chinese_analyzer" },
      "content":    { "type": "text", "analyzer": "chinese_analyzer" },
      "excerpt":    { "type": "text", "analyzer": "chinese_analyzer" },
      "post_date":  { "type": "date" },
      "author":     { "type": "keyword" },
      "categories": { "type": "keyword" }
    }
  }
}'

推荐插件：
1. ElasticPress（免费，功能强大）
2. WP ElasticSearch（付费，易用）
3. SearchWP + ElasticPress（高级）

# 下载插件
cd wp-content/plugins
wget https://downloads.wordpress.org/plugin/elasticpress.zip
unzip elasticpress.zip

# 启用
wp plugin activate elasticpress

// wp-config.php
define('EP_HOST', 'http://localhost:9200');
define('EP_INDEX_PREFIX', 'wp_');  // 多站点隔离

// 后台配置路径
// WordPress后台 → ElasticPress → Settings
// - Elasticsearch Host: http://localhost:9200
// - Index Prefix: wp_
// - Enable Features: Post Search, Related Posts, Autosuggest

add_action('save_post', 'sync_to_elasticsearch');

function sync_to_elasticsearch($post_id) {
    $post = get_post($post_id);

    if ($post->post_status != 'publish') return;

    $data = [
        'post_id'   => $post->ID,
        'title'     => $post->post_title,
        'content'   => $post->post_content,
        'excerpt'   => get_the_excerpt($post),
        'post_date' => $post->post_date,
        'author'    => get_the_author_meta('display_name', $post->post_author),
        'categories' => wp_get_post_categories($post->ID, ['fields' => 'names']),
    ];

    $ch = curl_init('http://localhost:9200/wordpress/_doc/' . $post_id);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
    curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
    curl_exec($ch);
    curl_close($ch);
}

add_action('delete_post', 'delete_from_elasticsearch');

function delete_from_elasticsearch($post_id) {
    $ch = curl_init('http://localhost:9200/wordpress/_doc/' . $post_id);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
    curl_exec($ch);
    curl_close($ch);
}

add_filter('posts_pre_query', 'elasticsearch_search', 10, 2);

function elasticsearch_search($posts, $query) {
    if (! $query->is_main_query() || ! $query->is_search()) {
        return $posts;
    }

    $keyword = $query->get('s');

    // 调用Elasticsearch
    $ch = curl_init('http://localhost:9200/wordpress/_search');
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode([
        'query' => [
            'multi_match' => [
                'query'  => $keyword,
                'fields' => ['title^3', 'content', 'excerpt^2']  // title权重×3
            ]
        ],
        'highlight' => [
            'fields' => ['title' => new stdClass(), 'content' => new stdClass()]
        ]
    ]));
    curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

    $response = json_decode(curl_exec($ch));
    curl_close($ch);

    // 转换为WP_Post数组
    $post_ids = array_map(fn($hit) => $hit->_source->post_id, $response->hits->hits);

    // 强制WP使用指定ID
    $query->set('post__in', $post_ids);
    $query->set('orderby', 'post__in');
    $query->set('s', '');  // 清除原生搜索
}

# logstash.conf
input {
  jdbc {
    jdbc_driver_library => "/path/to/mysql-connector.jar"
    jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://localhost:3306/wordpress"
    jdbc_user => "wp_user"
    jdbc_password => "password"
    schedule => "* * * * *"  # 每分钟同步
    statement => "SELECT ID, post_title, post_content, post_date FROM wp_posts WHERE post_status='publish' AND post_modified > :sql_last_value"
  }
}

filter {
  mutate {
    rename => { "post_title" => "title" }
    rename => { "post_content" => "content" }
  }
}

output {
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "wordpress"
    document_id => "%{ID}"
  }
}

Elasticsearch 8.x默认启用安全特性：
- HTTPS（TLS）
- 用户认证（用户名/密码）
- API Key认证

配置WP连接时需要用户名/密码：
define('EP_HOST', 'https://user:pass@localhost:9200');

OpenSearch（AWS主导）：
- 完全开源（Elasticsearch 7.10分支）
- 兼容Elasticsearch API
- 无许可证风险

使用OpenSearch替代ES：
define('EP_HOST', 'http://localhost:9200');  // 完全兼容

# Elasticsearch 8.11+ 支持向量搜索
# 可用于"语义搜索"（类似Google）

curl -X PUT "localhost:9200/wordpress" -d '
{
  "mappings": {
    "properties": {
      "title_embedding": {
        "type": "dense_vector",
        "dims": 768  # BERT模型维度
      }
    }
  }
}'

# 搜索相似文章（语义相关，而非关键词匹配）

// ElasticPress自定义映射
add_filter('ep_config_mapping', 'add_product_mapping');

function add_product_mapping($mapping) {
    $mapping['mappings']['properties']['price'] = [
        'type' => 'double'
    ];
    $mapping['mappings']['properties']['sku'] = [
        'type' => 'keyword'
    ];
    return $mapping;
}

// 同步产品数据
add_filter('ep_sync_excluded_meta_keys', '__return_empty_array');  // 包含所有meta

// 使用ElasticPress REST API
fetch('/wp-json/elasticpress/v1/posts?search=' + query)
  .then(res => res.json())
  .then(data => {
    data.forEach(post => {
      console.log(post.title.rendered);
    });
  });

# 安装Kibana
sudo apt install kibana -y

# 配置（/etc/kibana/kibana.yml）
server.port: 5601
elasticsearch.hosts: ["http://localhost:9200"]

# 启动
sudo systemctl start kibana