客户端的搭建与注册

简介: 客户端的搭建与注册


image.png

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

1.什么是客户端

微服务的每一个业务功能服务都叫做客户端。即每一个被拆分出来的功能模块服务。

2.搭建客户端

客户端就是普通的springboot项目,在其中添加一些注解就被叫做微服务的客户端。

1.新建springboot项目

按照传统方法新建springboot项目。

2.修改pom

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>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

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

3.修改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);
  }
}

4.编写接口

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

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;
  }
}

5.修改application.properties

1.必要配置

最后着重说一下配置文件。以下是是必不可少的配置。

spring.profiles.active=dev
application-dev.properties
spring.application.name=eureka-client
server.port=2001     #指定服务端口
eureka.client.serviceUrl.defaultZone=http://localhost:1001/eureka/

2.其他配置解析

发呆时间,即服务续约到期时间(缺省为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,这样我们自己就可以创建一个集群环境。

image.png

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

image.png


相关文章
|
21天前
|
监控 API 开发工具
邮件中继中转邮箱API发送邮件的方法和步骤
AokSend介绍了使用邮件中继中转邮箱API发送邮件的步骤:理解API概念,获取API密钥,设置发件人和收件人信息,构建并发送API请求,处理响应,监控调试,及完善邮件功能。该服务支持大量验证码发送、触发式接口和高触达SMTP/API接口。选择合适提供商并参考文档可优化邮件发送。
|
21天前
|
SpringCloudAlibaba Java Nacos
Nacos报错问题之服务端注册的时候返回404如何解决
Nacos是一个开源的、易于部署的动态服务发现、配置管理和服务管理平台,旨在帮助微服务架构下的应用进行快速配置更新和服务治理;在实际运用中,用户可能会遇到各种报错,本合集将常见的Nacos报错问题进行归纳和解答,以便使用者能够快速定位和解决这些问题。
|
Web App开发 缓存 网络协议
如何实现服务端向客户端推送数据
常见的http协议只能从客户端主动向服务端请求数据,而服务端无法向客户端发送数据.本文通过介绍几种方式来实现上述功能.
|
7月前
|
存储 传感器 物联网
MQTT 客户端和代理连接如何工作?
MQTT 客户端和代理连接如何工作?
155 2
MQTT 客户端和代理连接如何工作?
|
11月前
|
Java Linux Nacos
【Java项目】SpringCloud项目注册到Nacos中心时显示的是内网IP导致不同服务器之间无法互相调用接口的解决并发
【Java项目】SpringCloud项目注册到Nacos中心时显示的是内网IP导致不同服务器之间无法互相调用接口的解决并发
218 0
|
11月前
|
缓存 Java Nacos
Nacos 服务注册概述及客户端注册实例源码分析(一)(中)
Nacos 服务注册概述及客户端注册实例源码分析(一)(中)
127 1
|
11月前
|
存储 缓存 负载均衡
Nacos 服务注册概述及客户端注册实例源码分析(一)(上)
Nacos 服务注册概述及客户端注册实例源码分析(一)(上)
182 1
|
11月前
|
设计模式 程序员 API
Nacos 服务注册概述及客户端注册实例源码分析(一)(下)
Nacos 服务注册概述及客户端注册实例源码分析(一)(下)
81 1
SpringCloud 踩坑之 注册中心绑定端口一直是8080
SpringCloud 踩坑之 注册中心绑定端口一直是8080
217 0
RPC框架(7 - 实现服务端自动注册服务)
RPC框架(7 - 实现服务端自动注册服务)