springcloud的eureka集群

末蓝、 2021-12-10 03:49 373阅读 0赞

使用的版本

springcloud版本：Greenwich.SR1
springboot 版本：2.1.6.RELEASE

项目目录

在这里插入图片描述

eureka集群 peer1

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.springframework.boot</groupId>
  6.         <artifactId>spring-boot-starter-parent</artifactId>
  7.         <version>2.1.6.RELEASE</version>
  8.         <relativePath/> <!-- lookup parent from repository -->
  9.     </parent>
  10.     <groupId>com.wuk</groupId>
  11.     <artifactId>movie-service-eureka-peer1</artifactId>
  12.     <version>0.0.1-SNAPSHOT</version>
  13.     <name>movie-service-eureka-peer1</name>
  14.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.         <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
  19.     </properties>
  21.     <dependencies>
  22.         <dependency>
  23.             <groupId>org.springframework.cloud</groupId>
  24.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  25.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-test</artifactId>
  30.             <scope>test</scope>
  31.         </dependency>
  32.     </dependencies>
  34.     <dependencyManagement>
  35.         <dependencies>
  36.             <dependency>
  37.                 <groupId>org.springframework.cloud</groupId>
  38.                 <artifactId>spring-cloud-dependencies</artifactId>
  39.                 <version>${spring-cloud.version}</version>
  40.                 <type>pom</type>
  41.                 <scope>import</scope>
  42.             </dependency>
  43.         </dependencies>
  44.     </dependencyManagement>
  46.     <build>
  47.         <plugins>
  48.             <plugin>
  49.                 <groupId>org.springframework.boot</groupId>
  50.                 <artifactId>spring-boot-maven-plugin</artifactId>
  51.             </plugin>
  52.         </plugins>
  53.     </build>
  55. </project>

application.yml

  1. server:
  2.   port: 8761
  3. spring:
  4.   application:
  5.     name: peer1
  6. eureka:
  7.   client:
  8.     register-with-eureka: false #是否注册到eureka上 
  9.     fetch-registry: true #获取注册表（eureka集群时候用到）
  10.     service-url:
  11.       defaultZone: http://peer2:8762/eureka #配置eureka的server的注册地址
  12.   instance:
  13.     hostname: peer1

启动类

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

eureka集群 peer2

application.yml

  1. server:
  2.   port: 8762
  3. spring:
  4.   application:
  5.     name: peer2
  6. eureka:
  7.   client:
  8.     register-with-eureka: false #是否注册到eureka上 
  9.     fetch-registry: true #获取注册表（eureka集群时候用到）
  10.     service-url:
  11.       defaultZone: http://peer1:8761/eureka #配置eureka的server的注册地址
  12.   instance:
  13.     hostname: peer2

其他的文件都和peer1一致。
注意：
要在host里面配置peer1和peer2
C:\Windows\System32\drivers\etc\hosts

  1. 127.0.0.1 peer1 peer2

服务者 movie-service-user

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <groupId>org.springframework.boot</groupId>
  6.         <artifactId>spring-boot-starter-parent</artifactId>
  7.         <version>2.1.6.RELEASE</version>
  8.         <!-- <version>1.4.3.RELEASE</version> -->
  9.         <relativePath /> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.wuk</groupId>
  12.     <artifactId>movie-service-user</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>movie-service-user</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-data-jpa</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-actuator</artifactId>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>mysql</groupId>
  37.             <artifactId>mysql-connector-java</artifactId>
  38.             <version>5.1.47</version>
  39.             <scope>runtime</scope>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.springframework.boot</groupId>
  43.             <artifactId>spring-boot-starter-test</artifactId>
  44.             <scope>test</scope>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-devtools</artifactId>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>org.projectlombok</groupId>
  52.             <artifactId>lombok</artifactId>
  53.         </dependency>
  54.         <dependency>
  55.             <groupId>org.springframework.cloud</groupId>
  56.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  57.         </dependency>
  58.         <dependency>
  59.             <groupId>com.zaxxer</groupId>
  60.             <artifactId>HikariCP</artifactId>
  61.             <version>3.3.1</version>
  62.         </dependency>
  64.     </dependencies>
  65.     <dependencyManagement>
  66.         <dependencies>
  67.             <dependency>
  68.                 <groupId>org.springframework.cloud</groupId>
  69.                 <artifactId>spring-cloud-dependencies</artifactId>
  70.                 <version>${spring-cloud.version}</version>
  71.                 <type>pom</type>
  72.                 <scope>import</scope>
  73.             </dependency>
  74.         </dependencies>
  75.     </dependencyManagement>
  76.     <build>
  77.         <plugins>
  78.             <plugin>
  79.                 <groupId>org.springframework.boot</groupId>
  80.                 <artifactId>spring-boot-maven-plugin</artifactId>
  81.             </plugin>
  82.         </plugins>
  83.     </build>
  85. </project>

application.yml

  1. server:
  2.   port: 8000
  3. spring:
  4.   application: 
  5.     name: movie-service-user
  6.   jpa:
  7.     show-sql: true
  8.     hibernate:
  9.       ddl-auto: none
  10.     database: MYSQL
  11.   datasource:
  12.     url: jdbc:mysql://127.0.0.1:3306/movieservice
  13.     username: root
  14.     password: root
  15.     driver-class-name: com.mysql.jdbc.Driver  
  16.     type: com.zaxxer.hikari.HikariDataSource
  17.     hikari: 
  18.       minimum-idle: 20
  19.       maximum-pool-size: 60
  20.       max-lifetime: 180000
  21.       auto-commit: true
  22.       idle-timeout: 30000
  23.       pool-name: DatebookHikariCP
  24.       connection-test-query: SELECT 1
  25.       connection-timeout: 30000
  26.     #schema: classpath:sql/user.sql
  27.     #data: classpath:sql/data.sql
  28. logging:
  29.   level:
  30.     root: info
  31.     com.wuk: debug
  32. eureka: 
  33.   client:
  34.     service-url:
  35.        defaultZone:  http://peer1:8761/eureka, http://peer2:8762/eureka
  36.   instance:
  37.     prefer-ip-address: true #表示将自己的ip注册到Eureka上面 
  38.     instance-id: movie-service-user:8000

启动类

  1. package com.wuk;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  6. @EnableEurekaClient
  7. @SpringBootApplication
  8. public class MovieServiceUserApplication { 
  10.     public static void main(String[] args) { 
  11.         SpringApplication.run(MovieServiceUserApplication.class, args);
  12.     }
  14. }

User.ajva

  1. package com.wuk.domain;
  3. import java.io.Serializable;
  4. import java.math.BigDecimal;
  6. import javax.persistence.Column;
  7. import javax.persistence.Entity;
  8. import javax.persistence.GeneratedValue;
  9. import javax.persistence.GenerationType;
  10. import javax.persistence.Id;
  12. import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
  14. import lombok.Data;
  16. @Data
  17. @Entity
  18. @JsonIgnoreProperties(value = {  "hibernateLazyInitializer", "handler" })
  19. public class User implements Serializable{ 
  21.     @Id
  22.     @GeneratedValue(strategy=GenerationType.AUTO)
  23.     private Long id;
  24.     @Column
  25.     private String username;
  26.     @Column
  27.     private String name;
  28.     @Column
  29.     private Integer age;
  30.     @Column
  31.     private BigDecimal balance;
  33. }

注意：
如果访问报错：
No serializer found for class org.hibernate.proxy.pojo.bytebuddy.ByteBuddyInterceptor
加上如下注解
@JsonIgnoreProperties(value = { “hibernateLazyInitializer”, “handler” })

UserController.java

  1. package com.wuk.controller;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.web.bind.annotation.GetMapping;
  5. import org.springframework.web.bind.annotation.PathVariable;
  6. import org.springframework.web.bind.annotation.RestController;
  8. import com.wuk.dao.UserRepository;
  9. import com.wuk.domain.User;
  11. import lombok.extern.slf4j.Slf4j;
  13. @Slf4j
  14. @RestController
  15. public class UserController { 
  17.     @Autowired
  18.     private UserRepository userRepository;
  20.     @GetMapping("/{id}")
  21.     public User findById(@PathVariable Long id) { 
  23.         User user = userRepository.getOne(id);
  24.         log.info("user={}",user);
  25.         return user;
  26.     }
  27. }

UserRepository.java

  1. package com.wuk.dao;
  3. import org.springframework.data.jpa.repository.JpaRepository;
  5. import com.wuk.domain.User;
  7. public interface UserRepository extends JpaRepository<User, Long>{ 
  9. }

消费者

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.6.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.wuk</groupId>
  12.     <artifactId>movie-service-movie</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>movie-service-movie</name>
  15.     <description>Demo project for Spring Boot</description>
  17.     <properties>
  18.         <java.version>1.8</java.version>
  19.         <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-web</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-test</artifactId>
  30.             <scope>test</scope>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.cloud</groupId>
  34.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-devtools</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.projectlombok</groupId>
  42.             <artifactId>lombok</artifactId>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>com.zaxxer</groupId>
  46.             <artifactId>HikariCP</artifactId>
  47.             <version>3.3.1</version>
  48.         </dependency>
  49.          <dependency>
  50.              <groupId>org.springframework.cloud</groupId>
  51.              <artifactId>spring-cloud-netflix-ribbon</artifactId>
  52.            </dependency>
  53.            <dependency>
  54.              <groupId>org.springframework.cloud</groupId>
  55.              <artifactId>spring-cloud-starter-config</artifactId>
  56.           </dependency>
  57.     </dependencies>
  58.     <dependencyManagement>
  59.         <dependencies>
  60.             <dependency>
  61.                 <groupId>org.springframework.cloud</groupId>
  62.                 <artifactId>spring-cloud-dependencies</artifactId>
  63.                 <version>${ spring-cloud.version}</version>
  64.                 <type>pom</type>
  65.                 <scope>import</scope>
  66.             </dependency>
  67.         </dependencies>
  68.     </dependencyManagement>
  69.     <build>
  70.         <plugins>
  71.             <plugin>
  72.                 <groupId>org.springframework.boot</groupId>
  73.                 <artifactId>spring-boot-maven-plugin</artifactId>
  74.             </plugin>
  75.         </plugins>
  76.     </build>
  78. </project>

注意这两个特别重要
在这里插入图片描述

application.yml

  1. server:
  2.   port: 8010
  3. spring:
  4.   application:
  5.     name: movie-service-movie
  6. eureka:
  7.   client:
  8.     service-url:
  9.        defaultZone:  http://peer1:8761/eureka, http://peer2:8762/eureka 
  10.   instance:
  11.     prefer-ip-address: true #表示将自己的ip注册到Eureka上面
  12.     instance-id: movie-service-movie:8010

ConfigBean.java

  1. package com.wuk.config;
  3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.web.client.RestTemplate;
  8. @Configuration
  9. public class ConfigBean { 
  10.     /** * RestTemplate提供了多种便捷访问远程Http服务的方法， 是一种简单便捷的访问restful服务模板类，是Spring提供的用于访问Rest服务的客户端模板工具集 */
  11.     @Bean
  12.     @LoadBalanced//获取rest时候加入Ribbon的配置
  13.     public RestTemplate getRestTemplate() { 
  14.         return new RestTemplate();
  15.     }
  17. }

UserController.java

  1. package com.wuk.controller;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.web.bind.annotation.GetMapping;
  5. import org.springframework.web.bind.annotation.PathVariable;
  6. import org.springframework.web.bind.annotation.RestController;
  7. import org.springframework.web.client.RestTemplate;
  9. import com.wuk.domain.User;
  11. import lombok.extern.slf4j.Slf4j;
  13. @Slf4j
  14. @RestController
  15. public class UserController { 
  17.     @Autowired
  18.     private RestTemplate restTemplate;
  19.     private String URL="http://movie-service-user:8000"; 
  21.     @GetMapping("/{id}")
  22.     public User findById(@PathVariable Long id) { 
  24.         log.info(URL+"/1");
  25.         User user=restTemplate.getForObject(URL+"/1", User.class);
  26.         return user;
  27.     }
  28. }

请求访问：

在这里插入图片描述

发表评论

表情：
评论列表 （有 0 条评论，373人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SpringCloud-eureka集群demo

    eureka的工作方式、原理： •会保存各个注册进来的微服务的基本信息：微服务名、ip、端口等 •eureka还会监控各个微服务的运行情况，做一个基本的监控，每隔30

    川长思鸟来川长思鸟来/ 0 赞/ 68 阅读