Eureka Server入門項(xiàng)目搭建
(剛開始學(xué)習(xí)微服務(wù)架構(gòu),來記錄下.)
一:單體應(yīng)用與微服務(wù)
? ? 1.單體應(yīng)用缺點(diǎn)
? ? ? ? ? ? 1.1 開發(fā)速度慢
????????????1. 2 啟動(dòng)時(shí)間長(zhǎng)
????????????1. 3 依賴龐大
????????????????......等等
? ? ? ? 2.什么是微服務(wù)
? ? ? ? ? ? ? ? ?2.1. 微服務(wù)架構(gòu)設(shè)計(jì)代表了一種架構(gòu)設(shè)計(jì)思想无蜂,再配合上容器技術(shù)(如Docker)避矢,可以在程序開發(fā)上的流程腹躁、 部署庄蹋、服務(wù)維護(hù)等各方面的效率得到很大提升览徒。
? ? ? ? ? ? ? ? ?2.2. 微服務(wù)就是將一個(gè)單體架構(gòu)的應(yīng)用按業(yè)務(wù)劃分為一個(gè)個(gè)的獨(dú)立運(yùn)行的程序即服務(wù)哀蘑,它們之間通過 HTTP協(xié)議進(jìn)行通信(也可以采用消息隊(duì)列來通信顿苇,如 RoocketMQ撩满,Kafaka等)僵刮,可以采用不同的編程語言,使用不同的存儲(chǔ)技術(shù)鹦牛,自動(dòng)化部署(如Jenkins)減少人為控制搞糕,降低出錯(cuò)概率。服務(wù)數(shù)量越多曼追,管理起來越復(fù)雜窍仰,因此采用集中化管理。例如 Eureka礼殊,Zookeeper等都是比較常見的服務(wù)集中化管理框架
? ? ? ? ? ? ? ? ?2.3. .........
? ? ? ? 3.微服務(wù)的好處
? ? ? ? ? ? ? ? 3.1. 可以將一個(gè)龐大的單體架構(gòu)的應(yīng)用按業(yè)務(wù)切分為多個(gè)具有不同服務(wù)的程序應(yīng)用,各自獨(dú)立運(yùn)行,每個(gè)服務(wù)都有一個(gè)定義清楚的邊界驹吮,通過 RPC- 或者消息驅(qū)動(dòng)API與外接溝通,單個(gè)微服務(wù)相比單體應(yīng)用更容易開發(fā)和維護(hù).
? ? ? ? ? ? ? ? ?3.2. 微服務(wù)架構(gòu)使得每個(gè)微服務(wù)獨(dú)立部署晶伦。加快部署速度,這樣一來,每個(gè)服務(wù)都屬于一個(gè)單獨(dú)的個(gè)體,對(duì)服務(wù)的維護(hù),升級(jí),擴(kuò)展等帶來極大的便利
? ? ? ? ? ? ? ? ? ? ?3.3. .....
? ? ? ? 4.微服務(wù)架構(gòu)的不足之處
? ? ? ? ? ? ? ? ?4.1. 微服務(wù)應(yīng)用是一個(gè)分布式系統(tǒng)碟狞,由此會(huì)帶來分布式系統(tǒng)固有的復(fù)雜性.
? ? ? ? ? ? ? ? ?4.2. 多個(gè)服務(wù)之間的依賴問題,相關(guān)應(yīng)用的升級(jí)以及修改等有可能會(huì)波及多個(gè)服務(wù)模塊的修改.在以往單體應(yīng)用中,只需要修改相關(guān)的模塊便可婚陪,整合后一并部署族沃。而微服務(wù)架構(gòu)模式,修改服務(wù)模塊時(shí)就需要考慮服務(wù)間的依賴關(guān)系
? ? ? ? ? ? ? ? ?4.3. 分布式系統(tǒng)--->分布式事務(wù)問題
? ? ? ? ? ? ? ? ?4.4. 需要管理多個(gè)服務(wù)-->服務(wù)治理
另:微服務(wù)核心知識(shí) :網(wǎng)關(guān)、服務(wù)發(fā)現(xiàn)注冊(cè)、配置中心脆淹、鏈路追蹤常空、負(fù)載均衡器、熔斷...等
1. 網(wǎng)關(guān):路由轉(zhuǎn)發(fā) + 過濾器
????????????????????/api/v1/pruduct/? ? ? 商品服務(wù)
? ? ? ? ? ? ? ? ? ? ?/api/v1/order/? ? ? ? 訂單服務(wù)
????????????????????/api/v1/user/? ? 用戶服務(wù)
2. 服務(wù)注冊(cè)發(fā)現(xiàn):調(diào)用和被調(diào)用方的信息維護(hù)
3. 配置中心:管理配置盖溺,動(dòng)態(tài)更新 application.properties
4. 鏈路追蹤:分析調(diào)用鏈路耗時(shí)
例子:下單-》查詢商品服務(wù)獲取商品價(jià)格-》查詢用戶信息-》保存數(shù)據(jù)庫
5. 負(fù)載均衡器:分發(fā)負(fù)載
6. 熔斷:保護(hù)自己和被調(diào)用方
常見的微服務(wù)框架:
1. consumer: 調(diào)用方
2. provider: 被調(diào)用方
一個(gè)接口一般都會(huì)充當(dāng)兩個(gè)角色(不是同時(shí)充當(dāng))
1漓糙、dubbo: zookeeper + dubbo + springmvc/springboot
官方地址:http://dubbo.apache.org/#!/?lang=zh-cn
配套
通信方式:rpc
注冊(cè)中心:zookeper/redis
配置中心:diamond
2、springcloud: 全家桶+輕松嵌入第三方組件(Netflix 奈飛)
官網(wǎng):http://projects.spring.io/spring-cloud/
配套
通信方式:http restful
注冊(cè)中心:eruka/consul
配置中心:config
斷路器:hystrix
網(wǎng)關(guān):zuul
分布式追蹤系統(tǒng):sleuth+zipkin
二:搭建步驟
(剛開始學(xué)習(xí),我這里使用的是Eureka)
**項(xiàng)目結(jié)構(gòu):**
? (我這里按照習(xí)慣,建的是"父子工程",當(dāng)然也可以新建兩個(gè)獨(dú)立工程,編輯器:IDEA)
1.新建一個(gè)空白的父工程,src以及其他暫時(shí)用不著的東西可以先刪除
? (步驟略)
? 2.新建第一個(gè)Module,用來做"注冊(cè)中心"
入門項(xiàng)目,業(yè)務(wù)不多,依賴選擇一個(gè)即可,項(xiàng)目創(chuàng)建好后的依賴:
<properties>
? ? ? ? <java.version>1.8</java.version>
? ? ? ? <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>
? ? </properties>
? ? <dependencies>
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.springframework.cloud</groupId>
? ? ? ? ? ? <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
? ? ? ? </dependency>
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.springframework.boot</groupId>
? ? ? ? ? ? <artifactId>spring-boot-starter-test</artifactId>
? ? ? ? ? ? <scope>test</scope>
? ? ? ? ? ? <exclusions>
? ? ? ? ? ? ? ? <exclusion>
? ? ? ? ? ? ? ? ? ? <groupId>org.junit.vintage</groupId>
? ? ? ? ? ? ? ? ? ? <artifactId>junit-vintage-engine</artifactId>
? ? ? ? ? ? ? ? </exclusion>
? ? ? ? ? ? </exclusions>
? ? ? ? </dependency>
? ? </dependencies>
? ? <dependencyManagement>
? ? ? ? <dependencies>
? ? ? ? ? ? <dependency>
? ? ? ? ? ? ? ? <groupId>org.springframework.cloud</groupId>
? ? ? ? ? ? ? ? <artifactId>spring-cloud-dependencies</artifactId>
? ? ? ? ? ? ? ? <version>${spring-cloud.version}</version>
? ? ? ? ? ? ? ? <type>pom</type>
? ? ? ? ? ? ? ? <scope>import</scope>
? ? ? ? ? ? </dependency>
? ? ? ? </dependencies>
? ? </dependencyManagement>
3.在啟動(dòng)類上添加注解:@EnableEurekaServer
4.添加配置(application.yml):
server:
? port: 8761
eureka:
? instance:
? ? hostname: localhost
? client:
? ? #聲明自己是服務(wù)端
? ? registerWithEureka: false
? ? fetchRegistry: false
? ? serviceUrl:
? ? ? defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
5.啟動(dòng)服務(wù):方式跟平常啟動(dòng)sprinboot應(yīng)用一樣
瀏覽器輸入:http://localhost:8761/
一個(gè)簡(jiǎn)單的"注冊(cè)中心"創(chuàng)建完畢
6.創(chuàng)建第二個(gè)Module:商品服務(wù)
依賴選擇:
7.分別創(chuàng)建實(shí)體類,service,controller;
實(shí)體類:
//Product.java
package com.xt.tools.eureka.product_server.domain;
import lombok.Data;
/*
* @description: 說明
* @author: 小譚
* @date: 2019/12/5 20:04
*/
@Data
public class Product {
? ? private int id;
? ? private String name;
? ? private int price;
? ? private int store;
? ? public Product(int id, String name, int price, int store) {
? ? ? ? this.id = id;
? ? ? ? this.name = name;
? ? ? ? this.price = price;
? ? ? ? this.store = store;
? ? }
? ? public Product() {}
}
service接口:
//ProductService.java
package com.xt.tools.eureka.product_server.service;
import com.xt.tools.eureka.product_server.domain.Product;
import java.util.List;
/*
* @description: 說明
* @author: 小譚
* @date: 2019/12/5 20:06
*/
public interface ProductService {
? ? List<Product> ListProduct();
? ? Product findById(int id);
}
service接口實(shí)現(xiàn)類:
package com.xt.tools.eureka.product_server.service;
import com.xt.tools.eureka.product_server.domain.Product;
import org.springframework.stereotype.Service;
import java.util.*;
/*
* @description: 說明
* @author: 小譚
* @date: 2019/12/5 20:09
*/
@Service
public class ProductServiceImpl implements ProductService {
? ? private static Map<Integer,Product> daoMap = new HashMap<>();
? ? static {
? ? ? ? Product p1 = new Product(1,"iphonex",9999, 10);
? ? ? ? Product p2 = new Product(2,"冰箱",5342, 19);
? ? ? ? Product p3 = new Product(3,"洗衣機(jī)",523, 90);
? ? ? ? Product p4 = new Product(4,"電話",64345, 150);
? ? ? ? Product p5 = new Product(5,"汽車",2345, 140);
? ? ? ? Product p6 = new Product(6,"椅子",253, 20);
? ? ? ? Product p7 = new Product(7,"java編程思想",2341, 10);
? ? ? ? daoMap.put(p1.getId(),p1);
? ? ? ? daoMap.put(p2.getId(),p2);
? ? ? ? daoMap.put(p3.getId(),p3);
? ? ? ? daoMap.put(p4.getId(),p4);
? ? ? ? daoMap.put(p5.getId(),p5);
? ? ? ? daoMap.put(p6.getId(),p6);
? ? ? ? daoMap.put(p7.getId(),p7);
? ? }
? ? @Override
? ? public List<Product> ListProduct() {
? ? ? ? Collection<Product> values = daoMap.values();
? ? ? ? List<Product> products = new ArrayList<>(values);
? ? ? ? return products;
? ? }
? ? @Override
? ? public Product findById(int id) {
? ? ? ? return daoMap.get(id);
? ? }
}
controller:
package com.xt.tools.eureka.product_server.controller;
import com.xt.tools.eureka.product_server.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
/*
* @description: 說明
* @author: 小譚
* @date: 2019/12/5 20:03
*/
@RestController
@RequestMapping("/api/v1/product")
public class productController {
? ? @Autowired
? ? private ProductService productService;
? ? @RequestMapping("list")
? ? public Object List(){
? ? ? ? return productService.ListProduct();
? ? }
? ? @RequestMapping("find")
? ? public Object product(@RequestParam("id") int id){
? ? ? ? return productService.findById(id);
? ? }
}
最后,配置文件:
server:
? port: 8771
#指定spring應(yīng)用名稱
spring:
? application:
? ? name: product-server
#指定注冊(cè)中心地址
eureka:
? client:
? ? serviceUrl:
? ? ? defaultZone: http://localhost:8761/eureka/
現(xiàn)在可以啟動(dòng)服務(wù)了,至于這個(gè)Module的啟動(dòng)類的注解:@EnableEurekaClient,可加可不加
(1):http://localhost:8771/api/v1/product/list
(2):http://localhost:8771/api/v1/product/find?id=2
有數(shù)據(jù)返回,功能一切正常,再來刷新一下注冊(cè)中心:
與開始相比,頁面多出了一些東西,目前,商品服務(wù)已成功注冊(cè)進(jìn)去了,
問題一:eureka管理后臺(tái)出現(xiàn)一串紅色字體:是警告烘嘱,說明有服務(wù)上線率低
EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY'RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.
關(guān)閉檢查方法:eureka服務(wù)端配置文件加入
server:
enable-self-preservation: false
注意:自我保護(hù)模式禁止關(guān)閉昆禽,默認(rèn)是開啟狀態(tài)true
問題二:為什么只加一個(gè)注冊(cè)中心地址,就可以注冊(cè)
官方解釋:(https://cloud.spring.io/spring-cloud-netflix/reference/html/#service-discovery-eureka-clients):
By having spring-cloud-starter-netflix-eureka-client on the classpath, your application automatically registers with the Eureka Server. Configuration is required to locate the Eureka server, as shown in the following example:
google翻譯:
通過在類路徑上使用spring-cloud-starter-netflix-eureka-client蝇庭,您的應(yīng)用程序?qū)⒆詣?dòng)向Eureka Server注冊(cè)为狸。需要配置以找到Eureka服務(wù)器,如以下示例所示
github項(xiàng)目: https://github.com/XT962464oo/Eureka_demo