基于Spring Cloud Zookeeper实现服务注册与发现

基于Spring Cloud Zookeeper实现服务注册与发现

服务注册

1.添加Spring Cloud Zookeeper依赖:

org.springframework.cloud

spring-cloud-starter-zookeeper-discovery

org.apache.zookeeper

zookeeper

org.apache.zookeeper

zookeeper

ehkluc

org.apache.zookeeper

zookeeper

3.6.2

org.slf4j

slf4j-log4j12

org.springframework.boot

spring-boot-starter-web

2.在服务配置文件中添加zookeeper配置:

spring:

cloud:

zookeeper:

connect-string: localhost:2181 #zookeeper地址

3.启动zookeeper服务器和服务（我这边是启动了两个服务，分别是provider和consumer），然后在zookeeper客户端中可以查看已经注册到zookeeper中的服务:

服务发现

1.创建controller

消费者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;

@RestController

public 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;

/**

* 调用提供者服务

* @return

*/

@GetMapping("/zk/consumer")

public String zkConsumer(){

return "我吃了" + restTemplate.getForObject("http://" + SERVICE_NAME + SERVICE_PATH, String.class);

}

/**

* 获取提供者服务URL

* @return

*/

@GetMapping("/zk/url")

public String serviceUrl() {

List list = discoveryClient.getInstances(SERVICE_NAME);

if (list != null && list.size() > 0 ) {

return list.get(0).getUri().toString() + SERVICE_PATH;

}

return null;

}

}

要使用RestTemplate别忘了加配置：

@Bean

@LoadBalanced

public 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;

@RestController

public class ZkProviderController {

@GetMapping("/zk/provider")

public String zkProvider(){

return "10个苹果";

}

}

2.服务调用

以上就是基于Spring Cloud Zookeeper实现服务注册与发现的详细内容，更多关于Spring Cloud Zookeeper服务注册与发现的资料请关注我们其它相关文章！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。