consul Ops

consul client

通過下面的命令可以建立consul client

nohup consul agent -data-dir /tmp/consul -node=liaokailin -bind=192.168.21.48  -join=120.76.145.187 &

• node 指定client節點名稱
• bind client繫結的ip
• join 指定加入到的consul serverip地址

通過執行

consul members --rpc-addr=120.76.145.187:8400

得到

Node          Address              Status  Type    Build  Protocol  DC
iZ94235juoyZ  120.76
 
.145.187:8301  alive   server  0.6.4  2         dc1
liaokailin    192.168.21.48:8301   alive   client  0.5.2  2         dc1
``
可以看出一個為`server` 一個為`client`



##service register

在consul中實現服務發現的前提是進行服務註冊

###命令實現

執行如下命令構建一個服務

mkdir /etc/consul.d

vim /etc/consul.d/first-service.json

輸入以下內容

{“service”: {“name”: “first-service”, “tags”: [“dev”], “port”: 8081}}

以上資訊定義一個名稱為`first-service`,tag為`dev`的`service`,一個服務可以有多個tag用以區別在不同的環境，因此在進行服務發現時要精準發現
一個服務需要`tag`和`name`兩個條件

配置完成後指定如下指令碼

consul agent -data-dir /tmp/consul -node=liaokailin -bind=192.168.21.48 -join=120.76.145.187 -config-dir /etc/consul.d
“

{
consul: [ ],
first-service: [
"dev"
]
}

通過dns

 dig @120.76.145.187 -p 8600 first-service.service.consul SRV

得到

penAccoutIntrs
; <<>> DiG 9.8.3-P1 <<>> @120.76.145.187 -p 8600 first-service.service.consul SRV
; (1 server found)
;; global options: +cmd
;; Got answer:
;; ->>HEADER<<- opcode: QUERY, status: NOERROR, id: 26100
;; flags: qr aa rd; QUERY: 1, ANSWER: 1, AUTHORITY: 0, ADDITIONAL: 1
;; WARNING: recursion requested but not available

;; QUESTION SECTION:
;first-service.service.consul.  IN  SRV

;; ANSWER SECTION:
first-service.service.consul. 0 IN  SRV 1 1 8081 liaokailin.node.dc1.consul.

;; ADDITIONAL SECTION:
liaokailin.node.dc1.consul. 0   IN  A   192.168.21.48

;; Query time: 44 msec
;; SERVER: 120.76.145.187#8600(120.76.145.187)
;; WHEN: Thu Jun  2 15:52:29 2016
;; MSG SIZE  rcvd: 162

java實現

pom.xml

 <dependencies>
        <dependency>
            <groupId>com.orbitz.consul</groupId>
            <artifactId>consul-client</artifactId>
            <version>0.12.2</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.10</version>
        </dependency>
    </dependencies>

    <repositories>
        <repository>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
            <id>central</id>
            <name>bintray</name>
            <url>http://jcenter.bintray.com</url>
        </repository>
    </repositories>

建立一個單元測試

package com.lkl.consul;

import com.google.common.net.HostAndPort;
import com.orbitz.consul.AgentClient;
import com.orbitz.consul.Consul;
import org.junit.Test;

import java.util.UUID;
import java.util.concurrent.TimeUnit;

/**
 * 服務註冊
 * Created by liaokailin on 16/6/2.
 */
public class ServiceRegister {

    @Test
    public void registerServiceForConsul() throws Exception {
        Consul consul = Consul.builder().withHostAndPort(HostAndPort.fromParts("127.0.0.1", 8500)).build();
        AgentClient agentClient = consul.agentClient();
        String serviceId = UUID.randomUUID().toString();
        String serviceName = "java-consul-service";
        String serviceTag = "test";
        long ttl = 3l;
        agentClient.register(9090, ttl, serviceName, serviceId, serviceTag);
        agentClient.pass(serviceId);
        System.out.println("succ.");
        TimeUnit.MINUTES.sleep(2);
    }
}

首先通過builder構建consul物件，通過agent註冊一個服務.

通過web-ui可以發現服務成功註冊.

健康檢查

命令實現

vim /etc/consul.d/first-service.json

結果：

cat first-service.json | json_pp
{
   "service" : {
      "check" : {
         "script" : "curl localhost:8080 >/dev/null 2>&1",
         "interval" : "3s"
      },
      "name" : "first-service",
      "tags" : [
         "dev"
      ],
      "port" : 8081
   }
}

增加了check,表示間隔3秒訪問一次localhost:8080，如果成功表示service為passing 否則為critical

由於localhost:8080不能訪問，所以通過web-ui發現狀態為critical，如果本地啟動一個tomcat監聽8080埠，則服務狀態為passing

java實現

package com.lkl.consul;

import com.google.common.net.HostAndPort;
import com.orbitz.consul.AgentClient;
import com.orbitz.consul.Consul;
import com.orbitz.consul.HealthClient;
import org.junit.Test;

import java.net.URI;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

/**
 * 健康檢查
 * Created by liaokailin on 16/6/2.
 */
public class HealthCheck {

    @Test
    public void doHealthCheck() throws Exception {
        Consul consul = Consul.builder().withHostAndPort(HostAndPort.fromParts("127.0.0.1", 8500)).build();
        AgentClient agentClient = consul.agentClient();
        String serviceName = "health-check-service";
        String serviceTag = "test";
        agentClient.register(9090, HostAndPort.fromParts("127.0.0.1", 8080), 3l, serviceName, "service-id", serviceTag);
        TimeUnit.MINUTES.sleep(2);
    }
}

這種方式為client agent間隔3秒會自動ping http://localhost:8080來進行將康檢查，還可以通過agentClient.pass()讓service主動
向agent報告健康

key-value

命令方式

輸入key

curl -X PUT -d 'test' http://localhost:8500/v1/kv/web/key1

查詢所有值

curl http://localhost:8500/v1/kv/?recurse

查詢指定key對應值

 curl http://localhost:8500/v1/kv/web/key1

java方式

package com.lkl.consul;

import com.google.common.base.Optional;
import com.google.common.net.HostAndPort;
import com.orbitz.consul.Consul;
import com.orbitz.consul.KeyValueClient;
import com.orbitz.consul.model.kv.Value;
import org.apache.commons.codec.binary.Base64;
import org.junit.Test;
import sun.misc.BASE64Decoder;

import java.util.List;
import java.util.Set;

/**
 * key-value操作
 * Created by liaokailin on 16/6/3.
 */
public class KeyValues {

    /**
     * 新增一個key
     */
    @Test
    public void pubKey() {
        Consul consul = Consul.builder().withHostAndPort(HostAndPort.fromParts("127.0.0.1", 8500)).build();
        KeyValueClient keyValueClient = consul.keyValueClient();
        keyValueClient.putValue("/web/key3","test");
    }

    /**
     * 按key獲取值
     */
    @Test
    public void getValueByKey(){
        Consul consul = Consul.builder().withHostAndPort(HostAndPort.fromParts("127.0.0.1", 8500)).build();
        KeyValueClient keyValueClient = consul.keyValueClient();
        Optional<String> result = keyValueClient.getValueAsString("/web/key3");
        System.out.println(result.get());
    }

    /**
     * 獲取values
     */
    @Test
    public void getValues(){
        Consul consul = Consul.builder().withHostAndPort(HostAndPort.fromParts("127.0.0.1", 8500)).build();
        KeyValueClient keyValueClient = consul.keyValueClient();

        List<Value> values =  keyValueClient.getValues("/web");
        for(Value value : values){
            System.out.println(value.getKey()+","+ new String(Base64.decodeBase64(value.getValue().get())) );
        }
    }

}

consul架構

相關術語

• Agent 長期執行在後臺的守護程序，通過consul agent 執行，不論是客戶端還是服務端都是一個agent

• Client 轉發所有的RPC到服務端的agent，client是相對無狀態的，主要與service以及通過區域網的gossip pool與server通訊，對資源消耗少

• Server 負責引數Raft選舉、維護叢集狀態、響應RPC、通過廣域網gossip pool與其他資料中心通訊

• Datacenter 資料中心，可以理解為一個私有的、低延遲的網路環境

• Consensus 一致性，叢集狀態下多個伺服器在狀態上達成一致，為了以容錯方式達成一致，一般有超過半數一致則可以認為整體一致
  consul使用Raft實現一致性，進行leader選舉，在consul中的使用bootstrap時，可以進行自選，其他server加入進來後bootstrap就可以取消

• Gossip consul通過Serf提供基於Gossip協議通訊，Serf是去中心化的服務發現和編制的解決方案，節點失敗偵測與發現，具有容錯、輕量、高可用的特點。

• LAN Gossip 同一網路或者資料中心節點通訊協議

• WAN Gossip 不同網路或不同資料中心中server通訊協議

圖表說明

利用官網給出的圖片

通過以上圖片可以發現:

1.同一資料中心Client與Server通過LAN Gossip通訊，service與server不會直接通訊，其通訊流程為service–>client –>server

2.server通過Raft演算法進行選舉

3.不同資料中心通過WAN Gossip通訊

ok ~ it’s work ! more about is here

歡迎關注，您的肯定是對我最大的支援