天天看点

SpringCloud整合Zookeeper代替Eureka一.前言二.SpringCloud整合Zookeeper

目录

  • 一.前言
  • 二.SpringCloud整合Zookeeper
    • 1.Docker部署Zookeeper
    • 2.服务注册进Zookeeper
    • 3.启动测试调用服务

一.前言

现在的Eureka已经停更了,当然可以使用,也可以使用其他的代替Eureka,比如Zookeeper、Consul、还有SpringCloud Alibaba 的Nacos都可以作为服务的注册中心,本文就是记录一下SpringCloud整合Zookeeper的详细步骤

二.SpringCloud整合Zookeeper

1.Docker部署Zookeeper

  • 下载zookeeper镜像
docker pull zookeeper
           
  • 查看镜像
docker images
           
  • 运行zookeeper镜像
docker run --name zk01 --restart always -d -p 2181:2181 镜像id
           
  • 进入zookeeper容器
docker exec -it c92d46f793af /bin/bash
           
  • 进入zkCli.sh
cd bin/
./zkCli.sh
           

可以看到当前没有其他服务

SpringCloud整合Zookeeper代替Eureka一.前言二.SpringCloud整合Zookeeper

2.服务注册进Zookeeper

  • 创建支付服务 cloud-provider-payment8004

pom.xml:

<dependencies>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
        <!-- 引入自己定义的api通用包,可以使用Payment支付Entity -->
            <groupId>com.baidu</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- SpringBoot整合zookeeper客户端 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
           

application.yml:

#8004表示注册到zookeeper服务器的支付服务提供者端口号
server:
  port: 8004

#服务别名----注册zookeeper到注册中心名称
spring:
  application:
    name: cloud-provider-payment
  cloud:
    zookeeper:
      connect-string: 192.168.85.130:2181
           

controller:

@RestController
@Slf4j
public class PaymentController {

    @Value("${server.port}")
    private String serverPort;

    @RequestMapping("/payment/zk")
    public String paymentZk(){

        return "springCloud with zookeeper:"+serverPort+"\t"+ UUID.randomUUID().toString();
    }
}
           

主启动类:

@SpringBootApplication
@EnableDiscoveryClient
public class PaymentMain8004 {
     public static void main(String[] args) {
           SpringApplication.run(PaymentMain8004.class, args);
      }
}
           
  • 创建订单服务cloud-consumerzk-order80

    pom.xml:

<dependencies>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
        <!-- 引入自己定义的api通用包,可以使用Payment支付Entity -->
            <groupId>com.baidu</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- SpringBoot整合zookeeper客户端 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
           

application.yml:

server:
  port: 80
#服务别名----注册zookeeper到注册中心名称
spring:
  application:
    name: cloud-consumerzk-order
  cloud:
    zookeeper:
      connect-string: 192.168.85.130:2181
           

config/ApplicationContextConfig:配置RestTemplate

@Configuration
public class ApplicationContextConfig {
    @LoadBalanced
    @Bean
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}
           

controller:

@RestController
@Slf4j
public class OrderZkController {

    public static final String INVOKE_URL = "http://cloud-provider-payment";

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/consumer/payment/zk")
    public String paymentInfo(){
        String result = restTemplate.getForObject(INVOKE_URL+"/payment/zk",String.class);
        return result;
    }
}
           

主启动类:

@SpringBootApplication
@EnableDiscoveryClient
public class OrderZkMain80 {
     public static void main(String[] args) {
           SpringApplication.run(OrderZkMain80.class, args);
      }
}
           

3.启动测试调用服务

再次查看zookeeper,两个服务已经注册进zookeeper了!

SpringCloud整合Zookeeper代替Eureka一.前言二.SpringCloud整合Zookeeper
SpringCloud整合Zookeeper代替Eureka一.前言二.SpringCloud整合Zookeeper

订单服务调用支付服务也成功了!

SpringCloud整合Zookeeper代替Eureka一.前言二.SpringCloud整合Zookeeper