• demo(一)eureka----服务注册与提供

     下面写一个简单的demo验证下eureka，实现服务注册、服务发现。

    一、单节点：

    1、api：

    封装其他组件需要共用的dto

    2、eureka-service服务注册中心：

    （1）pom:

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0</modelVersion>
    6.  
    7.     <groupId>com.demo.cloud</groupId>
    8.     <artifactId>myspringcloud-eureka-server</artifactId>
    9.     <version>1.0-SNAPSHOT</version>
    10.  
    11.     <!-- springBoot -->
    12.     <parent>
    13.         <groupId>org.springframework.boot</groupId>
    14.         <artifactId>spring-boot-starter-parent</artifactId>
    15.         <version>1.5.9.RELEASE</version>
    16.     </parent>
    17.  
    18.     <properties>
    19.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    20.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    21.         <java.version>1.8</java.version>
    22.         <spring-cloud.version>Edgware.RELEASE</spring-cloud.version>
    23.     </properties>
    24.     <dependencies>
    25.  
    26.         <!--eureka-server-->
    27.         <dependency>
    28.             <groupId>org.springframework.cloud</groupId>
    29.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
    30.         </dependency>
    31.     </dependencies>
    32.  
    33.     <dependencyManagement>
    34.         <dependencies>
    35.             <dependency>
    36.                 <groupId>org.springframework.cloud</groupId>
    37.                 <artifactId>spring-cloud-dependencies</artifactId>
    38.                 <version>${spring-cloud.version}</version>
    39.                 <type>pom</type>
    40.                 <scope>import</scope>
    41.             </dependency>
    42.         </dependencies>
    43.     </dependencyManagement>
    44.  
    45.     <repositories>
    46.         <repository>
    47.             <id>spring-milestones</id>
    48.             <name>Spring Milestones</name>
    49.             <url>https://repo.spring.io/libs-milestone</url>
    50.             <snapshots>
    51.                 <enabled>false</enabled>
    52.             </snapshots>
    53.         </repository>
    54.     </repositories>
    55.     
    56. </project>

     （2）application.properties:在默认设置下，该服务注册中心也会将自己作为客户端来尝试注册它自己，所以需要禁用它的客户端注册行为

    1. server.port=1111
    2. eureka.client.registerWithEureka=false  
    3. eureka.client.fetchRegistry=false  
    4. eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/

    （3）启动类：

    1. package com.demo.cloud;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    6.  
    7. @SpringBootApplication
    8. @EnableEurekaServer
    9. public class MyEurekaServerApplication {
    10.     public static void main(String args[]){
    11.         SpringApplication.run(MyEurekaServerApplication.class,args);
    12.     }
    13. }

    启动后，访问http://localhost:1111/：

    就可以从后台监控服务了，（是不是比dubbo搭建zk注册中心方便多了） ，此时还没有服务注册过来，可以看到application下是空的。

    3、eureka-client注册服务提供者：将原有的springboot工程改造，注册到eureka注册中心

    （1）pom:

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0</modelVersion>
    6.  
    7.     <groupId>com.demo.cloud</groupId>
    8.     <artifactId>myspringcloud-eureka-client</artifactId>
    9.     <version>1.0-SNAPSHOT</version>
    10.     <!-- springBoot -->
    11.     <parent>
    12.         <groupId>org.springframework.boot</groupId>
    13.         <artifactId>spring-boot-starter-parent</artifactId>
    14.         <version>1.5.9.RELEASE</version>
    15.     </parent>
    16.  
    17.     <properties>
    18.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    19.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    20.         <java.version>1.8</java.version>
    21.         <spring-cloud.version>Edgware.RELEASE</spring-cloud.version>
    22.     </properties>
    23.  
    24.     <dependencies>
    25.         <!--eureka-server-->
    26.         <dependency>
    27.             <groupId>org.springframework.cloud</groupId>
    28.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
    29.         </dependency>
    30.  
    31.         <dependency>
    32.             <groupId>com.demo.cloud.api</groupId>
    33.             <artifactId>myspringcloud-api</artifactId>
    34.             <version>1.0-SNAPSHOT</version>
    35.         </dependency>
    36.  
    37.         <dependency>
    38.             <groupId>org.springframework.boot</groupId>
    39.             <artifactId>spring-boot-starter-web</artifactId>
    40.         </dependency>
    41.  
    42.         <!-- mybatis -->
    43.         <dependency>
    44.             <groupId>org.mybatis.spring.boot</groupId>
    45.             <artifactId>mybatis-spring-boot-starter</artifactId>
    46.             <version>1.1.1</version>
    47.         </dependency>
    48.         <dependency>
    49.             <groupId>mysql</groupId>
    50.             <artifactId>mysql-connector-java</artifactId>
    51.             <version>5.1.21</version>
    52.         </dependency>
    53.  
    54.         <dependency>
    55.             <groupId>commons-collections</groupId>
    56.             <artifactId>commons-collections</artifactId>
    57.             <version>3.2.1</version>
    58.         </dependency>
    59.  
    60.         <dependency>
    61.             <groupId>commons-lang</groupId>
    62.             <artifactId>commons-lang</artifactId>
    63.             <version>2.5</version>
    64.         </dependency>
    65.  
    66.     </dependencies>
    67.  
    68.     <dependencyManagement>
    69.         <dependencies>
    70.             <dependency>
    71.                 <groupId>org.springframework.cloud</groupId>
    72.                 <artifactId>spring-cloud-dependencies</artifactId>
    73.                 <version>${spring-cloud.version}</version>
    74.                 <type>pom</type>
    75.                 <scope>import</scope>
    76.             </dependency>
    77.         </dependencies>
    78.     </dependencyManagement>
    79.  
    80.     <repositories>
    81.         <repository>
    82.             <id>spring-milestones</id>
    83.             <name>Spring Milestones</name>
    84.             <url>https://repo.spring.io/libs-milestone</url>
    85.             <snapshots>
    86.                 <enabled>false</enabled>
    87.             </snapshots>
    88.         </repository>
    89.     </repositories>
    90.  
    91. </project>

    （2）application.properties:

    1. server.port=2222
    2. server.context-path=/myService
    3. spring.application.name=my-service
    4. eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
    5.  
    6. #mybatis
    7. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    8. spring.datasource.url=jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=utf-8&useSSL=false
    9. spring.datasource.username=root
    10. spring.datasource.password=wtyy
    11. mybatis.mapper-locations=classpath*:Mapper/*Mapper.xml

    （3）dao、service、Mapper：mybatis持久化部分，此处省略

    （4）controller：

    1. package com.demo.cloud.controller;
    2.  
    3. import com.demo.cloud.dto.AuthorityDTO;
    4. import com.demo.cloud.dto.UserDTO;
    5. import com.demo.cloud.service.UserService;
    6. import org.springframework.beans.factory.annotation.Autowired;
    7. import org.springframework.beans.factory.annotation.Value;
    8. import org.springframework.web.bind.annotation.RequestBody;
    9. import org.springframework.web.bind.annotation.RequestMapping;
    10. import org.springframework.web.bind.annotation.RestController;
    11.  
    12. import java.util.List;
    13.  
    14. @RequestMapping("/user")
    15. @RestController
    16. public class UserApiController {
    17.  
    18.     @Autowired
    19.     private UserService userService;
    20.  
    21.     @Value("${server.port}")
    22.     private String port;
    23.  
    24.     @RequestMapping("/findByUserName")
    25.     public UserDTO findByUserName(String username){
    26.         return userService.findByUserName(username);
    27.     }
    28.  
    29.     @RequestMapping("/getAllUsers")
    30.     public List getAllUsers(){
    31.         System.out.println(port);
    32.         return userService.getAllUsers();
    33.     }
    34.  
    35.     @RequestMapping("/getAuthortiesByUserId")
    36.     public List getAuthortiesByUserId(Integer userId){
    37.         return userService.getAuthortiesByUserId(userId);
    38.     }
    39.  
    40.     @RequestMapping("/addUser")
    41.     public void addUser1(@RequestBody UserDTO userDTO){
    42.         userService.addUser(userDTO);
    43.     }
    44.  
    45. }

    （5）启动类：

    1. package com.demo.cloud;
    2. import org.mybatis.spring.annotation.MapperScan;
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    6.  
    7. @SpringBootApplication
    8. @EnableEurekaClient
    9. @MapperScan("com.demo.cloud.dao")
    10. public class MyEurekaClientApplication {
    11.     public static void main(String args[]){
    12.         SpringApplication.run(MyEurekaClientApplication.class,args);
    13.     }
    14. }

    注意：这里使用的是@EnableEurekaClient注解，也可以使用@EnableDiscoveryClient注解， 

    1. @EnableEurekaClient是Eureka特有的注解，用于启动Eureka客户端。当使用Eureka作为注册中心时，就推荐使用@EnableEurekaClient注解，应用启动后会自动注册到Eureka Server，并完成服务治理。
    2. @EnableDiscoveryClient是Spring Cloud通用的注解，可以与Eureka、Consul等多种注册中心对接。当我们的微服务同时需要与多个注册中心集成时，就需要使用@EnableDiscoveryClient注解。
    3. 可以说，@EnableEurekaClient是@EnableDiscoveryClient的一个具体实现，如果项目中注册中心只使用Eureka，那么使用@EnableEurekaClient更加方便和简单。但如果要切换到其他的注册中心，改动较大。

    启动项目，再浏览下http://localhost:1111/：

    可以看到注册成功了。

    二、高可用部署：

    1、先部署eukera-service的高可用

    2、再部署eureka-client的高可用：连接注册中心的配置项改为多个,以逗号分隔，然后将该组件部署多个节点即可

    eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/,http://xxx.xx.xxx:1111/eureka/

  • 相关阅读:
    SQL执行计划生成
    什么是研学
    轴心时代的三大东方圣人老子、孔子和释迦牟尼
    完美解决docker skywalking报错：no provider found for module storage
    读＜深入理解Java虚拟机-第3版＞
    ListUtil java
    2.SpringSecurity - 处理器简单说明
    13.1 GAS基本框架搭建及第一个GA
    Unity 游戏开发、01 基础篇 | 知识大全、简单功能脚本实现
    最新基于MATLAB 2023a的机器学习、深度学习教程
  • 原文地址：https://blog.csdn.net/w_t_y_y/article/details/134399633