一，搭建基于consul的服务提供者集群
1,consul集群，共3个实例：
2, 服务提供者集群:共2个实例：
3，服务消费者：一个实例即可
4,consul集群的搭建,请参考:
https://www.cnblogs.com/architectforest/p/13735545.html
5，演示例子实现生产环境中需要的高可用：
consul server集群和服务提供者集群
说明：刘宏缔的架构森林是一个专注架构的博客，地址：https://www.cnblogs.com/architectforest
对应的源码可以访问这里获取： https://github.com/liuhongdi/
说明：作者:刘宏缔 邮箱: 371125307@qq.com
二，演示项目的相关信息:
1,两个项目的地址:
服务提供者:
https://github.com/liuhongdi/cloudconsul
服务消费者:
https://github.com/liuhongdi/consulconsumer
2,项目的功能说明
演示了基于consul实现的服务提供者和消费者，
基于consul集群和消费者集群
3，服务提供者项目的结构：如图
4，服务消费者项目的结构：如图
三，服务提供者项目的配置文件说明
1，pom.xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency> <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency> <dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
2,application.properties
spring.application.name=provider1
server.port=8080
#
spring.cloud.consul.host=127.0.0.1
spring.cloud.consul.port=8500
spring.cloud.consul.discovery.service-name=lhdprovider
spring.cloud.consul.discovery.prefer-ip-address=true
spring.cloud.consul.discovery.instance-id=${spring.application.name}:${spring.cloud.client.ip-address}
provider.name = p1
3,application-provider2.properties
spring.application.name=provider2
server.port=8080
#
spring.cloud.consul.host=127.0.0.1
spring.cloud.consul.port=8500
spring.cloud.consul.discovery.service-name=lhdprovider
spring.cloud.consul.discovery.prefer-ip-address=true
spring.cloud.consul.discovery.instance-id=${spring.application.name}:${spring.cloud.client.ip-address}
provider.name = p2
说明：spring.cloud.consul.discovery.prefer-ip-address=true：
这个配置项的作用是consul中提供的服务名称是ip和port,
这样消费者可以直接访问服务提供者，否则的话，
需要在运行服务消费者的机器上配置实例名称和ip的对应到 /etc/hosts当中才行
四，服务提供者项目的java代码说明
1,DemoApplication.java
@EnableDiscoveryClient
@SpringBootApplication
public class DemoApplication { public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
} }
2,HomeController.java
@RestController
@RequestMapping("/home")
public class HomeController { @Resource
private DiscoveryClient discoveryClient; @Value("${provider.name}")
private String name; @Value("${server.port}")
private String port; // list services
@GetMapping("/serviceslist")
public Object serviceslist() {
return discoveryClient.getServices();
} // list instances in a service id
@GetMapping("/instanceslist")
public Object instanceslist() {
return discoveryClient.getInstances("consul");
} //test api
@GetMapping("/hello")
public String hello() {
String ip = "";
try {
Enumeration<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces();
while (interfaces.hasMoreElements()) {
NetworkInterface current = interfaces.nextElement();
if (!current.isUp() || current.isLoopback() || current.isVirtual()) continue;
Enumeration<InetAddress> addresses = current.getInetAddresses();
while (addresses.hasMoreElements()) {
InetAddress addr = addresses.nextElement();
if (addr.isLoopbackAddress()) continue;
ip = addr.getHostAddress();
}
}
} catch (SocketException e) {
e.printStackTrace();
}
System.out.println("ip:"+ip);
//return discoveryClient.getInstances("consul");
String res = "ip:"+ip+";name:"+name+";port:"+port;
return res;
}
}
五，服务消费者项目的配置文件说明
1,pom.xml
<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>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2,application.properties
spring.application.name=lhdconsumer
spring.cloud.consul.host=localhost
spring.cloud.consul.port=8500
spring.cloud.consul.discovery.register=false
server.port=8081
六，服务消费者项目的java代码说明
1,DemoApplication.java
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class DemoApplication { public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
} }
2,HiService.java
@Service
public class HiService { @Resource
HomeFeignClient homeFeignClient; public String sayHi(String name){
return homeFeignClient.sayHifromClient();
}
}
3,HomeFeignClient.java
@FeignClient(value="lhdprovider")
public interface HomeFeignClient {
@GetMapping(value="/home/hello")
String sayHifromClient();
}
4,HomeController.java
@RestController
@RequestMapping("/home")
public class HomeController { @Resource
HiService hiService; @GetMapping("/hi")
public String sayHi(){
return hiService.sayHi();
}
}
七，搭建服务提供者集群
provider1上：
1,启动consul
[root@provider1 /]# nohup /usr/local/soft/consul agent -data-dir=/data/consul/data -node=provider1 -bind=172.17.0.5 -datacenter=dc1 -client=0.0.0.0 -join=172.17.0.2 > /dev/null 2>&1 &
2,启动服务:
[root@provider1 /]# /usr/local/soft/jdk-13/bin/java -jar /usr/local/soft/demo-0.0.1-SNAPSHOT.jar
provider2上：
1，启动consul
[root@provider2 /]# nohup /usr/local/soft/consul agent -data-dir=/data/consul/data -node=provider2 -bind=172.17.0.6 -datacenter=dc1 -client=0.0.0.0 -join=172.17.0.2 > /dev/null 2>&1 &
[1] 206
2,启动服务:
[root@provider2 /]# /usr/local/soft/jdk-13/bin/java -jar /usr/local/soft/demo-0.0.1-SNAPSHOT.jar --spring.profiles.active=provider2
八，测试效果
1,服务启动后，查看服务提供的情况:
访问:
http://172.17.0.5:8080/home/hello
返回:
ip:172.17.0.5;name:p1;port:8080
访问：
http://172.17.0.6:8080/home/hello
返回:
ip:172.17.0.6;name:p2;port:8080
2,测试服务消费者:访问:
http://127.0.0.1:8081/home/hi
返回:
ip:172.17.0.5;name:p1;port:8080
刷新后返回:
ip:172.17.0.6;name:p2;port:8080
3,测试高可用：关掉服务:
在provider2上，把服务停掉:
直接ctrl-c关掉或者kill也可
ip:172.17.0.6
ip:172.17.0.6
^C2020-10-06 08:41:30.727 INFO 379 --- [extShutdownHook] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 'catalogWatchTaskScheduler'
2020-10-06 08:41:30.738 INFO 379 --- [extShutdownHook] o.s.c.c.s.ConsulServiceRegistry : Deregistering service with consul: provider2-172-17-0-6
2020-10-06 08:41:30.780 INFO 379 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor : Shutting down ExecutorService 'applicationTaskExecutor'
然后查看consul的web ui：
可以看到lhdprovider中只剩下了一个实例：
访问服务消费者:
http://127.0.0.1:8081/home/hi
返回:
ip:172.17.0.5;name:p1;port:8080
反复刷新后返回结果中也没有provider2的返回，只有p1的返回，
说明高可用有效
4,测试高可用：关掉consul的agent
把上面所掉的provider2的服务再次启动
这次我们关掉provider1上的consul client
[root@provider1 /]# ps auxfww
USER PID %CPU %MEM VSZ RSS TTY STAT START TIME COMMAND
root 495 0.5 0.0 12028 3012 pts/2 Ss 08:48 0:00 /bin/bash
root 508 0.0 0.0 43964 3084 pts/2 R+ 08:48 0:00 \_ ps auxfww
root 200 0.0 0.0 12128 180 pts/1 Ss 01:16 0:00 /bin/bash
root 239 0.4 0.5 784952 23788 pts/1 Sl 07:09 0:24 \_ /usr/local/soft/consul agent -data-dir=/data/consul/data -node=provider1 -bind=172.17.0.5 -datacenter=dc1 -client=0.0.0.0 -join=172.17.0.2
root 453 0.8 2.2 3619488 91824 pts/1 Sl+ 07:42 0:34 \_ /usr/local/soft/jdk-13/bin/java -jar /usr/local/soft/demo-0.0.1-SNAPSHOT.jar
root 1 0.0 0.0 93860 376 ? Ss 01:15 0:00 /usr/sbin/init
root 25 0.0 0.0 91304 1176 ? Ss 01:15 0:00 /usr/lib/systemd/systemd-journald
root 33 0.0 0.0 88832 76 ? Ss 01:15 0:00 /usr/lib/systemd/systemd-udevd
dbus 66 0.0 0.0 52812 0 ? Ss 01:15 0:00 /usr/bin/dbus-daemon --system --address=systemd: --nofork --nopidfile --systemd-activation --syslog-only
[root@provider1 /]# kill 239
[root@provider1 /]# kill 239
[root@provider1 /]# kill 239
bash: kill: (239) - No such process
查看consul的web ui,只剩下了provider2
访问消费者：
http://127.0.0.1:8081/home/hi
只返回:
ip:172.17.0.6;name:p2;port:8080
5，测试高可用：关掉consul集群中的一个:
[root@consul1 /]# /usr/local/soft/consul leave
Graceful leave complete
[1]+ Done nohup /usr/local/soft/consul agent -server -bind=172.17.0.2 -client=0.0.0.0 -bootstrap-expect=2 -data-dir=/data/consul/da -node=server-2 > /dev/null 2>&1
查看consul web ui,只剩下了两个实例
进入查看:
测试服务消费者：访问:
http://127.0.0.1:8081/home/hi
可以正常访问
九，查看spring boot版本:
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.3.4.RELEASE)