您好,登錄后才能下訂單哦!
Springboot2XConsul中怎么利用RestTemplate實(shí)現(xiàn)服務(wù)調(diào)用,針對(duì)這個(gè)問題,這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答,希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡(jiǎn)單易行的方法。
服務(wù)調(diào)用有兩種方式:
A.使用RestTemplate 進(jìn)行服務(wù)調(diào)用
負(fù)載均衡——通過Ribbon注解RestTemplate
B.使用Feign 進(jìn)行聲明式服務(wù)調(diào)用
負(fù)載均衡——默認(rèn)使用Ribbon實(shí)現(xiàn)
先使用RestTemplate來實(shí)現(xiàn)
1.服務(wù)注冊(cè)發(fā)現(xiàn)中心
啟動(dòng)Consul
consul agent -dev
2.服務(wù)端
在spring boot2X整合Consul 的基礎(chǔ)上
添加服務(wù)provider,provider1
provider測(cè)試方法
package com.xyz.provider.controller;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class demoController { @RequestMapping("/hello") public String Hello(){ return "hello,provider"; }}
provider1測(cè)試方法
package com.xyz.provider1.controller;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class demoController { @RequestMapping("/hello") public String Hello(){ return "hello,another provider"; }}
啟動(dòng)provider和provider1
瀏覽器訪問http://localhost:8500
有兩個(gè)服務(wù)提供者節(jié)點(diǎn)實(shí)例
3.客戶端
(1)添加依賴
<properties> <java.version>1.8</java.version> <spring-cloud.version>Greenwich.SR4</spring-cloud.version> </properties> <dependencies> <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></dependencies><dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies></dependencyManagement>
(2)添加配置
server.port=8015spring.application.name=xyz-comsumerspring.cloud.consul.host=localhostspring.cloud.consul.port=8500spring.cloud.consul.discovery.register=falsespring.cloud.consul.discovery.health-check-url=/actuator/healthspring.cloud.consul.discovery.heartbeat.enabled=truemanagement.endpoints.web.exposure.include=*management.endpoint.health.show-details=always
(3)測(cè)試方法
獲取所有注冊(cè)的服務(wù),從注冊(cè)的服務(wù)中選取一個(gè),服務(wù)調(diào)用
package com.xyz.comsumer.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.cloud.client.ServiceInstance;import org.springframework.cloud.client.discovery.DiscoveryClient;import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;@RestControllerpublic class HelloController { @Autowired private LoadBalancerClient loadBalancer; @Autowired private DiscoveryClient discoveryClient; private String serviceName = "service-provider"; @RequestMapping("/services") public Object services() { return discoveryClient.getInstances(serviceName); } @RequestMapping("/discover") public Object discover() { return loadBalancer.choose(serviceName).getUri().toString(); } @RequestMapping("/hello") public String hello() { ServiceInstance serviceInstance = loadBalancer.choose(serviceName); String callServiceResult = new RestTemplate().getForObject(serviceInstance.getUri().toString() + "/hello", String.class); return callServiceResult; }}
注:
客戶端調(diào)用的服務(wù)名,是在服務(wù)端指定的,在服務(wù)端配置里使用 spring.cloud.consul.discovery.service-name指注冊(cè)到 Consul 的服務(wù)名稱
測(cè)試
啟動(dòng)Consul
啟動(dòng)provider和provider1
啟動(dòng)comsumer
測(cè)試地址 http://localhost:8015/services
返回結(jié)果
[ { "instanceId": "provider-8010", "serviceId": "service-provider", "host": "hkgi-PC", "port": 8010, "secure": false, "metadata": { "secure": "false" }, "uri": "http://hkgi-PC:8010", "scheme": null }, { "instanceId": "provider-8011", "serviceId": "service-provider", "host": "hkgi-PC", "port": 8011, "secure": false, "metadata": { "secure": "false" }, "uri": "http://hkgi-PC:8011", "scheme": null }]
測(cè)試地址 http://localhost:8015/discover
返回結(jié)果
http://hkgi-PC:8011 或 http://hkgi-PC:8011 測(cè)試地址 http://localhost:8015/hello 返回結(jié)果 hello,provider 或 hello,another provider
注:
結(jié)果交替出現(xiàn)的,這是因?yàn)樨?fù)載均衡器是采用的是輪詢的方式
說明:
調(diào)用的過程:
A.通過LoadBalancerClient查詢服務(wù)
B.通過RestTemplate調(diào)用遠(yuǎn)程服務(wù)
Ribbon負(fù)載均衡策略
BestAvailableRule AvailabilityFilteringRule WeightedResponseTimeRule RetryRule RoundRobinRule RandomRule ZoneAvoidanceRule
自定義Ribbon負(fù)載均衡——使用隨機(jī)訪問策略
修改啟動(dòng)類
package com.xyz.comsumer;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 ComsumerApplication { public static void main(String[] args) { SpringApplication.run(ComsumerApplication.class, args); } @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); }}
服務(wù)調(diào)用
package com.xyz.comsumer.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;@RestControllerpublic class RibbonHelloController { @Autowired private RestTemplate restTemplate; private String serviceName = "service-provider"; @RequestMapping("/ribbon/hello") public String hello() { String callServiceResult = restTemplate.getForObject("http://"+serviceName+"/hello", String.class); return callServiceResult; }}
配置添加
service-provider.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule
重新啟動(dòng) comsumer
測(cè)試地址 http://localhost:8015/ribbon/hello
關(guān)于Springboot2XConsul中怎么利用RestTemplate實(shí)現(xiàn)服務(wù)調(diào)用問題的解答就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。