当前位置：首页>后端>正文

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）

后端2024-05-04 05:51:26

@TOC

问题背景

从零开始学springcloud微服务项目
注意事项：

约定 > 配置 > 编码
IDEA版本2021.1
这个项目，我分了很多篇章，每篇文章一个操作步骤，目的是显得更简单明了
controller调service，service调dao
项目源码以及sentinel安装包

cloud-payment-service8004搭建

1 创建module

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第1张

2 选择jdk1.8

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第2张

3 输入服务名：cloud-provider-payment8004

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第3张

4 复制cloud-provider-payment8001到cloud-provider-payment8004，更改启动类

package com.yg.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * @Author suolong
 * @Date 2022/6/14 20:31
 * @Version 2.0
 */
@EnableDiscoveryClient
@SpringBootApplication
public class PaymentMain8004 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8004.class);
    }
}

更改PaymentController

package com.yg.springcloud.controller;

import com.yg.springcloud.entities.CommonResult;
import com.yg.springcloud.entities.Payment;
import com.yg.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;
import java.util.UUID;

/**
 * @Author suolong
 * @Date 2022/6/14 21:36
 * @Version 2.0
 */
@RestController
@Slf4j
public class PaymentController {

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

    @Resource
    private PaymentService paymentService;

    @Resource
    private DiscoveryClient discoveryClient;

    @PostMapping(value = "/payment/create")
    public CommonResult create(@RequestBody Payment payment) {
        int result = paymentService.create(payment);
        log.info("result哈哈哈: {}", result);
        if (result > 0) {
            return new CommonResult(200, "插入成功", result);
        }
        return new CommonResult(500, "插入失败", null);
    }

    @GetMapping(value = "/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id) {
        Payment payment = paymentService.getPaymentById(id);
        log.info("查询结果哈哈哈hahah:{}", payment);
        if (payment != null) {
            return new CommonResult(200, "查询成功哈: " + serverPort, payment);
        } else {
            return new CommonResult(500, "没有对应记录,查询ID: " + id, null);
        }
    }


    @GetMapping(value = "/payment/discovery")
    public Object discovery() {
        List<String> services = discoveryClient.getServices();
        for (String element : services) {
            System.out.println(element);
        }

        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance element : instances) {
            System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
                    + element.getUri());
        }
        return this.discoveryClient;
    }

    @GetMapping(value = "/payment/zk")
    public String paymentzk() {
        return "springcloud with zookeeper: " + serverPort + "\t" + UUID.randomUUID().toString();
    }

}

5 更改application

server:
  port: 8004

spring:
  application:
    name: cloud-payment-service
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
    driver-class-name: com.mysql.cj.jdbc.Driver              # mysql驱动包
    url: jdbc:mysql://localhost:3306/mysqltest?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
    username: root
    password: 123456
  cloud:
    zookeeper:
      connect-string: 192.168.207.128:2181

mybatis:
  mapperLocations: classpath:mapper/*.xml
  type-aliases-package: com.yg.springcloud.entities    # 所有Entity别名类所在包

6 默认已安装zookeeper，启动zookeeper，启动程序，打开postman：http://localhost:8004/payment/zk

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第4张

7 登录zookeeper客户端，创建的是临时节点

sh zkCli.sh

ls /services/cloud-payment-service

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第5张

get /services/cloud-payment-service/fd829187-2dfa-4e05-b3bd-76b14a3b263b

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第6张

使用在线json查看json串：

{
    "name": "cloud-payment-service",
    "id": "fd829187-2dfa-4e05-b3bd-76b14a3b263b",
    "address": "B-YUAN-G.com",
    "port": 8004,
    "sslPort": null,
    "payload": {
        "@class": "org.springframework.cloud.zookeeper.discovery.ZookeeperInstance",
        "id": "application-1",
        "name": "cloud-payment-service",
        "metadata": {}
    },
    "registrationTimeUTC": 1655518957100,
    "serviceType": "DYNAMIC",
    "uriSpec": {
        "parts": [{
            "value": "scheme",
            "variable": true
        }, {
            "value": "://",
            "variable": false
        }, {
            "value": "address",
            "variable": true
        }, {
            "value": ":",
            "variable": false
        }, {
            "value": "port",
            "variable": true
        }]
    }
}

cloud-consumer-order81搭建

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第7张

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第8张

3 输入服务名：cloud-consumer-order81

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第9张

4 复制cloud-consumer-order80到cloud-consumer-order81，更改启动类

package com.yg.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @Author suolong
 * @Date 2022/6/15 15:10
 * @Version 2.0
 */
@SpringBootApplication
public class MainApp81 {

    public static void main(String[] args) {
        SpringApplication.run(MainApp81.class);
    }

}

引入pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2022</artifactId>
        <groupId>com.yg</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-consumer-order81</artifactId>

    <dependencies>
        <!-- SpringBoot整合zookeeper客户端 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>
        <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
            <groupId>com.yg</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</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>

</project>

修改application文件

server:
  port: 81


spring:
  application:
    name: cloud-consumer-order
  cloud:
    #注册到zookeeper地址
    zookeeper:
      connect-string: 10.10.195.193:2181

修改controller，zookeeper的服务名是区分大小写的

package com.yg.springcloud.controller;

import com.yg.springcloud.entities.CommonResult;
import com.yg.springcloud.entities.Payment;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**
 * @Author suolong
 * @Date 2022/6/15 20:54
 * @Version 2.0
 */

@RestController
public class OrderController {


    //public static final String PaymentSrv_URL = "http://localhost:8001";
    public static final String PaymentSrv_URL = "http://cloud-payment-service";


    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/consumer/payment/create") //客户端用浏览器是get请求，但是底层实质发送post调用服务端8001
    public CommonResult create(Payment payment) {
        return restTemplate.postForObject(PaymentSrv_URL + "/payment/create", payment, CommonResult.class);
    }


    @GetMapping("/consumer/payment/get/{id}")
    public CommonResult getPayment(@PathVariable Long id) {
        return restTemplate.getForObject(PaymentSrv_URL + "/payment/get/" + id, CommonResult.class, id);
    }

    @GetMapping(value = "/consumer/zk")
    public String paymentInfo()
    {
        String result = restTemplate.getForObject(PaymentSrv_URL+"/payment/zk", String.class);
        System.out.println("消费者调用支付服务(zookeeper)--->result:" + result);
        return result;
    }

}

5 启动服务，登录zookeeper客户端

sh zkCli.sh

ls /services/cloud-consumer-order

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第10张

get /services/cloud-consumer-order/81355215-85a5-4b84-b3a9-627302b4c3c3

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第11张

使用在线json查看json串：

{
    "name": "cloud-consumer-order",
    "id": "81355215-85a5-4b84-b3a9-627302b4c3c3",
    "address": "B-YUAN-G.com",
    "port": 81,
    "sslPort": null,
    "payload": {
        "@class": "org.springframework.cloud.zookeeper.discovery.ZookeeperInstance",
        "id": "application-1",
        "name": "cloud-consumer-order",
        "metadata": {}
    },
    "registrationTimeUTC": 1655524194818,
    "serviceType": "DYNAMIC",
    "uriSpec": {
        "parts": [{
            "value": "scheme",
            "variable": true
        }, {
            "value": "://",
            "variable": false
        }, {
            "value": "address",
            "variable": true
        }, {
            "value": ":",
            "variable": false
        }, {
            "value": "port",
            "variable": true
        }]
    }
}

SpringCloud无介绍快使用，Seata处理分布式事务（二十五）
SpringCloud无介绍快使用，sentinel服务熔断功能（二十四）
SpringCloud无介绍快使用，sentinel注解@SentinelResource的基本使用（二十三）
SpringCloud无介绍快使用，sentinel热点key限流与系统规则的基本使用（二十二）
SpringCloud无介绍快使用，sentinel熔断降级和限流的基本使用（二十一）
SpringCloud无介绍快使用，Nacos集群和Nginx代理（二十）
SpringCloud无介绍快使用，nacos配置中心的基本使用（十九）
SpringCloud无介绍快使用，nacos注册中心的基本使用（十八）
SpringCloud无介绍快使用，gateway通过微服务名实现动态路由（十七）
SpringCloud无介绍快使用，gateway的基本使用（十六）
SpringCloud无介绍快使用，Ribbon负载均衡工具与OpenFeign的使用（十五）
SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）
SpringCloud无介绍快使用，服务发现Discovery和Eureka自我保护（十三）
SpringCloud无介绍快使用，集群cloud-provider-payment8002搭建（十二）
SpringCloud无介绍快使用，集群Eureka服务注册中心cloud-eureka-server7002搭建（十一）
SpringCloud无介绍快使用，单机Eureka服务注册中心cloud-eureka-server7001搭建（十）
SpringCloud无介绍快使用，新建cloud-api-commons公共模块module（九）
SpringCloud无介绍快使用，新建子module消费者订单模块（八）
SpringCloud无介绍快使用，热部署devtools配置（七）
SpringCloud无介绍快使用，子module提供者支付微服务业务开发（六）
SpringCloud无介绍快使用，新建子module提供者支付微服务yml整合和新建启动类（五）
SpringCloud无介绍快使用，新建子module提供者支付微服务pom整合（四）
SpringCloud无介绍快使用，springcloud父工程pom文件整理（三）
SpringCloud无介绍快使用，IDEA新建springcloud父工程（二）
SpringCloud无介绍快使用，与Spingboot之间的兼容版本选择（一）

作为程序员第 181 篇文章，每次写一句歌词记录一下，看看人生有几首歌的时间，wahahaha ...

SpringCloud无介绍快使用，使用Zookeeper替换Eureka服务注册与发现（十四）,第12张

Lyric： Mara? dondurmas?

查看全文

https://www.xamrdz.com/backend/33a1941470.html

问题背景

cloud-payment-service8004搭建

cloud-consumer-order81搭建

Lyric： Mara? dondurmas?

相关文章：