SpringCloud EureKa服务集群

浅浅的花香味﹌ 2022-02-13 03:15 314阅读 0赞

1、pom文件（由于我服务里用到redis，之前在[ SpringBoot整合redis及遇到的版本问题][SpringBoot_redis] 里讲过，springBoot2.1.x版本跟redis兼容有问题，所以这里使用2.0.6）

<modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.0.6.RELEASE</version>
    		<relativePath/> 
    	</parent>
    	<groupId>com.luzx.EurekaClient</groupId>
    	<artifactId>EurekaClient</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>EurekaClient</name> 
    	<description>Demo project for Spring Boot</description>
    
    	<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Finchley.SR2</spring-cloud.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</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-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		
    		
    		<dependency>
            	<groupId>org.springframework.boot</groupId>
            	<artifactId>spring-boot-devtools</artifactId>
            	<optional>true</optional>
        	</dependency>
    		
    		
            <dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-redis</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>

2、配置文件

#springCloud
    #是否注册自身到eureka服务器
    eureka.client.registerWithEureka=true
    #是否从eureka服务器获取注册信息
    eureka.client.fetchRegistry=true
    #注册地址
    eureka.client.serviceUrl.defaultZone=http://xx.xx.xx.xx:9980/eureka/
    # 每间隔1s，向服务端发送一次心跳，证明自己依然存活
    eureka.client.lease-renewal-interval-in-seconds=1
    #告诉服务端，如果我10s之内没有给你发心跳，就代表我“死”了，将我踢出掉
    eureka.client.lease-expiration-duration-in-seconds=10
    #网卡禁用
    #spring.cloud.inetutils.ignored-interfaces[0]=eth0
    
    
    # Redis数据库索引（默认为0）
    spring.redis.database=0
    # Redis服务器地址
    #spring.redis.host=
    # Redis服务器连接端口
    #spring.redis.port=7000
    #集群服务器
    spring.redis.cluster.nodes=
    # Redis服务器连接密码（默认为空）集群密码
    spring.redis.password=
    # 连接池最大连接数（使用负值表示没有限制）
    spring.redis.jedis.pool.max-active=8
    # 连接池最大阻塞等待时间（使用负值表示没有限制）
    spring.redis.jedis.pool.max-wait=-1
    # 连接池中的最大空闲连接
    spring.redis.jedis.pool.max-idle=8
    # 连接池中的最小空闲连接
    spring.redis.jedis.pool.min-idle=0
    # 连接超时时间（毫秒）
    spring.redis.timeout=10000
    
    
    #日志
    logging.level.com.luzx.EurekaClient=DEBUG
    
    #允许覆盖
    spring.main.allow-bean-definition-overriding=true
    
    spring.application.name=EurekaDotaServiceClient
    
    #hostname
    eureka.instance.hostname= ${spring.cloud.client.ipaddress}
    #使用ip地址注册
    eureka.instance.prefer-ip-address=true
    eureka.instance.ip-address=xx.xx.xx.xx
    
    
    #端口
    server.port=8081
    #server.port=8082

3、启动类添加注释@EnableEurekaClient或者@EnableDiscoveryClient

@SpringBootApplication
    @EnableEurekaClient
    public class EurekaClientApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(EurekaClientApplication.class, args);
    	}
    
    }

4、跟往常一样正常编写Controller层接口就行

package com.luzx.EurekaClient.EurekaClient.controller;
    
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Optional;
    
    import javax.servlet.http.HttpServletRequest;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import com.luzx.EurekaClient.EurekaClient.service.DotaService;
    
    @Controller
    public class DotaController {
    
    	@Autowired
    	private DotaService dotaService;
    	@Value("${server.port}")
    	private String port;
    	
    
    	
    	@RequestMapping("/getHeroMsgById")
    	@ResponseBody
    	public Map<String,Object> getHeroMsgById(HttpServletRequest request){
    		Map<String,Object> result = new HashMap<String,Object>();
    		result.put("status", false);
    		result.put("port", port);
    		try {
    			Optional<String> heroId = Optional.ofNullable(request.getParameter("heroId"));
    			heroId.ifPresent((value) -> {
    				result.put("status", true);
    				result.put("result", dotaService.getHeroMsgById(value));
    			});
    		}
    		catch(Exception e) {
    			e.printStackTrace();
    		}
    		return result;
    	}
    	
    	
    }

5、修改配置文件的端口号，启动多个服务，实现集群

[SpringBoot_redis]: https://blog.csdn.net/wjlzx/article/details/83268963