SpringCloud+Eureka+Feign+Ribbon的簡化搭建流程和CRUD練習[1]
做者:
故事我忘了￠
我的微信公衆號: 程序猿的月光寶盒
我的微信公衆號: 程序猿的月光寶盒
環境:win10--idea2019--jdk8
1.搭建Eureka服務模塊
1.1 新建eureka服務模塊(Sping Initializr)
取名爲eureka-server,並添加以下Dependencies:java
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/mysql
有畫面則說明啓動成功spring
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
如上圖,有就好了...sql
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.javamybatis
@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.javaapp
//啓用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超過配置值)
相關文章
- 1. thinkjs crud練習
- 2. oozie框架簡介和搭建流程
- 3. java8的stream流練習-1
- 4. 搭建Jenkins簡單流程
- 5. LAMP 搭建練習
- 6. JBPM4.4(1)-簡單工程的搭建
- 7. 一個簡單的自動化流程搭建示例2
- 8. 一個簡單的自動化流程搭建示例
- 9. （2）Dubbo入門到熟練學習-Dubbo-Admin搭建流程
- 10. Elasticsearch學習筆記（1） -- 環境安裝和簡單CRUD
- 更多相關文章...
- • Hibernate的運行流程 - Hibernate教程
- • Swift 環境搭建 - Swift 教程
- • 適用於PHP初學者的學習線路和建議
- • Github 簡明教程
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
