yum install -y http://mirrors.yun-idc.com/epel/6/i386/epel-release-6-8.noarch.rpm

yum install -y docker-io

mkdir -p /opt/elasticsearch/data
vim /opt/elasticsearch/elasticsearch.yml

docker run --name elasticsearch -p : -p : -p : -e "discovery.type=single-node" -v /opt/elasticsearch/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.yml -v /opt/elasticsearch/data:/usr/share/elasticsearch/data -d elasticsearch

cluster.name: elasticsearch_cluster

node.name: node-master

node.master: true

node.data: true

http.port:

network.host: 0.0.0.0

network.publish_host: 192.168.6.77

discovery.zen.ping.unicast.hosts: ["192.168.6.77","192.168.6.78"]

http.host: 0.0.0.0

http.cors.enabled: true

http.cors.allow-origin: "*"

bootstrap.memory_lock: false

bootstrap.system_call_filter: false

# Uncomment the following lines for a production cluster deployment

#transport.host: 0.0.0.0

discovery.zen.minimum_master_nodes: 

docker run --name kibana -e ELASTICSEARCH_URL=http://127.0.0.1:9200 --net=container:elasticsearch -d kibana

切换到root用户

、vi /etc/security/limits.conf 修改如下配置

* soft nofile

* hard nofile 

2、vi /etc/sysctl.conf 添加配置

vm.max_map_count=

运行命令 sysctl -p

cluster.name: elasticsearch_cluster

node.name: node-slave

node.master: false

node.data: true

http.port:

network.host: 0.0.0.0

network.publish_host: 192.168.6.78

discovery.zen.ping.unicast.hosts: ["192.168.6.77:9300","192.168.6.78:9300"]

http.host: 0.0.0.0

http.cors.enabled: true

http.cors.allow-origin: "*"

bootstrap.memory_lock: false

bootstrap.system_call_filter: false

# Uncomment the following lines for a production cluster deployment

# #transport.host: 0.0.0.0

# #discovery.zen.minimum_master_nodes:

#

spring:

  data:

   elasticsearch:

    cluster-nodes: 192.168.6.77:

    repositories.enabled: true

    cluster-name: elasticsearch_cluster

package com.smkj.user.repository;

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

import org.springframework.stereotype.Component;

import com.smkj.user.entity.XymApiUser;

/**

 * @author dalaoyang

 * @Description

 * @project springboot_learn

 * @package com.dalaoyang.repository

 * @email yangyang@dalaoyang.cn

 * @date 2018/5/4

 */

@Component

public interface UserRepository extends ElasticsearchRepository<XymApiUser,String> {

}

package com.smkj.user.controller;

import java.util.List;

import org.elasticsearch.action.get.GetResponse;

import org.elasticsearch.client.transport.TransportClient;

import org.elasticsearch.index.query.QueryBuilder;

import org.elasticsearch.index.query.QueryBuilders;

import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;

import org.elasticsearch.index.query.functionscore.ScoreFunctionBuilders;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.domain.Page;

import org.springframework.data.domain.PageRequest;

import org.springframework.data.domain.Pageable;

import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;

import org.springframework.data.elasticsearch.core.query.SearchQuery;

import org.springframework.data.web.PageableDefault;

import org.springframework.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RestController;

import com.google.common.collect.Lists;

import com.smkj.user.entity.XymApiUser;

import com.smkj.user.repository.UserRepository;

import com.smkj.user.service.UserService;

@RestController

public class UserController {

    @Autowired

    private UserService userService;

    @Autowired

    private UserRepository userRepository;

     @Autowired

        private TransportClient client;

@GetMapping("user/{id}")

    public XymApiUser getUserById(@PathVariable String id) {

    XymApiUser apiuser = userService.selectByPrimaryKey(id);

    userRepository.save(apiuser);

    System.out.println(apiuser.toString());

    return apiuser;

    }

/**

 * @param title   搜索标题

 * @param pageable page = 第几页参数, value = 每页显示条数

 */

@GetMapping("get/{id}")

public ResponseEntity  search(@PathVariable String id,@PageableDefault(page = , value = ) Pageable pageable){

       if (id.isEmpty()) {

           return new ResponseEntity(HttpStatus.NOT_FOUND);

       }

    // 通过索引、类型、id向es进行查询数据

       GetResponse response = client.prepareGet("testuser", "xymApiUser", id).get();

       if (!response.isExists()) {

           return new ResponseEntity(HttpStatus.NOT_FOUND);

       }

       // 返回查询到的数据

       return new ResponseEntity(response.getSource(), HttpStatus.OK);

}

/**

 * 3、查   +++：分页、分数、分域（结果一个也不少）

 * @param page

 * @param size

 * @param q

 * @return

 * @return

 */

@GetMapping("/{page}/{size}/{q}")

public Page<XymApiUser> searchCity(@PathVariable Integer page, @PathVariable Integer size, @PathVariable String q) {

    SearchQuery searchQuery = new NativeSearchQueryBuilder()

            .withQuery( QueryBuilders.prefixQuery("cardNum",q))

            .withPageable(PageRequest.of(page, size))

            .build();

    Page<XymApiUser> pagea = userRepository.search(searchQuery);

    System.out.println(pagea.getTotalPages());

    return pagea;

}

}