SpringCloud+Eureka+Feign+Ribbon的簡化搭建流程和CRUD練習

来源:https://www.cnblogs.com/jsccc520/archive/2019/12/20/12075547.html
-Advertisement-
Play Games

作者:個人微信公眾號:程式猿的月光寶盒 環境:win10 idea2019 jdk8 1.搭建Eureka服務模塊 1.1 新建eureka服務模塊(Sping Initializr) 取名為 ,並添加如下Dependencies: 1.2 配置 1.3 在啟動類前加上註解 1.4 開啟啟動器,並訪 ...


作者:程式猿的月光寶盒

環境:win10--idea2019--jdk8

1.搭建Eureka服務模塊

1.1 新建eureka服務模塊(Sping Initializr)

取名為eureka-server,並添加如下Dependencies:

圖片

1.2 配置application.properties

#配置埠
server.port=8761

#spring 的應用名=一般是模塊名
spring.application.name=eureka-server

#當前模塊是否註冊為eureka的客戶端
# --->因為當前應用應該是服務端
# --->所以選false
eureka.client.register-with-eureka=false

#既然不是客戶端,那麼是否
# 在Server Center 註冊?
# --->不要,因為當前應用本來就是server
eureka.client.fetch-registry=false
#------------------------------------------
#eureka.客戶端.服務url.預設區域,${server.port} 動態獲取port-->即第1行的8761
eureka.client.serviceUrl.defaultZone=http://localhost:${server.port}/eureka

1.3 在啟動類前加上註解@EnableEurekaServer

//啟用Eureka伺服器
@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}

1.4 開啟啟動器,並訪問,測試是否正確配置eureka的服務端

本機訪問http://localhost:8761/

有畫面則說明啟動成功

圖片

2.編寫公共的實體類模塊

2.1 新建普通maven-quickstart工程

圖片

圖片

2.2 在pom文件中添加lombok坐標(用於簡化實體類)

  <dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.12</version>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <version>1.18.10</version>
    </dependency>
  </dependencies>

2.3 編寫實體類

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Dept implements Serializable {
    private Integer deptno;
    private String dname;
    private String loc;
}
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Emp implements Serializable {
    private Integer empno;
    private String ename;
    private String job;
    private Integer mgr;
    private java.sql.Date hiredate;
    private Double sal;
    private Double comm;
    private Integer deptno;
}

2.4 然後用maven打包工具先clean然後再install打包到本地倉庫

圖片

2.4.1 檢查本地倉庫是否有對應的jar

圖片

如上圖,有就行了...

3. 編寫provider-one模塊

3.1 新建Spring Initializr 工程

圖片

圖片

3.2 在pom中加入公共實體類的依賴,並修改資料庫驅動版本號為5.1.38

<dependency>
            <groupId>cn.kgc</groupId>
            <artifactId>employee-common</artifactId>
            <version>1.0-SNAPSHOT</version>
</dependency>

<dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <!--修改版本號-->
            <version>5.1.38</version>
</dependency>

3.3 編寫 實體類的mapper

DeptMapper.java

@Mapper
public interface DeptMapper {
    @Select("select * from dept")
    List<Map<String,Object>>selAllDeptData();
}

3.4 編寫service

DeptService.java

public interface DeptService {
    List<Map<String,Object>> optionData();
}

3.5 編寫serviceImpl

DeptServiceImpl.java

@Service
public class DeptServiceImpl implements DeptService {
    @Autowired
    private DeptMapper deptMapper;
    @Override
    public List<Map<String, Object>> optionData() {
        return deptMapper.selAllDeptData();
    }
}

3.6 編寫中心控制類

CenterController.java

@RestController
public class CenterController {
    @Autowired
    private DeptService deptService;
    @GetMapping("/optionData.do")
    public List<Map<String, Object>> optionData() {
        return deptService.optionData();
    }
}

3.7 編寫配置文件

application.properties

#服務埠號
server.port=8762
#應用名
spring.application.name=provider
#eureka客戶端服務url預設區域
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

#數據源驅動類名
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
#數據源url,www.52cc.monster為我的伺服器,但是可能在國外,time out 噁心死我了  還是用回localhost或者國內阿裡的
spring.datasource.url=jdbc:mysql://www.52cc.monster:3306/kh75
#數據源用戶名
spring.datasource.username=root
#數據源密碼
spring.datasource.password=****

#後期會寫mapper.xml,這裡先註釋
#mybatis.mapper-locations=classpath:mapper/*.xml

#給實體類起別名,同樣這裡先註釋
#mybatis.type-aliases-package=cn.kgc.vo

3.8 在啟動類上加註解

ProviderOneApplication.java

//啟用eureka客戶端
@EnableEurekaClient
//Mapper掃描,對應的mapper包
@MapperScan("cn.kgc.mapper")
@SpringBootApplication
public class ProviderOneApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderOneApplication.class, args);
    }
}

4.編寫consumer模塊

4.1 新建Spring Initializr 工程

圖片

圖片

4.2 在pom中加入公共實體類的依賴

<dependency>
            <groupId>cn.kgc</groupId>
            <artifactId>employee-common</artifactId>
            <version>1.0-SNAPSHOT</version>
</dependency>

4.3 編寫Feign類

CenterFeign.java

/**
 * 是consumer調用provider（需要指定provider的名字）
 * 請求的清單列表：規定調用地址、參數、返回值
 */
@FeignClient(name = "provider")
public interface CenterFeign {
    @GetMapping("/optionData.do")
    public List<Map<String, Object>> optionData();
}

4.4 編寫中心控制類CenterController

CenterController.java

@RestController
public class CenterController  {
    @Autowired
    private CenterFeign centerFeign;
    @GetMapping("/optionData-consumer.do")
    public List<Map<String, Object>> optionData() {
        return centerFeign.optionData();
    }
}

4.5 編寫配置文件

application.properties

#埠號
server.port=8764
#應用名
spring.application.name=consumer
#eureka客戶端服務url預設區域
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
#下線名稱.ribbon.NF載入平衡規則類名,這裡先註釋
#provider.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule

4.6在啟動類上添加註解

ConsumerApplication.java

//開啟Feign客戶端
@EnableFeignClients
//開啟eureka客戶端
@EnableEurekaClient
@SpringBootApplication
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

5.用postman測試介面

圖片

已查出數據....

6. 重覆以上3.3-4中步驟,建立新的mapper

6.1 更新provider-one模塊

EmpMapper.java

public interface EmpMapper {
    @Select(
            "<script>" +
            "    select d.dname,d.loc,e.* from emp e,dept d WHERE e.deptno=d.deptno" +
            "    <if test='deptno!=-1 and deptno!=null'>" +
            "        and e.deptno=#{deptno}" +
            "    </if>" +
            "    <if test='empno!=null'>" +
            "        and e.empno=#{empno}" +
            "    </if>" +
            "</script>" )
    List<Map<String,Object>> selEmpData(Emp emp);

    @Insert("insert into emp(empno,ename,sal,job,deptno) values(#{empno},#{ename},#{sal},#{job},#{deptno})")
    Integer insert(Emp emp);

    @Update("update emp set ename=#{ename},sal=#{sal},job=#{job},deptno=#{deptno} where empno=#{empno}")
    Integer updEmp(Emp emp);

    @Delete("delete from emp where empno=#{empno}")
    Integer delEmpByPrimaryKey(Integer empno);
}

​ EmpService.java

public interface EmpService {

    List<Map<String,Object>> showEmpData(Emp emp);

    Integer add(Emp emp);

    Integer edit(Emp emp);

    Integer del(Integer empno);
}

EmpServiceImpl.java

@Service
@Transactional
public class EmpServiceImpl implements EmpService {
    @Autowired
    private EmpMapper empMapper;
    @Override
    public List<Map<String, Object>> showEmpData(Emp emp) {
        return empMapper.selEmpData(emp);
    }

    @Override
    public Integer add(Emp emp) {
        return empMapper.insert(emp);
    }

    @Override
    public Integer edit(Emp emp) {
        return empMapper.updEmp(emp);
    }

    @Override
    public Integer del(Integer empno) {
        return empMapper.delEmpByPrimaryKey(empno);
    }
}

更新中心控制類

CenterController.java

@RestController
public class CenterController {
    @Autowired
    private DeptService deptService;
    @Autowired
    private EmpService empService;
    @GetMapping("/optionData.do")
    public List<Map<String, Object>> optionData() {
        return deptService.optionData();
    }

    @PostMapping("/showEmpData.do")
    //Feign：不支持對象傳參,所以要用@RequestBody
    public List<Map<String, Object>> showEmpData(@RequestBody Emp emp) {
        return empService.showEmpData(emp);
    }

    @PostMapping("/add.do")
    public Integer add(@RequestBody Emp emp) {
        return empService.add(emp);
    }

    @PostMapping("/edit.do")
    public Integer edit(@RequestBody  Emp emp) {
        return empService.edit(emp);
    }

    @GetMapping("/del.do")
    public Integer del(@RequestParam("empno") Integer empno) {
        return empService.del(empno);
    }
}

6.2 更新consumer模塊

更新feign類

@FeignClient(name = "provider")
public interface CenterFeign {
    @GetMapping("/optionData.do")
    public List<Map<String, Object>> optionData();

    @PostMapping("/showEmpData.do")
    //Feign：不支持對象傳參,所以要用@RequestBody
    public List<Map<String, Object>> showEmpData(@RequestBody Emp emp);

    @PostMapping("/add.do")
    public Integer add(@RequestBody Emp emp);

    @PostMapping("/edit.do")
    public Integer edit(@RequestBody  Emp emp);

    @GetMapping("/del.do")
    public Integer del(@RequestParam("empno") Integer empno);
}

更新consumer的controller

@RestController
public class CenterController{
    @Autowired
    private CenterFeign centerFeign;

    @GetMapping("/optionData-consumer.do")
    public List<Map<String, Object>> optionData() {
        return centerFeign.optionData();
    }

    @PostMapping("/showEmpData-consumer.do")
    public List<Map<String, Object>> showEmpData(@RequestBody Emp emp) {
        return centerFeign.showEmpData(emp);
    }

    @PostMapping("/add-consumer.do")
    public Integer add(@RequestBody Emp emp) {
        return centerFeign.add(emp);
    }

    @PostMapping("/edit-consumer.do")
    public Integer edit(@RequestBody Emp emp) {
        return centerFeign.edit(emp);
    }

    @GetMapping("/del-consumer.do")
    public Integer del(@RequestParam("empno") Integer empno) {
        return centerFeign.del(empno);
    }
}

再用postman測試,都沒有問題

註意,這裡測試的都是http://localhost:8764/XXX-consumer.do的url

XXX為consumer的controller中的Mapping映射

7. 新建provider-two模塊

步驟和3一樣,就名改成two

7.1 在pom中加入公共實體類的依賴,並修改資料庫驅動版本號為5.1.38

<dependency>
            <groupId>cn.kgc</groupId>
            <artifactId>employee-common</artifactId>
            <version>1.0-SNAPSHOT</version>
</dependency>

<dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <!--修改版本號-->
            <version>5.1.38</version>
</dependency>

7.2 把one的cn.kgc下的包都扒拉過來

圖片

7.3 再更新啟動類,加註解,也直接扒拉

//啟用eureka客戶端
@EnableEurekaClient
//Mapper掃描,對應的mapper包
@MapperScan("cn.kgc.mapper")
@SpringBootApplication
public class ProviderTwoApplication {

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

}

7.4 再更新配置文件application.properties,也直接扒拉,把埠號改一改

#服務埠號
server.port=8763
#應用名
spring.application.name=provider
#eureka客戶端服務url預設區域
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

#數據源驅動類名
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
#數據源url
spring.datasource.url=jdbc:mysql:///kh75
#數據源用戶名
spring.datasource.username=root
#數據源密碼
spring.datasource.password=admin



#後期會寫mapper.xml,這裡先註釋
#mybatis.mapper-locations=classpath:mapper/*.xml

#給實體類起別名,同樣這裡先註釋
#mybatis.type-aliases-package=cn.kgc.vo

8. 更新consumer中的配置文件,把原來註釋的下線放出來

application.properties

#埠號
server.port=8764
#應用名
spring.application.name=consumer
#eureka客戶端服務url預設區域
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
#下線名稱.ribbon.NF載入平衡規則類名,預設是輪詢,現在改為隨機,RandomRule:隨機選擇一個服務節點
provider.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule

9. 為了看清楚是不是隨機,在這加控制台列印

9.1 在provider-one 的控制類的 /showEmpData.do中加列印

   @PostMapping("/showEmpData.do")
    //Feign：不支持對象傳參,所以要用@RequestBody
    public List<Map<String, Object>> showEmpData(@RequestBody Emp emp) {
        System.out.println("provider-one>>>>"+emp);
        return empService.showEmpData(emp);
    }

9.2 在provider-two 的控制類的 /showEmpData.do中加列印

    @PostMapping("/showEmpData.do")
    //Feign：不支持對象傳參,所以要用@RequestBody
    public List<Map<String, Object>> showEmpData(@RequestBody Emp emp) {
        System.out.println("provide-two>>>>"+emp);
        return empService.showEmpData(emp);
    }

9.3 這裡只用postman測 /showEmpData-consumer.do 測10次看後臺列印是不是隨機的

9.3.1 結果

one:有6個

圖片

two:有4個

圖片

所以負載均衡策略是隨機的

那現在把上面的註釋

#下線名稱.ribbon.NF載入平衡規則類名,這裡先註釋provider.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule

圖片

還是測10次,結果:

one:5次

圖片

two:5次

圖片

為了防止巧合,再測10次一共20次,結果:

one:10次

圖片

two:10次

圖片

所以,以下這句話起作用了

#下線名稱.ribbon.NF載入平衡規則類名,這裡先註釋provider.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule

10.整體結構圖

圖片

10.1employee-common

圖片

10.2eureka-server

圖片

10.3employee-common

圖片

10.4provider-one

圖片

10.5provider-two

圖片

10.6consumer

圖片

11.拓展,Ribbon提供的7種負載均衡策略:

Ribbon提供了多鐘負載均衡策略:
1 WeightedResponseTimeRule:根據響應時間分配一個weight(權重,大小的概念),響應時間和weight成反比
2.RoundRobinRule:輪詢選擇服務節點(預設的負載均衡策略)
3.RandomRule:隨機選擇一個服務節點
4.ZoneAvoidanceRule:綜合考慮服務節點所在區域的性能和服務節點的可用性來選擇服務節點
5.RetryRule:重試機制.在一個配置時間段內,當選擇服節點不成功時會一直嘗試重新選擇
6.BestAvailableRule:選擇一個併發請求最小的伺服器節點.
7.AvailabilityFilteringRule:過濾掉因為一直連接失敗而被標記為circuit tripped的服務節點和那些高併發的服務節點(active connections超過配置值)


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 從組件文檔引發的慘案 ◤1◢
    公司目前有很多後臺管理系統，目前代碼量都越來越大，在開發的過程中，我們也秉承著提取公共組件，通過復用組件來減少開發工作量，隨著公共組件數量的增加，新同事想要快速瞭解公共組件如何使用，需要到具體的業務頁面中去看，這樣子學習組件的成本太大，於是就想給每個組件提供一個文檔，來解釋組件如何使用。 恰巧之前有 ...
  • 2020年值得你去試試的10個React開發工具
    本文由葡萄城技術團隊翻譯並首發 轉載請註明出處：葡萄城官網，葡萄城為開發者提供專業的開發工具、解決方案和服務，賦能開發者。 JavaScript每天都在出現大量的框架和工具，而React是除了上次我們提到的Vue和Ember之外另一款比較流行的框架。但因為新的工具每天都在不斷的出現，開發者在嘗試時總 ...
  • JS---封裝緩動（變速）動畫函數---增加任意一個屬性
    封裝緩動(變速)動畫 增加任意一個屬性 1. 本來的變速動畫函數，是獲取特定的屬性(之前案例是向右移動，所以獲取的是left屬性) 2. 現在改變為，獲取任意一個屬性，使其移動到指定的target，相當於在原animate(element,target)函數上，增加了一個屬性，變為animate(e ...
  • [修仙之路]React-Redux 金丹篇
    作者：水濤追求技術，但又不失生活的樂趣，過自己想要的生活 React-Redux簡介 React-Redux可以使你的React項目擁有全局數據，可以使多個React組件讀取到全局數據並且組件中也可修改它。 React-Redux你可以理解為Vue中的Vuex,也是一種全局狀態（不懂Vue的這條略過 ...
  • JS---獲取元素計算後的樣式屬性值 (getComputedStyle)---相容函數
    獲取計算後的樣式屬性 獲取一個元素任意一個樣式屬性值 獲取元素距離左邊位置的值 會有如下相容性問題： my$("btn").onclick = function () { //獲取元素距離左邊位置的值 console.log(my$("dv").offsetLeft); //谷歌,火狐支持 //co ...
  • C++ lambda expression
    Emerged since c++11, lambda expression/function is an unnamed function object capable of capturing variables in scope. 1. syntax of a lambda expressio ...
  • Python連載58-http協議簡介
    一、http協議實戰 1.URL(Uniform Resource Located) （1）使用FFTP的URL，例如：ftp://rtfm.mit.edu （2）使用HTTP的URL，例如：http://www.baidu.com 2.HTTP工作原理 （1）瀏覽器分析超i鏈接中的URL （2）瀏 ...
  • Centos7上離線搭建PHP-7.2.26
    一、下載php源安裝包，解壓至/home/php目錄下 下載地址：https://www.php.net/distributions/php-7.2.26.tar.gz [root@localhost home]# tar -zxvf php-7.2.26.tar.gz #在這裡是上傳到了/home ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類