springcloudconsul配置详解,springcloud配置consul集群
00-1010 1.执政官2简介。技术术语。领事4的优势。特点5。领事和尤里卡的区别6 3。咨询安装6.1 docker-compose安装7。快速入门7.1启动咨询服务7.2创建客户端-提供者7.2.1简介坐标7.2.2配置应用程序. yml7.2.3添加测试方法7.3创建客户端-消费7.3.1配置应用程序. yml7.3.2添加RestTemplate7.3.3添加测试方法7.4启动
目录
Consul是HashiCorp推出的开源工具，用于实现分布式系统的服务发现和配置。与其他分布式服务注册和发现方案相比，Consul的方案更加“一站式”，内置服务注册和发现框架、实现分布式一致性协议、健康检查、键/值存储、多数据中心方案。它不再需要依赖其他工具(如ZooKeeper等。).使用起来也比较简单。领事是用Go语言写的，所以自然是可移植的(支持Linux，windows，Mac OS X)；安装包只包含一个可执行文件，便于部署，可以与Docker等轻量级容器无缝协作。
1. Consul 简介
代理consul集群的每个成员都应该运行一个代理，该代理可以通过consul代理命令启动。代理可以在服务器状态或客户端状态下运行。自然，运行在服务器状态的节点称为服务器节点，运行在客户端状态的节点称为客户端节点。
Server负责组建一个集群的复杂工作(自己选择一个领导者，维护状态，把请求转发给领导者)，以及consul提供的服务(响应RPC请求)，存储和复制数据。考虑到容错性和可用性，一般部署3 ~ 5个为宜。
客户端节点负责将所有RPC转发到服务器节点。它是无状态和轻量级的，因此可以部署大量的客户端节点。
数据中心虽然数据中心的定义看似显而易见，但仍有一些微妙的细节必须考虑。我们将数据中心定义为私有、低延迟和高带宽的网络环境。这不包括通过公共互联网的通信，但出于我们的目的，单个EC2 (aws云主机)区域内的多个可用区域将被视为单个数据中心的一部分。
00-1010 Raft算法用于保证一致性，比复杂的Paxos算法更直接。相比较而言，zookeeper用的是Paxos，etcd用的是Raft。支持多数据中心，通过不同的端口监控内外网的服务。多数据中心集群可以避免单数据中心故障，其部署需要考虑网络延迟、碎片化等问题。zookeeper和etcd都没有提供对多数据中心功能的支持。支持健康检查。Etcd不提供此功能。支持http和dns协议接口。zookeeper的集成比较复杂，etcd只支持http协议。提供了官方的web管理界面，但是etcd没有这个功能。总的来说，Consul作为服务注册和配置管理的后起之秀，更值得关注和研究。
00-1010服务发现健康检查键/值存储多数据中心
00-1010 1.一致性咨询强一致性(CP)
注册会比尤里卡稍微慢一点。因为Consul的raft协议要求必须成功写入一半以上的节点才算注册成功。领导挂了，改选时整个领事都不在。确保强大的一致性，但牺牲了可用性。2.Eureka保证高可用性和最终一致性(AP)
服务注册比较快，因为不需要等待注册信息复制到其他节点，也不能保证注册信息复制成功。当数据不一致时，虽然A和B上的注册信息不完全相同，但是各个尤里卡节点仍然可以正常对外提供服务，这就会导致服务信息的查询。如果请求A找不到，请求B就能找到。这确保了可用性，但牺牲了一致性。
2. 专业名词
咨询码头中心
00-1010以开发模式启动，并将client=0.0.0.0设置为所有ip都可以连接到此服务。
版本： 2 服务：咨询-控制
tainer: image: consul container_name: consul-dev environment: - CONSUL_BIND_INTERFACE=eth0 ports: - "8500:8500" volumes: - "./config:/consul/config/" - "./data/:/consul/data/" command: agent -dev -client=0.0.0.0服务启动成功后，通过浏览器访问localhost:8500,显示如下页面即安装成功。
7. Quick Start
7.1 启动consul服务
本文使用的是docker-compose方式管理consul服务，直接启动即可
7.2 创建客户端-provider
7.2.1 引入依赖坐标
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId></dependency><dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-consul-discovery</artifactId></dependency><!--actuator用于心跳检查--><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId></dependency>
7.2.2 配置application.yml
server: port: ${port:8082}spring: application: name: provider cloud: consul: #consul服务地址 host: 127.0.0.1 #consul服务端口 port: 8500 discovery: #是否注册 register: true #实例ID # instance-id: ${spring.application.name}-${server.port} instance-id: ${spring.application.name}:${random.value} #服务实例名称 service-name: ${spring.application.name} #服务实例端口 port: ${server.port} #健康检查路径 healthCheckPath: /actuator/health #健康检查时间间隔 healthCheckInterval: 15s #开启ip地址注册 prefer-ip-address: true #实例的请求ip ip-address: ${spring.cloud.client.ip-address}
7.2.3 添加测试方法
package com.ldx.provider.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.cloud.client.ServiceInstance;import org.springframework.cloud.client.discovery.DiscoveryClient;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;import java.util.List;@RestControllerpublic class TestController { @Autowired private DiscoveryClient discoveryClient; @Value("${server.port}") private String port; @GetMapping("products") public String products(){ List<ServiceInstance> list = discoveryClient.getInstances("consumer"); if(list != null && list.size() > 0 ) { ServiceInstance serviceInstance = list.get(0); System.out.println(serviceInstance); } return "Hello World：" + port; }}
7.3 创建客户端-comsumer
创建过程和provider一样 测试方法换一下，并且在启动类上添加RestTemplate Bean
7.3.1 配置application.yml
server: port: ${port:8081}spring: application: name: consumer cloud: consul: #consul服务地址 host: 127.0.0.1 #consul服务端口 port: 8500 discovery: #是否注册 register: true #实例ID # instance-id: ${spring.application.name}-${server.port} instance-id: ${spring.application.name}:${random.value} #服务实例名称 service-name: ${spring.application.name} #服务实例端口 port: ${server.port} #健康检查路径 healthCheckPath: /actuator/health #健康检查时间间隔 healthCheckInterval: 15s #开启ip地址注册 prefer-ip-address: true #实例的请求ip ip-address: ${spring.cloud.client.ip-address} metadata: #添加自定义元数据 my-name: zhangtieniu-consumer
7.3.2 添加支持负载均衡的RestTemplate
package com.ldx.consumer;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.loadbalancer.LoadBalanced;import org.springframework.context.annotation.Bean;import org.springframework.web.client.RestTemplate;@SpringBootApplicationpublic class ConsumerApplication { @Bean @LoadBalanced public RestTemplate loadbalancedRestTemplate(){ return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(ConsumerApplication.class, args);}
7.3.3 添加测试方法
package com.ldx.consumer.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.cloud.client.ServiceInstance;import org.springframework.cloud.client.discovery.DiscoveryClient;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;import java.util.List;@RestControllerpublic class TestController { @Autowired private RestTemplate restTemplate; @GetMapping() public String consumer(){ return this.restTemplate.getForObject("http://provider/products", String.class); }}
7.4 启动
启动了两个 provider 和一个 consumer
浏览器输入localhost:8500 查看consul控制台，显示服务注册成功
测试服务调用
其中provider 输出的 实例信息如下：
[ConsulServiceInstance@4c2b7437 instanceId = 'consumer-6cfd981c90545313155d1f43c3ed23a5', serviceId = 'consumer', host = '192.168.0.101', port = 8081, secure = false, metadata = map['my-name' -> 'zhangtieniu-consumer', 'secure' -> 'false'], uri = http://192.168.0.101:8081, healthService = HealthService{node=Node{id='3fe6ea9e-3846-ff8d-b01f-a6528caaa3fd', node='44a66c1caa9c', address='172.26.0.2', datacenter='dc1', taggedAddresses={lan=172.26.0.2, lan_ipv4=172.26.0.2, wan=172.26.0.2, wan_ipv4=172.26.0.2}, meta={consul-network-segment=}, createIndex=11, modifyIndex=13}, service=Service{id='consumer-6cfd981c90545313155d1f43c3ed23a5', service='consumer', tags=[], address='192.168.0.101', meta={my-name=zhangtieniu-consumer, secure=false}, port=8081, enableTagOverride=false, createIndex=275, modifyIndex=275}, checks=[Check{node='44a66c1caa9c', checkId='serfHealth', name='Serf Health Status', status=PASSING, notes='', output='Agent alive and reachable', serviceId='', serviceName='', serviceTags=[], createIndex=11, modifyIndex=11}, Check{node='44a66c1caa9c', checkId='service:consumer-6cfd981c90545313155d1f43c3ed23a5', name='Service 'consumer' check', status=PASSING, notes='', output='HTTP GET http://192.168.0.101:8081/actuator/health: 200 Output: {"status":"UP"}', serviceId='consumer-6cfd981c90545313155d1f43c3ed23a5', serviceName='consumer', serviceTags=[], createIndex=275, modifyIndex=278}]}]
到此这篇关于SpringCloud-Consul的文章就介绍到这了,更多相关SpringCloudConsul内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT！
郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。