基于Spring Cloud Zookeeper實(shí)現(xiàn)服務(wù)注冊與發(fā)現(xiàn)
服務(wù)注冊
1.添加Spring Cloud Zookeeper依賴:
<dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zookeeper-discovery</artifactId><exclusions><exclusion><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.6.2</version><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies>
2.在服務(wù)配置文件中添加zookeeper配置:
spring: cloud: zookeeper: connect-string: localhost:2181 #zookeeper地址
3.啟動zookeeper服務(wù)器和服務(wù)(我這邊是啟動了兩個服務(wù),分別是provider和consumer),然后在zookeeper客戶端中可以查看已經(jīng)注冊到zookeeper中的服務(wù):

服務(wù)發(fā)現(xiàn)
1.創(chuàng)建controller
消費(fèi)者controller:
package com.buhe.zk.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.RestController;import org.springframework.web.client.RestTemplate;import java.util.List;@RestControllerpublic class ZkConsumerController { private static final String SERVICE_NAME = 'provider'; private static final String SERVICE_PATH = '/zk/provider'; @Autowired private RestTemplate restTemplate; @Autowired private DiscoveryClient discoveryClient; /** * 調(diào)用提供者服務(wù) * @return */ @GetMapping('/zk/consumer') public String zkConsumer(){ return '我吃了' + restTemplate.getForObject('http://' + SERVICE_NAME + SERVICE_PATH, String.class); } /** * 獲取提供者服務(wù)URL * @return */ @GetMapping('/zk/url') public String serviceUrl() { List<ServiceInstance> list = discoveryClient.getInstances(SERVICE_NAME); if (list != null && list.size() > 0 ) { return list.get(0).getUri().toString() + SERVICE_PATH; } return null; }}
要使用RestTemplate別忘了加配置:
@Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();}
提供者controller:
package com.buhe.zk.controller;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class ZkProviderController { @GetMapping('/zk/provider') public String zkProvider(){ return '10個蘋果'; }}
2.服務(wù)調(diào)用

以上就是基于Spring Cloud Zookeeper實(shí)現(xiàn)服務(wù)注冊與發(fā)現(xiàn)的詳細(xì)內(nèi)容,更多關(guān)于Spring Cloud Zookeeper服務(wù)注冊與發(fā)現(xiàn)的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. IDEA 2020.1.2 安裝教程附破解教程詳解2. 利用ajax+php實(shí)現(xiàn)商品價(jià)格計(jì)算3. Java利用TCP協(xié)議實(shí)現(xiàn)客戶端與服務(wù)器通信(附通信源碼)4. 使用AJAX(包含正則表達(dá)式)驗(yàn)證用戶登錄的步驟5. JS圖片懶加載庫VueLazyLoad詳解6. Java實(shí)現(xiàn)的迷宮游戲7. Python 解決火狐瀏覽器不彈出下載框直接下載的問題8. django queryset相加和篩選教程9. Java PreparedStatement用法詳解10. Spring如何集成ibatis項(xiàng)目并實(shí)現(xiàn)dao層基類封裝

網(wǎng)公網(wǎng)安備