目录:
springcloud费话之Eureka服务访问(restTemplate)
springcloud费话之Eureka接口调用(feign)
springcloud费话之断路器(hystrix in feign)
完成了Eureka的服务器集群的搭建后,需要相互调用访问,该访问主要分为两种内容的请求
①对集群中的所有客户端的注册信息请求
②对集群中的所有客户端的接口的调用
本文使用restTemplate方式来实现相互调用
一、获取server中的注册的client的信息
1.代码
找一个client,写一个java类,内容如下:
package com.lyh.lyh_eureka_server.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import com.netflix.appinfo.InstanceInfo; import com.netflix.discovery.EurekaClient; @RestController @EnableEurekaClient public class TestController { @Autowired private EurekaClient eurekaClient; @RequestMapping("/getServerInfo") public Object getServerInfo() { // 通过eurekaClient访问服务器获取某个命名的集群。 // getNextServerFromEureka的第一个参数是服务器名称,可重复 // 因为获得的是下一个,所以是负载均衡的 InstanceInfo nextServerFromEureka = eurekaClient.getNextServerFromEureka("eureka-client-9020", false); System.out.println("name:" + nextServerFromEureka.getAppName() + " port:" + nextServerFromEureka.getPort()); return nextServerFromEureka; } }
2.访问
访问该服务的地址+‘/getServerInfo’,浏览器访问得到的结果如下,更多api自己去查
3.测试负载均衡效果
将三个client修改为同名,在运行,查看结果,只启动一个server服务方便测试
此时server注册结果如下
此时刷新getServerInfo服务,发现端口号的变化,三个客户端的端口顺序获取,实现负载均衡。
若client分布于不同的server,则该client只能获取当前注册的server中的client列表
二、使用eureka服务发现实现服务器之间的http访问(restTemplate)
1.服务代码
代码如下:
package com.lyh.lyh_eureka_server.controller; import java.net.URI; import java.net.URISyntaxException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; import com.netflix.appinfo.InstanceInfo; import com.netflix.discovery.EurekaClient; @RestController @EnableEurekaClient public class TestController { @Autowired private EurekaClient eurekaClient; @RequestMapping("/getServerInfo") public Object getServerInfo() { // 通过eurekaClient访问服务器获取某个命名的集群。 // getNextServerFromEureka的第一个参数是服务器名称,可重复 // 因为获得的是下一个,所以是负载均衡的 InstanceInfo nextServerFromEureka = eurekaClient.getNextServerFromEureka("eureka-client", false); System.out.println("name:" + nextServerFromEureka.getAppName() + " port:" + nextServerFromEureka.getPort()); return nextServerFromEureka; } // 触发的接口 @RequestMapping("/getInfoFromClient") public Object getInfoFromClient() throws URISyntaxException { InstanceInfo nextServerFromEureka = eurekaClient.getNextServerFromEureka("eureka-client", false); System.out.println("name:" + nextServerFromEureka.getAppName() + " port:" + nextServerFromEureka.getPort()); RestTemplate restTemplate = new RestTemplate(); String u = "http://" + nextServerFromEureka.getIPAddr() + ":" + nextServerFromEureka.getPort() + "/getInfo"; URI uri = new URI(u); String obj = restTemplate.getForObject(uri, String.class); System.out.println(obj.toString()); return obj; } // 接口访问的服务 @RequestMapping("/getInfo") public Object getInfo() { return "I am info from client 9022"; } }
2.部署测试
持续访问一个端口,查看访问结果,如下:
3.服务访问的前置负载均衡
若网络来的请求,是经过了nginx的负载均衡,那么就能做到静态页面,或对后端请求的均衡,加上上述策略,即可达到前端和服务端的双端负载均衡
原文地址:https://www.cnblogs.com/liuyuhangCastle/p/11397258.html
时间: 2024-11-07 23:55:03