五分钟带你玩转springcloudNetflix（三）客户端的注册

上文说道EUREKA服务中心后，接下来需要介绍以下服务间的调用了。

首先新建一个被调用的服务，一个普通的接口，但是需要声明为spring cloud的项目 代码如下

pom文件 

<?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 https://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.2.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.baocl</groupId>
    <artifactId>eureka-client</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka-client</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
    </properties>

    <dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </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-starter-test</artifactId>
        <scope>test</scope>
        <exclusions>
            <exclusion>
                <groupId>org.junit.vintage</groupId>
                <artifactId>junit-vintage-engine</artifactId>
            </exclusion>
        </exclusions>
    </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>

这里有个坑！！！！最新的client是这个jar包，以前的包和现在的不同，如果EUREKA上没有注册进去，那么看看是不是这个原因

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

EurekaClientApplication

这里@EnableDiscoveryClient注解说明是spring cloud的客户端

package com.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient
public class EurekaClientApplication {

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

}

然后咱们这里写一个接口 没啥说的

package com.cloud.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.cloud.client.serviceregistry.Registration;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/aaa")
public class DcController {
	@Value("${server.port}")
	String port;

	@GetMapping("/dc")	
	public String dc(@RequestParam(value = "dk") String dk) {
//		try {
//			Thread.sleep(100L);
//		} catch (InterruptedException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
		//String services = "Services: " + discoveryClient.getServices();
		//System.out.println(services);
		// HttpServletRequest request = ((ServletRequestAttributes)
		// (RequestContextHolder.getRequestAttributes()));
		// ServletRequestAttributes se =
		// (ServletRequestAttributes)(RequestContextHolder.getRequestAttributes());
		// HttpServletRequest request = se.getRequest();
		return "服务提供者端口为" + port + "。。。。消费者端口为" + dk;
	}

}

最后着重说一下配置文件

上面三条配置是必须的 其他的都是可以选配的

application.properties

spring.profiles.active=dev

application-dev.properties

spring.application.name=eureka-client
server.port=2001
eureka.client.serviceUrl.defaultZone=http://localhost:1001/eureka/



# 发呆时间，即服务续约到期时间（缺省为90s） 表示eureka server至上一次收到client的心跳之后，等待下一次心跳的超时时间，
#在这个时间内若没收到下一次心跳，则将移除该instance。 （上下两个一起使用）
#eureka.instance.lease-expiration-duration-in-seconds=10
# 心跳时间，即服务续约间隔时间（缺省为30s）
#eureka.instance.lease-renewal-interval-in-seconds = 5

#连接 Eureka Server 的超时时间，单位：秒
#eureka.client.eureka-server-connect-timeout-seconds=10
#从Eureka服务器端获取注册信息的间隔时间，单位：秒 默认30
#eureka.client.registery-fetch-interval-seconds=1000
#启动服务注册 默认true
#eureka.client.register-with-eureka = true


#获取实例时是否过滤，只保留UP状态的实例 默认true
#eureka.client.filter-only-up-instances = true
# 开启健康检查（需要spring-boot-starter-actuator依赖）
#eureka.client.healthcheck.enabled	= true
#获取注册信息并缓存到本地
#eureka.client.fetch-registry=  true

这里还有一点 我们可以更改application.properties确定我们启动时启动的配置文件，同时可以在启动一个项目后修改application.properties，这样我们自己就可以创建一个集群环境。

然后 我们启动了三次(三个配置的端口号需要不同)，这样我们就创建了一个集群了，然后EUREKA上就可以看到我们客户端的信息了，如下图！

文章来源: baocl.blog.csdn.net，作者：小黄鸡1992，版权归原作者所有，如需转载，请联系作者。

原文链接：baocl.blog.csdn.net/article/details/104738312