2. 程式人生 > >Eureka學習例子

Eureka學習例子

阿新 • • 發佈：2017-12-19
2.x 團隊 普通 repos inter tar 應用程序 tco maven

Eureka學習

例子學習地址：https://github.com/MyCreazy/EurekaStudy

這裏有參考http://blog.csdn.net/nero__a/article/details/65631367進行總結操作

Spring Cloud下有很多工程：

  • Spring Cloud Config：依靠git倉庫實現的中心化配置管理。配置資源可以映射到Spring的不同開發環境中，但是也可以使用在非Spring應用中。
  • Spring Cloud Netflix：不同的Netflix OSS組件的集合：Eureka、Hystrix、Zuul、Archaius等。
  • Spring Cloud Bus：事件總線，利用分布式消息將多個服務連接起來。非常適合在集群中傳播狀態的改變事件（例如：配置變更事件）
  • Spring Cloud Consul：服務發現和配置管理，由Hashicorp團隊開發。我決定先從Spring Cloud Netflix看起，它提供了如下的功能特性：
  • 服務發現：Eureka-server實例作為服務提供者，可以註冊到服務註冊中心，Eureka客戶端可以通過Spring管理的bean發現實例；
  • 服務發現：嵌套式的Eureka服務可以通過聲明式的Java配置文件創建；
  • 斷路器：利用註解，可以創建一個簡單的Hystrix客戶端；
  • 斷路器：通過Java配置文件可以創建內嵌的Hystrix控制面板；
  • 聲明式REST客戶端：使用Feign可以創建聲明式、模板化的HTTP客戶端；
  • 客戶端負載均衡器：Ribbon
  • 路由器和過濾器：Zuul可以在微服務架構中提供路由功能、身份驗證、服務遷移、金絲雀發布等功能。

1. 服務註冊中心

在IDEA中創建一個Spring Cloud工程，引入Eureka-Server包，pom文件整體如下：

<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">

<modelVersion>4.0.0</modelVersion>

<groupId>com.sl</groupId>

<artifactId>RegistryCenter</artifactId>

<version>0.0.1-SNAPSHOT</version>

<packaging>jar</packaging>

<name>RegistryCenter</name>

<url>http://maven.apache.org</url>

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

</properties>

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>1.3.5.RELEASE</version>

<relativePath/>

</parent>

<dependencies>

<!-- 用於註冊中心訪問賬號認證 -->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-security</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

<!-- 註冊中心所需的包 -->

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-eureka-server</artifactId>

</dependency>

</dependencies>

<dependencyManagement>

<dependencies>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-dependencies</artifactId>

<version>Brixton.RELEASE</version>

<type>pom</type>

<scope>import</scope>

</dependency>

</dependencies>

</dependencyManagement>

<!-- spring boot的maven打包插件 -->

<build>

<defaultGoal>compile</defaultGoal>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

</project>

創建APP類，並用@EnableEurekaServer和@SpringBootApplication兩個註解修飾，後者是Spring Boot應用都需要用的，這裏不作過多解釋；@EnableEurekaServer註解的作用是觸發Spring Boot的自動配置機制，由於我們之前在pom文件中導入了eureka-server，spring boot會在容器中創建對應的bean。Eureka的代碼如下：

package com.sl.RegistryCenter;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.boot.builder.SpringApplicationBuilder;

import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**

* Hello world!

*

*/

@EnableEurekaServer

@SpringBootApplication

public class App {

public static void main(String[] args) {

new SpringApplicationBuilder(App.class).web(true).run(args);

}

}

添加配置文件application.properties，並且添加如下參數，才能創建一個真正可以使用的服務註冊中心。

######eureka服務端######

spring.application.name=eureka-server

#驅逐下線的服務，間隔,5秒，默認是60，建議開發和測試環境配置

eureka.server.evictionIntervalTimerInMs=10000

server.port=8761

#是否需要註冊到註冊中心，因為該項目本身作為服務註冊中心，所以為false

eureka.client.register-with-eureka=false

#是否需要從註冊中心獲取服務列表，原因同上，為false

eureka.client.fetch-registry=false

security.basic.enabled=true

security.user.name=admin

security.user.password=123

#註冊服務器的地址：服務提供者和服務消費者都要依賴這個地址

eureka.client.serviceUrl.defaultZone=http://admin:123@localhost:8761/eureka

###Eureka自我保護機制,為true表示開，false表示關，默認為開####

eureka.server.enable-self-preservation=true

啟動註冊服務，並訪問：http://localhost:8761，就可以看到如下界面。

2. 服務提供者

創建一個Spring Boot工程，代表服務提供者，該服務提供者會暴露一個當前請求產生的時間字符串。

工程的pom文件內容如下：

<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">

<modelVersion>4.0.0</modelVersion>

<groupId>com.sl</groupId>

<artifactId>TestMicroService</artifactId>

<version>0.0.1-SNAPSHOT</version>

<packaging>jar</packaging>

<name>TestMicroService</name>

<url>http://maven.apache.org</url>

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

</properties>

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>1.3.5.RELEASE</version>

<relativePath /> <!-- lookup parent from repository -->

</parent>

<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-eureka</artifactId>

</dependency>

<!-- 用於註冊中心訪問賬號認證 -->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-actuator</artifactId>

</dependency>

</dependencies>

<dependencyManagement>

<dependencies>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-dependencies</artifactId>

<version>Brixton.RELEASE</version>

<type>pom</type>

<scope>import</scope>

</dependency>

</dependencies>

</dependencyManagement>

<build>

<defaultGoal>compile</defaultGoal>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

</project>

其中的關鍵在於spring-cloud-starter-eureka這個Jar包，其中包含了eureka的客戶端實現。

在src/main/java/com.sl.TestMicroService下創建工程的主類App，使用@EnableDiscoveryClient註解修飾，該註解在服務啟動的時候，可以觸發服務註冊的過程，向配置文件中指定的服務註冊中心（Eureka-Server）的地址註冊自己提供的服務。App的源碼如下：

package com.sl.TestMicroService;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.boot.builder.SpringApplicationBuilder;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**

* Hello world!

*

*/

@EnableDiscoveryClient

@SpringBootApplication

public class App {

public static void main(String[] args) {

new SpringApplicationBuilder(App.class).web(true).run(args);

}

}

application.properties配置文件的內容如下：

server.port=8111

#設置應用的名稱

spring.application.name=microservice-provider-user

#服務註冊的Eureka Server地址

eureka.client.serviceUrl.defaultZone=http://admin:123@localhost:8761/eureka

#設置註冊ip

eureka.instance.prefer-ip-address=true

#自定義應用實例id

#健康檢查

eureka.client.healthcheck.enabled=true

服務提供者的基本框架搭好後，需要實現服務的具體內容，在ComputeController類中實現，它的具體代碼如下：

package com.sl.TestMicroService;

import java.text.SimpleDateFormat;

import java.util.Date;

import org.apache.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cloud.client.ServiceInstance;

import org.springframework.cloud.client.discovery.DiscoveryClient;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

@RestController

public class ComputeController {

private final Logger logger = Logger.getLogger(getClass());

@Autowired

private DiscoveryClient client;

private SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

@RequestMapping(value = "/test", method = RequestMethod.GET)

public String test() {

ServiceInstance instance = client.getLocalServiceInstance();

String temp = "當前時間【" + df.format(new Date()) + "】/add, host:" + instance.getHost() + ", service_id:"

+ instance.getServiceId();

logger.info(temp);

return temp;

}

}

先啟動服務註冊中心的工程，然後再啟動服務提供者，在訪問：localhost:8761，如下圖所示，服務提供者已經註冊到服務註冊中心啦，下圖可以查看

在Spring Cloud Netflix中，使用Ribbon實現客戶端負載均衡，使用Feign實現聲明式HTTP客戶端調用——即寫得像本地函數調用一樣。

3. 服務消費者-Feign

pom配置如下：

<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">

<modelVersion>4.0.0</modelVersion>

<groupId>com.sl</groupId>

<artifactId>ServiceConsumer</artifactId>

<version>0.0.1-SNAPSHOT</version>

<packaging>jar</packaging>

<name>ServiceConsumer</name>

<url>http://maven.apache.org</url>

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>1.3.5.RELEASE</version>

<relativePath /> <!-- lookup parent from repository -->

</parent>

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

</properties>

<build>

<defaultGoal>compile</defaultGoal>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

<dependencies>

<!-- Feign實現聲明式HTTP客戶端 -->

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-feign</artifactId>

</dependency>

<!-- eureka客戶端 -->

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-eureka</artifactId>

</dependency>

<!-- spring boot實現Java Web服務-->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

</dependencies>

<dependencyManagement>

<dependencies>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-dependencies</artifactId>

<version>Brixton.RELEASE</version>

<type>pom</type>

<scope>import</scope>

</dependency>

</dependencies>

</dependencyManagement>

</project>

首先創建應用程序啟動類：ConsumerApp，代碼如下：

package com.sl.ServiceConsumer;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

import org.springframework.cloud.netflix.feign.EnableFeignClients;

/**

* Hello world!

*

*/

@EnableDiscoveryClient // 用於啟動服務發現功能

@EnableFeignClients // 用於啟動Fegin功能

@SpringBootApplication

public class ConsumerApp {

/**

* main函數入口

*

* @param args

*/

public static void main(String[] args) {

SpringApplication.run(ConsumerApp.class);

}

}

然後創建ComputeClient接口，使用@FeignClient("microservice-provider-user")註解修飾，microservice-provider-user就是服務提供者的名稱，然後定義要使用的服務，代碼如下：

package com.sl.ServiceConsumer;

import org.springframework.cloud.netflix.feign.FeignClient;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

@FeignClient("microservice-provider-user")

public interface ConsumerClient {

// @RequestMapping(method = RequestMethod.GET, value = "/add")

// Integer add(@RequestParam(value = "a") Integer a, @RequestParam(value =

// "b") Integer b);

@RequestMapping(method = RequestMethod.GET, value = "/test")

String test();

}

在ConsumerController中，像引入普通的spring bean一樣引入ComputeClient對象，其他的和Ribbon的類似。

package com.sl.ServiceConsumer;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

@RestController

public class ConsumerController {

@Autowired

private ConsumerClient computeClient;

@RequestMapping(value = "/test", method = RequestMethod.GET)

public String test() {

return computeClient.test();

}

}

application.properties的內容如下：

#應用名稱

spring.application.name=fegin-consumer

#端口號

server.port=9000

#註冊中心的地址

eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

啟動fegin消費者，訪問localhost:9000/add，也可以看到服務提供者已經收到了消費者發來的請求。

可以看到兩個服務輪流被調用

註意事項

1.關於版本對應問題

  • Angel版本對應Spring Boot 1.2.x
  • Brixton版本對應Spring Boot 1.3.x
  • Camden版本對應Spring Boot 1.4.x

2.直接打包

打包時記得引用下面的包

<build>

<defaultGoal>compile</defaultGoal>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

Eureka學習例子

相關推薦

Eureka學習例子

2.x 團隊 普通 repos inter tar 應用程序 tco maven Eureka學習 例子學習地址：https://github.com/MyCreazy/EurekaStudy 這裏有參考http://blog.csdn.net/nero__a/articl

【python學習】今天看看學習 %d ,%s, %f 等用法，下面的學習例子是說輸入名字、年齡、工作，工資。並給出65歲退休還差多久的計算

msg ear end style 資料 科學 一個 保留 value 今天看看學習 %d ,%s, %f 等用法。%d 是占位符整數，%s 是占位符，%f 是浮點數。下面的學習例子是說輸入名字、年齡、工作，工資。並給出65歲退休還差多久的計算。重點在於用占位符來print

Markdown學習例子

tro ges 引用 例子 cnblogs 超鏈接 block 圖片 huang 運維文檔 一級標題 二級標題 選擇一 選擇二 三級標題 選擇一 選擇二 選擇三 這裏是一段引用 這是一個學習Markdown的超鏈接例子 這裏是加粗強調，這裏是傾斜 強調

Spring Boot 學習例子

base restfu lda tle sub spl over ber display 01.spring-boot-restfulservice 02.spring-boot-consumer 03.spring-boot-upload 04.spring-boot

eureka學習_1

開發工具：idea 版本：springcloud 2.1.0 首先建立一個空的專案資料夾，新增兩個模組來進行學習。 新增jar server：Eureka Server client：Eureka Discovery、Web 這樣前置準備就完成了。 然後，配置yml檔案，這裡跟以前cloud版本

夏農熵學習+例子[轉載]

轉自：https://www.cnblogs.com/wyuzl/p/7699818.html  1.在決策樹演算法中，就是根據資訊理論的方法找到最合適的特徵來劃分資料集。在這裡，我們首先要計算所有類別的所有可能值的夏農熵，根據夏農熵來我們按照取最大資訊增益（information gain）的方

事件的學習例子

1.利用委託實現事件例子   using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threadi

SpringCloud之Eureka學習筆記

Eureka介紹及原理 理解 Eureka就像一個物業管理公司，其他微服務就像小區的住戶，每個住戶入住時都要向物業管理公司註冊，並定時向物業公司交管理費。 介紹 Eureka是一個基於REST的服務，用於定位服務，以實現雲端中間層服務發現和故障轉移。 Eureka主管服務註冊與發現，

RNN：執行paddlepaddle語言學習例子訓練報錯彙總

1. Non-ASCII character ‘\xb6’ 報錯截圖 解決辦法 在py檔案第一行增加：#-*- coding: UTF-8 -*- 2. unexpected indent 報錯截圖 解決辦法 python依靠indent來縮排。要麼

Spring Cloud Eureka學習筆記

用於服務的註冊於發現 由兩個元件組成 Eureka Server 註冊中心 Eureka Client 服務註冊 Eureka Server(服務註冊中心) 先建立一個springboot專案，新增依賴的時候選擇如下 pom檔案如下 <?xml ve

QML學習例子一

心血來潮，在公司學習了幾天的QML，於是乎週末回家後寫個小例子練練手，於是就有了下面的QML頁面.該頁面還算比較簡單，實現了滾動切換，希望對初學者學習QML有點幫助。 執行：在QT的bin目錄下找到qml.exe，執行以下命令即可: qml.exe MainWndView.qml

Spring2 cloud eureka學習(一)

1、建立artifactId為microservice-discovery-eureka的maven工程。（spring boot 為2.0.3） <parent> <groupId>org.springframework.boot</groupId&

Spring-cloud微服務 Eureka學習教程-分散式搭建EurekaServer、EurekaClient（中級）

        我們這裡只有一臺伺服器，所以我們先仿叢集搭建。          完整demo專案程式碼：https://github.com/wades2/EurekaDemo2   &nb

Spring-cloud微服務 Eureka學習教程-單伺服器配置之快速搭建EurekaServer、EurekaClient（基礎）

以下例項程式碼下載地址：https://github.com/wades2/EurekaDemo        Eureka是Spring Cloud Netflix的一個子模組，也是核心模組之一。用於雲端服務發現，一個基於REST的服務，用於定位服務，以

java反射學習例子

反射的簡單的例子練習 package reflect; import java.lang.reflect.Constructor; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetE

spark深度學習例子音樂推薦程式碼

object MusicRecommend { def musicRecommend()={ val conf = new SparkConf().setAppName("musicRecommend") val sc =

java介面學習例子

你應該知道介面是一種契約，它與實現方式無關但是類，即使是抽象類，你都能自定義成員變數，而成員變數往往就與實現方式有關。這一點的實際意義不大。但是有一點，類會暴露太多不必要，甚至不能暴露的東西，你看一下java.util中，大部分的資料結構，都被設計成了介面-抽象類-最後實際類例如Collection-List

【深度學習基礎-02】概念學習-例子3則

目錄 概念學習： 概念學習舉例子1（教小孩子認識小鳥）： 概念學習舉例子2（判斷小明是否“享受運動”） 概念學習舉例子3（美國矽谷房價的學習）  一些基本知識點： 概念有兩大分類： 監督學習的例子： 本部落格基本概念：訓練集、測試集、特徵值、監督學習、非

Ant學習例子2(用ant釋出web專案，及連線資料庫)

<project>          <property name="build.dir" location="build"></property>     <property name="src.dir" location="src"></proper

CFRunLoop 學習 例子，控制 runloop 時間

#import "ViewController.h" @interface ViewController () @end @implementation ViewController - (void)viewDidLoad { [super viewDidLo