springcloud的eureka集群

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

## 使用的版本 ##

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

## 项目目录 ##

![在这里插入图片描述][20190715143033989.png]

## eureka集群 peer1 ##

#### pom.xml ####

#### application.yml ####

server:
      port: 8761
    spring:
      application:
        name: peer1
    eureka:
      client:
        register-with-eureka: false #是否注册到eureka上 
        fetch-registry: true #获取注册表（eureka集群时候用到）
        service-url:
          defaultZone: http://peer2:8762/eureka #配置eureka的server的注册地址
      instance:
        hostname: peer1

#### 启动类 ####

package com.wuk;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    @EnableEurekaServer
    @SpringBootApplication
    public class MovieServiceEurekaPeer1Application { 
    
    	public static void main(String[] args) { 
    		SpringApplication.run(MovieServiceEurekaPeer1Application.class, args);
    	}
    
    }

## eureka集群 peer2 ##

#### application.yml ####

server:
      port: 8762
    spring:
      application:
        name: peer2
    eureka:
      client:
        register-with-eureka: false #是否注册到eureka上 
        fetch-registry: true #获取注册表（eureka集群时候用到）
        service-url:
          defaultZone: http://peer1:8761/eureka #配置eureka的server的注册地址
      instance:
        hostname: peer2

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

127.0.0.1 peer1 peer2

## 服务者 movie-service-user ##

#### pom.xml ####

<?xml version="1.0" encoding="UTF-8"?>
    <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>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.6.RELEASE</version>
    		
    		<relativePath /> 
    	</parent>
    	<groupId>com.wuk</groupId>
    	<artifactId>movie-service-user</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>movie-service-user</name>
    	<description>Demo project for Spring Boot</description>
    
    	<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-jpa</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-actuator</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<version>5.1.47</version>
    			<scope>runtime</scope>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>com.zaxxer</groupId>
    			<artifactId>HikariCP</artifactId>
    			<version>3.3.1</version>
    		</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>
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>

#### application.yml ####

server:
      port: 8000
    spring:
      application: 
        name: movie-service-user
      jpa:
        show-sql: true
        hibernate:
          ddl-auto: none
        database: MYSQL
      datasource:
        url: jdbc:mysql://127.0.0.1:3306/movieservice
        username: root
        password: root
        driver-class-name: com.mysql.jdbc.Driver  
        type: com.zaxxer.hikari.HikariDataSource
        hikari: 
          minimum-idle: 20
          maximum-pool-size: 60
          max-lifetime: 180000
          auto-commit: true
          idle-timeout: 30000
          pool-name: DatebookHikariCP
          connection-test-query: SELECT 1
          connection-timeout: 30000
        #schema: classpath:sql/user.sql
        #data: classpath:sql/data.sql
    logging:
      level:
        root: info
        com.wuk: debug
    eureka: 
      client:
        service-url:
           defaultZone:  http://peer1:8761/eureka, http://peer2:8762/eureka
      instance:
        prefer-ip-address: true #表示将自己的ip注册到Eureka上面 
        instance-id: movie-service-user:8000

#### 启动类 ####

package com.wuk;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    @EnableEurekaClient
    @SpringBootApplication
    public class MovieServiceUserApplication { 
    
    	public static void main(String[] args) { 
    		SpringApplication.run(MovieServiceUserApplication.class, args);
    	}
    
    }

#### User.ajva ####

package com.wuk.domain;
    
    import java.io.Serializable;
    import java.math.BigDecimal;
    
    import javax.persistence.Column;
    import javax.persistence.Entity;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    
    import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
    
    import lombok.Data;
    
    @Data
    @Entity
    @JsonIgnoreProperties(value = {  "hibernateLazyInitializer", "handler" })
    public class User implements Serializable{ 
    
    	@Id
    	@GeneratedValue(strategy=GenerationType.AUTO)
    	private Long id;
    	@Column
    	private String username;
    	@Column
    	private String name;
    	@Column
    	private Integer age;
    	@Column
    	private BigDecimal balance;
    	
    }

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

#### UserController.java ####

package com.wuk.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.wuk.dao.UserRepository;
    import com.wuk.domain.User;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @RestController
    public class UserController { 
    
    	@Autowired
    	private UserRepository userRepository;
    	
    	@GetMapping("/{id}")
    	public User findById(@PathVariable Long id) { 
    		
    		User user = userRepository.getOne(id);
    		log.info("user={}",user);
    		return user;
    	}
    }

#### UserRepository.java ####

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

## 消费者 ##

#### pom.xml ####

<?xml version="1.0" encoding="UTF-8"?>
    <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>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.6.RELEASE</version>
    		<relativePath/> 
    	</parent>
    	<groupId>com.wuk</groupId>
    	<artifactId>movie-service-movie</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>movie-service-movie</name>
    	<description>Demo project for Spring Boot</description>
    
    	<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    	</properties>
    
    	<dependencies>
    		<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>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    		</dependency>
    		<dependency>
    	        <groupId>com.zaxxer</groupId>
    	        <artifactId>HikariCP</artifactId>
    	        <version>3.3.1</version>
        	</dependency>
        	 <dependency>
    		     <groupId>org.springframework.cloud</groupId>
    		     <artifactId>spring-cloud-netflix-ribbon</artifactId>
    		   </dependency>
    		   <dependency>
    		     <groupId>org.springframework.cloud</groupId>
    		     <artifactId>spring-cloud-starter-config</artifactId>
    		  </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>
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>

注意这两个特别重要  
![在这里插入图片描述][20190715144825465.png]

#### application.yml ####

server:
      port: 8010
    spring:
      application:
        name: movie-service-movie
    eureka:
      client:
        service-url:
           defaultZone:  http://peer1:8761/eureka, http://peer2:8762/eureka 
      instance:
        prefer-ip-address: true #表示将自己的ip注册到Eureka上面
        instance-id: movie-service-movie:8010

#### ConfigBean.java ####

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

#### UserController.java ####

package com.wuk.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import com.wuk.domain.User;
    
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    @RestController
    public class UserController { 
    
    	@Autowired
    	private RestTemplate restTemplate;
    	private String URL="http://movie-service-user:8000"; 
    	
    	@GetMapping("/{id}")
    	public User findById(@PathVariable Long id) { 
    		
    		log.info(URL+"/1");
    		User user=restTemplate.getForObject(URL+"/1", User.class);
    		return user;
    	}
    }

#### 请求访问： ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]

[20190715143033989.png]: /images/20211209/b1985640a4184e7b99ffe3f0288e33df.png
[20190715144825465.png]: /images/20211209/d0adca525a854f60b7ef1ec892286dc7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]: /images/20211209/54a95300f00a4d81b758bf7079136ebe.png