Kubernetes-在Kubernetes集群上搭建Solr集群-白红宇

准备工作

日常套路，制作solr镜像，我用的是solr 6.5.0版本

Dockerfile

FROM java:openjdk-8-jreMAINTAINER leo.lee "lis85@163.com"ENV SOLR_GROUP solrENV SOLR_USER solrENV SOLE_UID 8983ENV HOME /home/${SOLR_USER}ENV USER_BIN /usr/local/bin/RUN apt-get update && \    apt-get install -y iproute netcat lsof jq libxml2-utils xmlstarlet tar && \    apt-get clean && \    mkdir ${HOME} && \    groupadd -r ${SOLR_GROUP} && \    useradd -u ${SOLE_UID} -g ${SOLR_GROUP} -d ${HOME} ${SOLR_USER} && \    chown -R ${SOLR_USER}:${SOLR_GROUP} ${HOME} && \    chown -R ${SOLR_USER}:${SOLR_GROUP} ${USER_BIN}USER ${SOLR_USER}WORKDIR ${HOME}ENV SOLR_VERSION 6.5.0RUN curl -L -o ${HOME}/solr-${SOLR_VERSION}.tgz http://archive.apache.org/dist/lucene/solr/${SOLR_VERSION}/solr-${SOLR_VERSION}.tgz && \    tar -C ${HOME} -xf ${HOME}/solr-${SOLR_VERSION}.tgz && \    rm ${HOME}/solr-${SOLR_VERSION}.tgzENV SOLR_PREFIX ${HOME}/solr-${SOLR_VERSION}ADD docker-run.sh ${USER_BIN}ADD docker-stop.sh ${USER_BIN}RUN chmod +x ${USER_BIN}/docker-run.sh && \    chmod +x ${USER_BIN}/docker-stop.shEXPOSE 8983 7983 18983CMD ["/usr/local/bin/docker-run.sh"]

docker-run.sh

# IP detection.DETECTED_IP_LIST=($(  ip addr show | grep -e "inet[^6]" | \    sed -e "s/.*inet[^6][^0-9]*\([0-9.]*\)[^0-9]*.*/\1/" | \    grep -v "^127\."))DETECTED_IP=${DETECTED_IP_LIST[0]:-127.0.0.1}echo "DETECTED_IP=${DETECTED_IP}"# Set environment variables.SOLR_PREFIX=${SOLR_PREFIX:-/opt/solr}echo "SOLR_PREFIX=${SOLR_PREFIX}"SOLR_HOST=${SOLR_HOST:-${DETECTED_IP}}echo "SOLR_HOST=${SOLR_HOST}"SOLR_PORT=${SOLR_PORT:-8983}echo "SOLR_PORT=${SOLR_PORT}"SOLR_SERVER_DIR=${SOLR_SERVER_DIR:-${SOLR_PREFIX}/server}echo "SOLR_SERVER_DIR=${SOLR_SERVER_DIR}"SOLR_HOME=${SOLR_HOME:-${SOLR_SERVER_DIR}/solr}echo "SOLR_HOME=${SOLR_HOME}"SOLR_HEAP_SIZE=${SOLR_HEAP_SIZE:-512m}echo "SOLR_HEAP_SIZE=${SOLR_HEAP_SIZE}"SOLR_ADDITIONAL_PARAMETERS=${SOLR_ADDITIONAL_PARAMETERS:-""}echo "SOLR_ADDITIONAL_PARAMETERS=${SOLR_ADDITIONAL_PARAMETERS}"ZK_HOST=${ZK_HOST:-""}echo "ZK_HOST=${ZK_HOST}"ZK_HOST_LIST=($(echo ${ZK_HOST} | sed -e 's/^\(.\{1,\}:[0-9]\{1,\}\)*\(.*\)$/\1/g' | tr -s ',' ' '))echo "ZK_HOST_LIST=${ZK_HOST_LIST}"ZK_ZNODE=$(echo ${ZK_HOST} | sed -e 's/^\(.\{1,\}:[0-9]\{1,\}\)*\(.*\)$/\2/g')echo "ZK_ZNODE=${ZK_ZNODE}"STOP_PORT=${STOP_PORT:-$(expr $SOLR_PORT - 1000)}echo "STOP_PORT=${STOP_PORT}"ENABLE_REMOTE_JMX_OPTS=${ENABLE_REMOTE_JMX_OPTS:-false}echo "ENABLE_REMOTE_JMX_OPTS=${ENABLE_REMOTE_JMX_OPTS}"RMI_PORT=${RMI_PORT:-"1$SOLR_PORT"}echo "RMI_PORT=${RMI_PORT}"SOLR_PID_DIR=${SOLR_PID_DIR:-${SOLR_PREFIX}/bin}echo "SOLR_PID_DIR=${SOLR_PID_DIR}"CORE_NAME=${CORE_NAME:-""}echo "CORE_NAME=${CORE_NAME}"COLLECTION_NAME=${COLLECTION_NAME:-""}echo "COLLECTION_NAME=${COLLECTION_NAME}"COLLECTION_CONFIG_NAME=${COLLECTION_CONFIG_NAME:-${COLLECTION_NAME}_configs}echo "COLLECTION_CONFIG_NAME=${COLLECTION_CONFIG_NAME}"NUM_SHARDS=${NUM_SHARDS:-1}echo "NUM_SHARDS=${NUM_SHARDS}"REPLICATION_FACTOR=${REPLICATION_FACTOR:-1}echo "REPLICATION_FACTOR=${REPLICATION_FACTOR}"MAX_SHARDS_PER_NODE=${MAX_SHARDS_PER_NODE:-1}echo "MAX_SHARDS_PER_NODE=${MAX_SHARDS_PER_NODE}"CLOUD_SCRIPTS_DIR=${SOLR_PREFIX}/server/scripts/cloud-scriptsecho "CLOUD_SCRIPTS_DIR=${CLOUD_SCRIPTS_DIR}"SOLR_COLLECTIONS_API_PATH=/solr/admin/collectionsecho "SOLR_COLLECTIONS_API_PATH=${SOLR_COLLECTIONS_API_PATH}"CONFIGSET=${CONFIGSET:-data_driven_schema_configs}echo "CONFIGSET=${CONFIGSET}"ENABLE_CORS=${ENABLE_CORS:-false}echo "ENABLE_CORS=${ENABLE_CORS}"FILTER_NAME=${FILTER_NAME:-cross-origin}echo "FILTER_NAME=${FILTER_NAME}"FILTER_CLASS=${FILTER_CLASS:-org.eclipse.jetty.servlets.CrossOriginFilter}echo "FILTER_CLASS=${FILTER_CLASS}"URL_PATTERN=${URL_PATTERN:-/*}echo "URL_PATTERN=${URL_PATTERN}"ALLOWED_ORIGINS=${ALLOWED_ORIGINS:-*}echo "ALLOWED_ORIGINS=${ALLOWED_ORIGINS}"ALLOWED_METHODS=${ALLOWED_METHODS:-GET,POST,OPTIONS,DELETE,PUT,HEAD}echo "ALLOWED_METHODS=${ALLOWED_METHODS}"ALLOWED_HEADERS=${ALLOWED_HEADERS:-origin,content-type,accept}echo "ALLOWED_HEADERS=${ALLOWED_HEADERS}"SOLR_ACCESS_RETRY_COUNT=${SOLR_ACCESS_RETRY_COUNT:-10}echo "SOLR_ACCESS_RETRY_COUNT=${SOLR_ACCESS_RETRY_COUNT}"SOLR_ACCESS_INTERVAL=${SOLR_ACCESS_INTERVAL:-1}echo "SOLR_ACCESS_INTERVAL=${SOLR_ACCESS_INTERVAL}"# Start functionfunction start() {  NODE_NAME=${SOLR_HOST}:${SOLR_PORT}_solr  if [ "${ENABLE_CORS}" = "true" ]; then    echo "Enabling CORS"    cp ${SOLR_SERVER_DIR}/etc/webdefault.xml ${SOLR_SERVER_DIR}/etc/webdefault.xml.backup    xmlstarlet ed \      -N x="http://java.sun.com/xml/ns/javaee" \      -s "/x:web-app" -t elem -n "filter" \      -s "/x:web-app/filter[last()]" -t elem -n "filter-name" -v "${FILTER_NAME}" \      -s "/x:web-app/filter[last()]" -t elem -n "filter-class" -v "${FILTER_CLASS}" \      -s "/x:web-app/filter[last()]" -t elem -n "init-param" \      -s "/x:web-app/filter[last()]/init-param[last()]" -t elem -n "param-name" -v "allowedOrigins" \      -s "/x:web-app/filter[last()]/init-param[last()]" -t elem -n "param-value" -v "${ALLOWED_ORIGINS}" \      -s "/x:web-app/filter[last()]" -t elem -n "init-param" \      -s "/x:web-app/filter[last()]/init-param[last()]" -t elem -n "param-name" -v "allowedMethods" \      -s "/x:web-app/filter[last()]/init-param[last()]" -t elem -n "param-value" -v "${ALLOWED_METHODS}" \      -s "/x:web-app/filter[last()]" -t elem -n "init-param" \      -s "/x:web-app/filter[last()]/init-param[last()]" -t elem -n "param-name" -v "allowedHeaders" \      -s "/x:web-app/filter[last()]/init-param[last()]" -t elem -n "param-value" -v "${ALLOWED_HEADERS}" \      -s "/x:web-app" -t elem -n "filter-mapping" \      -s "/x:web-app/filter-mapping[last()]" -t elem -n "filter-name" -v "${FILTER_NAME}" \      -s "/x:web-app/filter-mapping[last()]" -t elem -n "url-pattern" -v "${URL_PATTERN}" \      ${SOLR_SERVER_DIR}/etc/webdefault.xml > ${SOLR_SERVER_DIR}/etc/webdefault.xml.cors    mv ${SOLR_SERVER_DIR}/etc/webdefault.xml.cors ${SOLR_SERVER_DIR}/etc/webdefault.xml  fi  if [ -n "${ZK_HOST}" ]; then    # Create a znode to ZooKeeper.    for TMP_ZK_HOST in "${ZK_HOST_LIST[@]}"    do      ZK_HOST_NAME=$(echo ${TMP_ZK_HOST} | cut -d":" -f1)      ZK_HOST_PORT=$(echo ${TMP_ZK_HOST} | cut -d":" -f2)      MATCHED_ZNODE=$(${CLOUD_SCRIPTS_DIR}/zkcli.sh -zkhost ${ZK_HOST_NAME}:${ZK_HOST_PORT} -cmd list | grep -E "^\s+${ZK_ZNODE}\s+.*$")      if [ -z "${MATCHED_ZNODE}" ]; then        echo "Creating a znode ${ZK_ZNODE} to ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}"        ${CLOUD_SCRIPTS_DIR}/zkcli.sh -zkhost ${ZK_HOST_NAME}:${ZK_HOST_PORT} -cmd makepath ${ZK_ZNODE}        # Wait until znode created.        for i in `seq ${SOLR_ACCESS_RETRY_COUNT}`        do          MATCHED_ZNODE=$(${CLOUD_SCRIPTS_DIR}/zkcli.sh -zkhost ${ZK_HOST_NAME}:${ZK_HOST_PORT} -cmd list | grep -E "^\s+${ZK_ZNODE}\s+.*$")          if [ -n "${MATCHED_ZNODE}" ]; then            echo "A znode ${ZK_ZNODE} has been created to ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}"            break          fi          sleep ${SOLR_ACCESS_INTERVAL}        done      else        echo "A znode ${ZK_ZNODE} already exist in ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}"      fi    done    # Start Solr in SolrCloud mode.    echo "Starting solr in SolrCloud mode"    ${SOLR_PREFIX}/bin/solr start -h ${SOLR_HOST} -p ${SOLR_PORT} -m ${SOLR_HEAP_SIZE} -d ${SOLR_SERVER_DIR} -s ${SOLR_HOME} -z ${ZK_HOST} -a "${SOLR_ADDITIONAL_PARAMETERS}"  else    # Start Solr standalone mode.    echo "Starting solr in standalone mode"    ${SOLR_PREFIX}/bin/solr start -h ${SOLR_HOST} -p ${SOLR_PORT} -m ${SOLR_HEAP_SIZE} -d ${SOLR_SERVER_DIR} -s ${SOLR_HOME} -a "${SOLR_ADDITIONAL_PARAMETERS}"  fi  # Get Solr process id.  SOLR_PID=$(cat $(find ${SOLR_PID_DIR} -name solr-${SOLR_PORT}.pid -type f))  if [ -z "${SOLR_PID}" ]; then    SOLR_PID=$(ps auxww | grep start\.jar | grep solr.solr.home | grep -E "^.*\s-Djetty.port=${SOLR_PORT}[^0-9]{0,}.*$" | grep -v grep | awk '{print $2}')  fi  # Wait until Solr started.  for i in `seq ${SOLR_ACCESS_RETRY_COUNT}`  do    SOLR_STATUS_JSON=$(${SOLR_PREFIX}/bin/solr status | sed -n -E "/Solr process ${SOLR_PID} running on port ${SOLR_PORT}/,/}/p" | sed -n -e "/{/,/}/p")    if [ -n "${SOLR_STATUS_JSON}" ]; then      echo "${SOLR_STATUS_JSON}"      break    fi    sleep ${SOLR_ACCESS_INTERVAL}  done  if [ -n "${ZK_HOST}" ]; then    # Wait until the node is registered to live_nodes.    for i in `seq ${SOLR_ACCESS_RETRY_COUNT}`    do      SOLR_CLUSTER_STATUS_JSON=$(curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CLUSTERSTATUS&wt=json")      LIVE_NODE_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.live_nodes[]"))      if [[ " ${LIVE_NODE_LIST[@]} " =~ " ${NODE_NAME} " ]]; then        echo "A node ${NODE_NAME} has been registered"        break      else        echo "A node ${NODE_NAME} is not registered yet"      fi      sleep ${SOLR_ACCESS_INTERVAL}    done    # Upload configset.    COLLECTION_CONFIG_UPLOADED="0"    for TMP_ZK_HOST in "${ZK_HOST_LIST[@]}"    do      ZK_HOST_NAME=$(echo ${TMP_ZK_HOST} | cut -d":" -f1)      ZK_HOST_PORT=$(echo ${TMP_ZK_HOST} | cut -d":" -f2)      # Check configset.      MATCHED_COLLECTION_CONFIG_NAME=$(${CLOUD_SCRIPTS_DIR}/zkcli.sh -zkhost ${ZK_HOST_NAME}:${ZK_HOST_PORT} -cmd list | grep -E "^\s+${ZK_ZNODE}/configs/${COLLECTION_CONFIG_NAME}\s+.*$")      if [ -z "${MATCHED_COLLECTION_CONFIG_NAME}" ]; then        echo "Uploading ${SOLR_HOME}/configsets/${CONFIGSET}/conf for config ${COLLECTION_CONFIG_NAME} to ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}${ZK_ZNODE}"        ${CLOUD_SCRIPTS_DIR}/zkcli.sh -zkhost ${ZK_HOST_NAME}:${ZK_HOST_PORT}${ZK_ZNODE} -cmd upconfig -confdir ${SOLR_HOME}/configsets/${CONFIGSET}/conf/ -confname ${COLLECTION_CONFIG_NAME}        # Wait until config uploaded.        for i in `seq ${SOLR_ACCESS_RETRY_COUNT}`        do          MATCHED_COLLECTION_CONFIG_NAME=$(${CLOUD_SCRIPTS_DIR}/zkcli.sh -zkhost ${ZK_HOST_NAME}:${ZK_HOST_PORT} -cmd list | grep -E "^\s+${ZK_ZNODE}/configs/${COLLECTION_CONFIG_NAME}\s+.*$")          if [ -n "${MATCHED_COLLECTION_CONFIG_NAME}" ]; then            echo "Config ${COLLECTION_CONFIG_NAME} has been uploaded to ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}${ZK_ZNODE}"            COLLECTION_CONFIG_UPLOADED="1"            break          else            echo "Config ${COLLECTION_CONFIG_NAME} is not uploaded in ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}${ZK_ZNODE} yet"          fi          sleep ${SOLR_ACCESS_INTERVAL}        done      else        echo "Config ${COLLECTION_CONFIG_NAME} already exists in ZooKeeper at ${ZK_HOST_NAME}:${ZK_HOST_PORT}${ZK_ZNODE}"        COLLECTION_CONFIG_UPLOADED="1"      fi      if [ "${COLLECTION_CONFIG_UPLOADED}" = "1" ]; then        break      fi    done    # Create collection.    SOLR_CLUSTER_STATUS_JSON=$(curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CLUSTERSTATUS&wt=json")    COLLECTION_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections | keys[]"))    if [[ " ${COLLECTION_NAME_LIST[@]} " =~ " ${COLLECTION_NAME} " ]]; then      echo "A collection ${COLLECTION_NAME} already exists"    else      echo "Creating collection ${COLLECTION_NAME}"      curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CREATE&name=${COLLECTION_NAME}&router.name=compositeId&numShards=${NUM_SHARDS}&replicationFactor=${REPLICATION_FACTOR}&maxShardsPerNode=${MAX_SHARDS_PER_NODE}&createNodeSet=EMPTY&collection.configName=${COLLECTION_CONFIG_NAME}&wt=json" | jq .      # Wait until collection created      for i in `seq ${SOLR_ACCESS_RETRY_COUNT}`      do        SOLR_CLUSTER_STATUS_JSON=$(curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CLUSTERSTATUS&wt=json")        COLLECTION_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections | keys[]"))        if [[ " ${COLLECTION_NAME_LIST[@]} " =~ " ${COLLECTION_NAME} " ]]; then          echo "A collection ${COLLECTION_NAME} has been created"          break        else          echo "A collection ${COLLECTION_NAME} has not been created yet"        fi        sleep ${SOLR_ACCESS_INTERVAL}              done    fi    # Find shard to add.    SOLR_CLUSTER_STATUS_JSON=$(curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CLUSTERSTATUS&wt=json")    ACTIVE_SHARD_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections.${COLLECTION_NAME}.shards | to_entries | .[] | select(.value.state == \"active\") | .key"))    SHARD_NAME=${ACTIVE_SHARD_NAME_LIST[0]}    MIN_REPLICA_COUNT=$(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections.${COLLECTION_NAME}.shards.${ACTIVE_SHARD_NAME_LIST[0]}.replicas | to_entries | .[] | select(.value.state == \"active\") | .key" | wc -l)    for TMP_SHARD_NAME in "${ACTIVE_SHARD_NAME_LIST[@]}"    do        ACTIVE_REPLICA_COUNT=$(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections.${COLLECTION_NAME}.shards.${TMP_SHARD_NAME}.replicas | to_entries | .[] | select(.value.state == \"active\") | .key" | wc -l)      if [ -z "${ACTIVE_REPLICA_COUNT}" ]; then        ACTIVE_REPLICA_COUNT=0      fi      echo "${TMP_SHARD_NAME} has ${ACTIVE_REPLICA_COUNT} replica(s)"      if [[ ${MIN_REPLICA_COUNT} -gt ${ACTIVE_REPLICA_COUNT} ]]; then        SHARD_NAME=${TMP_SHARD_NAME}        MIN_REPLICA_COUNT=${ACTIVE_REPLICA_COUNT}      fi            echo "Target shard is ${TMP_SHARD_NAME}"      # Add replica.      echo "Adding replica ${NODE_NAME} to ${COLLECTION_NAME}/${TMP_SHARD_NAME}"      curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=ADDREPLICA&collection=${COLLECTION_NAME}&shard=${TMP_SHARD_NAME}&node=${NODE_NAME}&wt=json" | jq .    done  else    echo "Creating Solr sore"    if [ -n "${CORE_NAME}" ]; then      # Create Solr core.      ${SOLR_PREFIX}/bin/solr create_core -c ${CORE_NAME} -d ${CONFIGSET}    fi  fi  echo "Initialized"}trap "docker-stop.sh; exit 1" TERM KILL INT QUIT# Startstart# Start infinitive loopwhile truedo  sleep 1done

docker-stop.sh

# IP detection.DETECTED_IP_LIST=($(  ip addr show | grep -e "inet[^6]" | \    sed -e "s/.*inet[^6][^0-9]*\([0-9.]*\)[^0-9]*.*/\1/" | \    grep -v "^127\."))DETECTED_IP=${DETECTED_IP_LIST[0]:-127.0.0.1}echo "DETECTED_IP=${DETECTED_IP}"# Set environment variables.SOLR_PREFIX=${SOLR_PREFIX:-/opt/solr}echo "SOLR_PREFIX=${SOLR_PREFIX}"SOLR_HOST=${SOLR_HOST:-${DETECTED_IP}}echo "SOLR_HOST=${SOLR_HOST}"SOLR_PORT=${SOLR_PORT:-8983}echo "SOLR_PORT=${SOLR_PORT}"SOLR_SERVER_DIR=${SOLR_SERVER_DIR:-${SOLR_PREFIX}/server}echo "SOLR_SERVER_DIR=${SOLR_SERVER_DIR}"SOLR_HOME=${SOLR_HOME:-${SOLR_SERVER_DIR}/solr}echo "SOLR_HOME=${SOLR_HOME}"ZK_HOST=${ZK_HOST:-""}echo "ZK_HOST=${ZK_HOST}"ZK_HOST_LIST=($(echo ${ZK_HOST} | sed -e 's/^\(.\{1,\}:[0-9]\{1,\}\)*\(.*\)$/\1/g' | tr -s ',' ' '))echo "ZK_HOST_LIST=${ZK_HOST_LIST}"ZK_ZNODE=$(echo ${ZK_HOST} | sed -e 's/^\(.\{1,\}:[0-9]\{1,\}\)*\(.*\)$/\2/g')echo "ZK_ZNODE=${ZK_ZNODE}"SOLR_COLLECTIONS_API_PATH=/solr/admin/collectionsecho "SOLR_COLLECTIONS_API_PATH=${SOLR_COLLECTIONS_API_PATH}"SOLR_ACCESS_RETRY_COUNT=${SOLR_ACCESS_RETRY_COUNT:-10}echo "SOLR_ACCESS_RETRY_COUNT=${SOLR_ACCESS_RETRY_COUNT}"SOLR_ACCESS_INTERVAL=${SOLR_ACCESS_INTERVAL:-1}echo "SOLR_ACCESS_INTERVAL=${SOLR_ACCESS_INTERVAL}"# Stop function.function stop() {  NODE_NAME=${SOLR_HOST}:${SOLR_PORT}_solr  # SolrCloud mode?  if [ -n "${ZK_HOST}" ]; then    # Get collection list.    SOLR_CLUSTER_STATUS_JSON=$(curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CLUSTERSTATUS&wt=json")    COLLECTION_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections | keys[]"))    for COLLECTION_NAME in "${COLLECTION_NAME_LIST[@]}"    do      # Get shard list in a collection.      SHARD_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections.${COLLECTION_NAME}.shards | keys[]"))      for SHARD_NAME in "${SHARD_NAME_LIST[@]}"      do        # Get replica list in a shard.        REPLICA_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections.${COLLECTION_NAME}.shards.${SHARD_NAME}.replicas | to_entries | .[] | select(.value.node_name == \"${NODE_NAME}\") | .key"))        if [ -n "${REPLICA_NAME_LIST[@]}" ]; then          for REPLICA_NAME in "${REPLICA_NAME_LIST[@]}"          do            # Delete replica.            echo "Deleting replica ${REPLICA_NAME}(${NODE_NAME}) from ${COLLECTION_NAME}/${SHARD_NAME}"            curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=DELETEREPLICA&collection=${COLLECTION_NAME}&shard=${SHARD_NAME}&replica=${REPLICA_NAME}&wt=json" | jq .          done        fi      done    done    # Wait until replica deleted.    for i in `seq ${SOLR_ACCESS_RETRY_COUNT}`    do      SOLR_CLUSTER_STATUS_JSON=$(curl -s "http://${SOLR_HOST}:${SOLR_PORT}${SOLR_COLLECTIONS_API_PATH}?action=CLUSTERSTATUS&wt=json")      REPLICA_NAME_LIST=($(echo ${SOLR_CLUSTER_STATUS_JSON} | jq -r ".cluster.collections.${COLLECTION_NAME}.shards.${SHARD_NAME}.replicas | to_entries | .[] | select(.value.node_name == \"${NODE_NAME}\") | .key"))      if [ -z "${REPLICA_NAME_LIST[@]}" ]; then        echo "${NODE_NAME} has been deleted"        break      else        echo "A node ${NODE_NAME} is not deleted yet"      fi      sleep ${SOLR_ACCESS_INTERVAL}    done  fi    ${SOLR_PREFIX}/bin/solr stop -p ${SOLR_PORT}  echo "Deleted"}# Stopstop

部署Solr

这里采用的是Replication Controller方式部署，我定义了一个服务，pod保持3个，zookeeper使用的是我之前部署的。

#solr serviceapiVersion: v1kind: Servicemetadata:  name: solr-service  namespace: default  labels:    app: solr-servicespec:  type: NodePort  ports:  - name: solr    port: 8983    targetPort: 8983    protocol: TCP  - name: stop    port: 7983    targetPort: 7983    protocol: TCP  - name: rmi    port: 18983    targetPort: 18983    protocol: TCP  selector:    app: solr-pod---apiVersion: v1kind: ReplicationControllermetadata:  name: solr-controller  namespace: default  labels:    app: solr-controllerspec:  replicas: 3  selector:    app: solr-pod  template:    metadata:      labels:        app: solr-pod    spec:      containers:      - name: solr-container        image: registry.docker.uih/library/leo-solr:6.5.0        imagePullPolicy: IfNotPresent        ports:        - name: solr          containerPort: 8983          protocol: TCP        - name: stop          containerPort: 7983          protocol: TCP        - name: rmi          containerPort: 18983          protocol: TCP        env:        - name: SOLR_HOST          valueFrom:            fieldRef:              fieldPath: status.podIP        - name: ZK_HOST          value: zk-cs:2181/solr        - name: COLLECTION_NAME          value: collection1        - name: NUM_SHARDS          value: "3"        - name: COLLECTION_CONFIG_NAME          value: data_driven_schema_configs

使用如下命令进行部署

kubectl create -f solr.yaml

部署完成后通过浏览器访问solr服务的地址就可以看到我们熟悉的Solr界面了

dashboard

query

Enjoy！！！