SpringCloud無介紹快使用跳纳,使用Zookeeper替換Eureka服務(wù)注冊(cè)與發(fā)現(xiàn)(十四)

@TOC

問題背景

從零開始學(xué)springcloud微服務(wù)項(xiàng)目
注意事項(xiàng):

  • 約定 > 配置 > 編碼
  • IDEA版本2021.1
  • 這個(gè)項(xiàng)目罚随,我分了很多篇章,每篇文章一個(gè)操作步驟,目的是顯得更簡(jiǎn)單明了
  • controller調(diào)service绵疲,service調(diào)dao
  • 項(xiàng)目源碼以及sentinel安裝包

cloud-payment-service8004搭建

1 創(chuàng)建module



2 選擇jdk1.8



3 輸入服務(wù)名:cloud-provider-payment8004

4 復(fù)制cloud-provider-payment8001到cloud-provider-payment8004,更改啟動(dòng)類

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("查詢結(jié)果哈哈哈hahah:{}", payment);
        if (payment != null) {
            return new CommonResult(200, "查詢成功哈: " + serverPort, payment);
        } else {
            return new CommonResult(500, "沒有對(duì)應(yīng)記錄,查詢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            # 當(dāng)前數(shù)據(jù)源操作類型
    driver-class-name: com.mysql.cj.jdbc.Driver              # mysql驅(qū)動(dòng)包
    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 默認(rèn)已安裝zookeeper臣疑,啟動(dòng)zookeeper盔憨,啟動(dòng)程序,打開postman:http://localhost:8004/payment/zk


7 登錄zookeeper客戶端讯沈,創(chuàng)建的是臨時(shí)節(jié)點(diǎn)

sh zkCli.sh
ls /services/cloud-payment-service
get /services/cloud-payment-service/fd829187-2dfa-4e05-b3bd-76b14a3b263b


使用在線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搭建

1

2

3 輸入服務(wù)名:cloud-consumer-order81

4 復(fù)制cloud-consumer-order80到cloud-consumer-order81郁岩,更改啟動(dòng)類

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:
    #注冊(cè)到zookeeper地址
    zookeeper:
      connect-string: 10.10.195.193:2181

修改controller,zookeeper的服務(wù)名是區(qū)分大小寫的

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請(qǐng)求驯用,但是底層實(shí)質(zhì)發(fā)送post調(diào)用服務(wù)端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("消費(fèi)者調(diào)用支付服務(wù)(zookeeper)--->result:" + result);
        return result;
    }

}

5 啟動(dòng)服務(wù)脸秽,登錄zookeeper客戶端

sh zkCli.sh
ls /services/cloud-consumer-order
get /services/cloud-consumer-order/81355215-85a5-4b84-b3a9-627302b4c3c3

使用在線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處理分布式事務(wù)(二十五)
SpringCloud無介紹快使用蝴乔,sentinel服務(wù)熔斷功能(二十四)
SpringCloud無介紹快使用记餐,sentinel注解@SentinelResource的基本使用(二十三)
SpringCloud無介紹快使用,sentinel熱點(diǎn)key限流與系統(tǒng)規(guī)則的基本使用(二十二)
SpringCloud無介紹快使用薇正,sentinel熔斷降級(jí)和限流的基本使用(二十一)
SpringCloud無介紹快使用片酝,Nacos集群和Nginx代理(二十)
SpringCloud無介紹快使用,nacos配置中心的基本使用(十九)
SpringCloud無介紹快使用挖腰,nacos注冊(cè)中心的基本使用(十八)
SpringCloud無介紹快使用雕沿,gateway通過微服務(wù)名實(shí)現(xiàn)動(dòng)態(tài)路由(十七)
SpringCloud無介紹快使用,gateway的基本使用(十六)
SpringCloud無介紹快使用猴仑,Ribbon負(fù)載均衡工具與OpenFeign的使用(十五)
SpringCloud無介紹快使用审轮,使用Zookeeper替換Eureka服務(wù)注冊(cè)與發(fā)現(xiàn)(十四)
SpringCloud無介紹快使用,服務(wù)發(fā)現(xiàn)Discovery和Eureka自我保護(hù)(十三)
SpringCloud無介紹快使用辽俗,集群cloud-provider-payment8002搭建(十二)
SpringCloud無介紹快使用疾渣,集群Eureka服務(wù)注冊(cè)中心cloud-eureka-server7002搭建(十一)
SpringCloud無介紹快使用,單機(jī)Eureka服務(wù)注冊(cè)中心cloud-eureka-server7001搭建(十)
SpringCloud無介紹快使用崖飘,新建cloud-api-commons公共模塊module(九)
SpringCloud無介紹快使用榴捡,新建子module消費(fèi)者訂單模塊(八)
SpringCloud無介紹快使用,熱部署devtools配置(七)
SpringCloud無介紹快使用朱浴,子module提供者支付微服務(wù)業(yè)務(wù)開發(fā)(六)
SpringCloud無介紹快使用吊圾,新建子module提供者支付微服務(wù)yml整合和新建啟動(dòng)類(五)
SpringCloud無介紹快使用,新建子module提供者支付微服務(wù)pom整合(四)
SpringCloud無介紹快使用翰蠢,springcloud父工程pom文件整理(三)
SpringCloud無介紹快使用项乒,IDEA新建springcloud父工程(二)
SpringCloud無介紹快使用,與Spingboot之間的兼容版本選擇(一)




作為程序員第 181 篇文章躏筏,每次寫一句歌詞記錄一下板丽,看看人生有幾首歌的時(shí)間呈枉,wahahaha ...

Lyric: Mara? dondurmas?

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末趁尼,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子猖辫,更是在濱河造成了極大的恐慌酥泞,老刑警劉巖,帶你破解...
    沈念sama閱讀 223,002評(píng)論 6 519
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件啃憎,死亡現(xiàn)場(chǎng)離奇詭異芝囤,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,357評(píng)論 3 400
  • 文/潘曉璐 我一進(jìn)店門悯姊,熙熙樓的掌柜王于貴愁眉苦臉地迎上來羡藐,“玉大人,你說我怎么就攤上這事悯许∑袜拢” “怎么了?”我有些...
    開封第一講書人閱讀 169,787評(píng)論 0 365
  • 文/不壞的土叔 我叫張陵先壕,是天一觀的道長(zhǎng)瘩扼。 經(jīng)常有香客問我,道長(zhǎng)垃僚,這世上最難降的妖魔是什么集绰? 我笑而不...
    開封第一講書人閱讀 60,237評(píng)論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮谆棺,結(jié)果婚禮上栽燕,老公的妹妹穿的比我還像新娘。我一直安慰自己改淑,他們只是感情好纫谅,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,237評(píng)論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著溅固,像睡著了一般付秕。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上侍郭,一...
    開封第一講書人閱讀 52,821評(píng)論 1 314
  • 那天询吴,我揣著相機(jī)與錄音,去河邊找鬼亮元。 笑死猛计,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的爆捞。 我是一名探鬼主播奉瘤,決...
    沈念sama閱讀 41,236評(píng)論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼煮甥!你這毒婦竟也來了盗温?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 40,196評(píng)論 0 277
  • 序言:老撾萬榮一對(duì)情侶失蹤成肘,失蹤者是張志新(化名)和其女友劉穎卖局,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體双霍,經(jīng)...
    沈念sama閱讀 46,716評(píng)論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡砚偶,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,794評(píng)論 3 343
  • 正文 我和宋清朗相戀三年批销,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片染坯。...
    茶點(diǎn)故事閱讀 40,928評(píng)論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡均芽,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出单鹿,到底是詐尸還是另有隱情骡技,我是刑警寧澤,帶...
    沈念sama閱讀 36,583評(píng)論 5 351
  • 正文 年R本政府宣布羞反,位于F島的核電站布朦,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏昼窗。R本人自食惡果不足惜是趴,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,264評(píng)論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望澄惊。 院中可真熱鬧唆途,春花似錦、人聲如沸掸驱。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,755評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽毕贼。三九已至温赔,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間鬼癣,已是汗流浹背陶贼。 一陣腳步聲響...
    開封第一講書人閱讀 33,869評(píng)論 1 274
  • 我被黑心中介騙來泰國(guó)打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留待秃,地道東北人拜秧。 一個(gè)月前我還...
    沈念sama閱讀 49,378評(píng)論 3 379
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像章郁,于是被迫代替她去往敵國(guó)和親枉氮。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,937評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容