Consul之：服务注册与发现

时间  2019-12-05
标签 consul 服务 注册 发现 繁體版
原文   原文链接

1、服务的管理（注册与发现）有三种方式：

1：经过配置文件的方式静态注册
2：经过HTTP API接口来动态注册（spring cloud使用方式，spring cloud中使用的是consul api）
3：使用consul client或consul api（程序）实现服务的注册和发现（Java非spring boot，cloud项目）java

1.一、经过配置文件的方式静态注册

1.1.一、建立文件夹/etc/consul.d，node

说明：.d表示一系列配置文件的存放目录（directory）web

1.1.二、建立服务并写入上述文件夹中的一个文件spring

说明：json

  • 一个服务咱们会配置为json格式：好比上述的单引号之间的形式
  • 一个服务会写在一个json文件中

注意：若是上述文件夹没有权限进行操做，先改变文件夹权限，bootstrap

我在window上，演示：ubuntu

1.1.三、先启动consul进程，带上config-dir参数windows

切换屏幕-->api

window上：D:\soft\worksoft\consul_1.0.6_windows_amd64>consul agent -dev -config-dir etc/consul.d/数组

说明：

  • 根据-config-dir指定根据服务注册的目录中的文件来启动服务。

1.2：经过HTTP API接口来动态注册

直接调用/v1/agent/service/register接口注册便可，须要注意的是：http method为PUT提交方式

如：

curl -X PUT -d '{"id": "jetty","name": "jetty","address": "192.168.1.200","port": 8080,"tags": ["dev"],"checks": [{"http": "http://192.168.1.104:9020/health","interval": "5s"}]}' http://192.168.1.100:8500/v1/agent/service/register

注意，这种方式，和上面的注册方式有一点不同，body的参数，是上面service的值，这点须要注意。

结果：

1.3：使用Consul client或Consul api实现服务的注册和发现（Java非spring boot，spring cloud项目）

1.3.一、使用Consul Client

首先加入consul client的依赖

<dependency>  
    <groupId>com.orbitz.consul</groupId>  
    <artifactId>consul-client</artifactId>  
    <version>0.15.1</version>  
</dependency>

 主类：ConsulClientDemo.java

package com.dxz.Consul_client;
import java.util.List;

import com.google.common.net.HostAndPort;
import com.orbitz.consul.AgentClient;
import com.orbitz.consul.Consul;
import com.orbitz.consul.HealthClient;
import com.orbitz.consul.model.agent.ImmutableRegCheck;
import com.orbitz.consul.model.agent.ImmutableRegistration;
import com.orbitz.consul.model.health.ServiceHealth;  
  
public class ConsulClientDemo {  
  
    static Consul consul = Consul.builder().withHostAndPort(HostAndPort.fromString("localhost:8500")).withPing(false).build();  
  
    /** 
     * 服务注册 
     */  
    public static void serviceRegister() {  
        AgentClient agent = consul.agentClient();  
          
        //健康检测  
        ImmutableRegCheck check = ImmutableRegCheck.builder().http("http://localhost:9020/health").interval("5s").build();  
          
        ImmutableRegistration.Builder builder = ImmutableRegistration.builder();  
        builder.id("consul-server3").name("consul-server").addTags("v1").address("localhost").port(8080).addChecks(check);  
          
        agent.register(builder.build());  
    }  
      
    /** 
     * 服务获取 
     */  
    public static void serviceGet() {  
        HealthClient client = consul.healthClient();  
        String name = "consul-server";  
        //获取全部服务  
        System.out.println(client.getAllServiceInstances(name).getResponse().size());  
          
        //获取全部正常的服务（健康检测经过的）  
        List<ServiceHealth> responses = client.getHealthyServiceInstances(name).getResponse();
        for(ServiceHealth sh : responses ) {
            System.out.println(sh.getService());
        }
    }  
    
    public static void main(String[] args) {  
        serviceRegister();  
        serviceGet();
        System.exit(0);
    }  
}

上面的注册后，看consul控制台以下：

 

1.3.二、使用Consul API

固然了，还可使用以下consul api

        <dependency>
            <groupId>com.ecwid.consul</groupId>
            <artifactId>consul-api</artifactId>
            <version>1.2.2</version>
        </dependency>

主类：ConsulApiDemo.java

复制代码 
package com.dxz.Consul_client;
import java.util.List;
import java.util.Map;

import com.ecwid.consul.v1.ConsulClient;
import com.ecwid.consul.v1.ConsulRawClient;
import com.ecwid.consul.v1.agent.model.Service;
import com.ecwid.consul.v1.health.model.HealthService;  
  
public class ConsulApiDemo {  
  
  
    public static void serviceApiGet() {
         ConsulRawClient client = new ConsulRawClient("localhost", 8500);  
         ConsulClient consul = new ConsulClient(client);  
         //获取全部服务  
         Map<String, Service> map = consul.getAgentServices().getValue();
         List<HealthService> list = consul.getHealthServices("consul-server", false, null).getValue();
         System.out.println(map.size()+"," +map);
         System.out.println("list" + list);
    }
      
    public static void main(String[] args) {  
        serviceApiGet();  
        System.exit(0);
    }  
}

启动时的日志片断：

6,map={application=Service{id='application', service='application', tags=[], address='192.168.5.6', port=8080}, consul=Service{id='consul', service='consul', tags=[], address='', port=8300}, consul-client1=Service{id='consul-client1', service='consul-client', tags=[], address='DESKTOP-PPSFCNC', port=8501}, consul-server1=Service{id='consul-server1', service='consul-server', tags=[], address='DESKTOP-PPSFCNC', port=8503}, consul-server2=Service{id='consul-server2', service='consul-server', tags=[], address='DESKTOP-PPSFCNC', port=8504}, consul-server3=Service{id='consul-server3', service='consul-server', tags=[v1], address='localhost', port=8080}}

3,list=[HealthService{node=Node{node='DESKTOP-PPSFCNC', address='127.0.0.1'}, service=Service{id='consul-server1', service='consul-server', tags=[], address='DESKTOP-PPSFCNC', port=8503}, checks=[Node{node='DESKTOP-PPSFCNC', checkId='serfHealth', name='Serf Health Status', status=PASSING, notes='', output='Agent alive and reachable', serviceId='', serviceName=''}, Node{node='DESKTOP-PPSFCNC', checkId='service:consul-server1', name='Service 'consul-server' check', status=CRITICAL, notes='', output='parse http://DESKTOP-PPSFCNC:8503${management.contextPath}/health: invalid character "{" in host name', serviceId='consul-server1', serviceName='consul-server'}]}, HealthService{node=Node{node='DESKTOP-PPSFCNC', address='127.0.0.1'}, service=Service{id='consul-server2', service='consul-server', tags=[], address='DESKTOP-PPSFCNC', port=8504}, checks=[Node{node='DESKTOP-PPSFCNC', checkId='serfHealth', name='Serf Health Status', status=PASSING, notes='', output='Agent alive and reachable', serviceId='', serviceName=''}, Node{node='DESKTOP-PPSFCNC', checkId='service:consul-server2', name='Service 'consul-server' check', status=CRITICAL, notes='', output='parse http://DESKTOP-PPSFCNC:8504${management.contextPath}/health: invalid character "{" in host name', serviceId='consul-server2', serviceName='consul-server'}]}, HealthService{node=Node{node='DESKTOP-PPSFCNC', address='127.0.0.1'}, service=Service{id='consul-server3', service='consul-server', tags=[v1], address='localhost', port=8080}, checks=[Node{node='DESKTOP-PPSFCNC', checkId='serfHealth', name='Serf Health Status', status=PASSING, notes='', output='Agent alive and reachable', serviceId='', serviceName=''}, Node{node='DESKTOP-PPSFCNC', checkId='service:consul-server3', name='Service 'consul-server' check', status=CRITICAL, notes='', output='Get http://localhost:9020/health: dial tcp [::1]:9020: connectex: No connection could be made because the target machine actively refused it.', serviceId='consul-server3', serviceName='consul-server'}]}]

其中，spring cloud 使用的就是第二种consul api。

2、服务查询

两种查询方式：DNS和HTTP

2.一、DNS:

访问的服务名字：

  • tag.servicename.service.consul  tag和servicename都是建立服务的时候配置的
  • DNS访问的端口是8600

2.二、HTTP:

说明：

  • 访问的路径：host:port/版本号/catalog/service/服务名
  • Address：用于指定一个特定service的IP地址，默认状况下，使用的是该service使用的agent。

consul client的命令行演示

1、启动consul server

在安装好consul的ubuntu虚拟机上启动consul server，以server方式启动：

D:\soft\worksoft\consul_1.0.6_windows_amd64>consul agent -ui -server -data-dir=/data -bootstrap-expect 1 -bind 10.200.110.100

 

 

 

使用-ui参数启动server成功后，能够在浏览器中输入：http://localhost:8500/ui 看到以下界面

2、启动consul client

在本机上启动consul client

consul agent -data-dir /data -node=duan -advertise=10.200.110.13 -join=10.200.110.100
加入server节点成功后的截图以下 

此时在web ui中查看节点，会发现多了一个节点，可是没有任何服务 

 

示例：多个服务注册的状况

4.一、每个服务注册到一个文件

假设如今又建立了一个secondservice服务，我会将该服务写入secondservice.json文件中去，以下：

使用http去访问：

说明：按照服务名去访问。

4.二、多个服务写在同一个json文件中

说明：

  • 放在services中而不是service里（上边的单文件单服务是放在service里的）
  • 多个服务放在一个数组里边

使用http去访问：

说明：按照服务名去访问。

注意：在实际开发中，微服务数量众多，

若是每一个文件都放在一个文件里，文件会很是多，很差！

若是全部微服务都放在一个文件里，文件太大，也很差！

因此，须要两者结合。例如，假设有100个微服务，放在10个json文件中去，每一个json文件存放10个服务。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程