Java之 Spring Cloud 微服务 Eureka （第一个阶段）【二】【SpringBoot项目实现商品服务器端是调用】

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.boot.autoconfigure.domain.EntityScan;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication

@EntityScan(“cn.itbluebox.product.entity”)

//激活Eureka

//@EnableEurekaClient

@EnableDiscoveryClient //写不写都一样

public class ProductApplication {

public static void main(String[] args) {

SpringApplication.run(ProductApplication.class,args);

}

4）运行测试，启动商品微服务

访问测试：http://localhost:9000/

多了

（3）服务消费者通过注册中心获取服务列表,并调用

Eureka中的元数据：服务的主机名,ip,等信息.可以通过eurekaserver进行获取，用于服务之间的调用，

1）引入EurekaClient的坐标

org.springframework.cloud

spring-cloud-starter-netflix-eureka-client

2）修改application.yml添加EurekaServer的信息

server:

port: 9002 #端口

spring:

application:

datasource:

driver-class-name: com.mysql.jdbc.Driver

url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8

username: root

password: root

jpa:

database: MySQL

show-sql: true

open-in-view: true

#配置Eureka

eureka:

client:

service-url:

defaultZone: http://localhost:9000/eureka/

instance:

prefer-ip-address: true #使用ip地址注册

3）完善order_service当中的 OrderController

package cn.itbluebox.order.controller;

import cn.itbluebox.order.entity.Product;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cloud.client.ServiceInstance;

import org.springframework.cloud.client.discovery.DiscoveryClient;

import org.springframework.web.bind.annotation.*;

import org.springframework.web.client.RestTemplate;

import java.util.List;

@RestController

@RequestMapping(“/order”)

public class OrderController {

//注入RestTemplate对象

@Autowired

private RestTemplate restTemplate;

注入DiscoveryClient:

SpringCloud 提供的获取原数组的工具类

调用方法获取服务的元数据信息

@Autowired

private DiscoveryClient discoveryClient;

参数：商品ID

通过订单系统，调用商品服务

1、需要配置商品对象

2、需要调用商品服务

3、entity.Product

使用java 当中的urlconnection，httpclient,okhttp

@RequestMapping(value = “/buy/{id}”, method = RequestMethod.GET)

public Product findById(@PathVariable Long id) {

//调用discoveryClient方法

//已调用服务名称获取所有的元数据

List instances = discoveryClient.getInstances(“service-product”);

//获取唯一的一个元数据

ServiceInstance instance = instances.get(0);

//根据元数据中的主机地址和端口号拼接请求微服务的URL

Product product = null;

//如何调用商品服务?

product = restTemplate.getForObject(“http://”+instance.getHost()+“:”+instance.getPort()+“/product/”+id,Product.class);

return product;

}

@RequestMapping(method = RequestMethod.POST)

public String save(@RequestBody Product product) {

//调用discoveryClient方法

//已调用服务名称获取所有的元数据

List instances = discoveryClient.getInstances(“service-product”);

//获取唯一的一个元数据

ServiceInstance instance = instances.get(0);

restTemplate.postForObject(“http://”+instance.getHost()+“:”+instance.getPort()+“/product/”,product,Product.class);

return “保存成功”;

}

@RequestMapping(method = RequestMethod.PUT)

public String update(@RequestBody Product product) {

//调用discoveryClient方法

//已调用服务名称获取所有的元数据

List instances = discoveryClient.getInstances(“service-product”);

//获取唯一的一个元数据

ServiceInstance instance = instances.get(0);

restTemplate.put(“http://”+instance.getHost()+“:”+instance.getPort()+“/product/”,product);

return “更新成功”;

}

@RequestMapping(value = “/{id}”, method = RequestMethod.DELETE)

public String delete(@PathVariable Long id) {

//调用discoveryClient方法

//已调用服务名称获取所有的元数据

List instances = discoveryClient.getInstances(“service-product”);

//获取唯一的一个元数据

ServiceInstance instance = instances.get(0);

restTemplate.delete(“http://”+instance.getHost()+“:”+instance.getPort()+“/product/”+id);

return “删除成功”;

}

4）运行测试

访问http://localhost:9002/order/buy/1

二、服务注册Eureka高级

=========================================================================

1、Eureka Server 高可用集群

在上一个章节，实现了单节点的Eureka Server的服务注册与服务发现功能。

Eureka Client会定时连接Eureka Server，获取注册表中的信息并缓存到本地。

微服务在消费远程API时总是使用本地缓存中的数据。

因此一般来说，即使Eureka Server发生宕机，也不会影响到服务之间的调用。但如果Eureka Server宕机时，某些微服务也出现了不可用的情况，Eureka Server中的缓存若不被刷新，就可能会影响到微服务的调用，甚至影响到整个应用系统的高可用。

因此，在生成环境中，通常会部署一个高可用的Eureka Server集群。

Eureka Server可以通过运行多个实例并相互注册的方式实现高可用部署，Eureka Server实例会彼此增量地同步信息，从而确保所有节点数据一致。

事实上，节点之间相互注册是Eureka Server的默认行为。

（1）搭建 Eureka Server高可用集群

1 准备2个EurekaServer,需要相互注册

1号server : 9000

2号server : 8000I

2需要将微服务注册到两个EurekaServer上

1）修改eureka_server当中的application.yml

#模拟两个EurekaServer

#端口9000 , 8000

#两个server需要相互注册

spring:

application:

server:

port: 9000 #端口

#配置eureka server

eureka:

client:

#register-with-eureka: false #是否将自己注册到注册中心

#fetch-registry: false #是否从eureka中获取注册信息

service-url: #配置暴露给Eureka Client的请求地址

defaultZone: http://127.0.0.1:8000/eureka/

运行测试

打开Run Dashboard

修改application.yml

#模拟两个EurekaServer

#端口9000 , 8000

#两个server需要相互注册

spring:

application:

server:

port: 8000 #端口

#配置eureka server

eureka:

client:

#register-with-eureka: false #是否将自己注册到注册中心

#fetch-registry: false #是否从eureka中获取注册信息

service-url: #配置暴露给Eureka Client的请求地址

defaultZone: http://127.0.0.1:9000/eureka/

启动多个eureka_server

实现eureka的相互注册

访问地址：

http://localhost:9000/

http://localhost:8000/

2）启动product_service

将product_service注册到http://localhost:8000/eureka/

修改product_service当中的application.yml

server:

port: 9001 #端口

spring:

application:

datasource:

driver-class-name: com.mysql.jdbc.Driver

url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8

username: root

password: root

jpa:

database: MySQL

show-sql: true

open-in-view: true

#配置Eureka

eureka:

client:

service-url:

defaultZone: http://localhost:9000/eureka/,http://localhost:8000/eureka/

instance:

prefer-ip-address: true #使用ip地址注册

启动product_service

在http://localhost:9000/上查看

http://localhost:8000/

3）启动order_service

将order_service注册到http://localhost:8000/eureka/

修改order_service当中的application.yml

server:

port: 9002 #端口

spring:

application:

datasource:

driver-class-name: com.mysql.jdbc.Driver

url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8

username: root

password: root

jpa:

database: MySQL

show-sql: true

open-in-view: true

#配置Eureka

eureka:

client:

service-url:

defaultZone: http://localhost:9000/eureka/,http://localhost:8000/eureka/

instance:

prefer-ip-address: true #使用ip地址注册

访问：http://localhost:9000/

访问：http://localhost:8000/

4）测试

断开一台eurekaService

8000断开

测试数据是否可以正确获取:http://localhost:9002/order/buy/1

2、显示护IP

修改eureka_server当中的application.yml，修改回之前的配置方便后期测试

#模拟两个EurekaServer

#端口9000 , 8000

#两个server需要相互注册

spring:

application:

server:

port: 9000 #端口

#配置eureka server

eureka:

client:

fetch-registry: false #是否从eureka中获取注册信息

service-url: #配置暴露给Eureka Client的请求地址

defaultZone: http://127.0.0.1:8000/eureka/

1）使product_service暴露对应的ip

修改product_service当中的application.yml

server:

port: 9001 #端口

spring:

application:

datasource:

driver-class-name: com.mysql.jdbc.Driver

url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8

username: root

password: root

jpa:

database: MySQL

show-sql: true

open-in-view: true

#配置Eureka

eureka:

client:

service-url:

defaultZone: http://localhost:9000/eureka/

instance:

prefer-ip-address: true #使用ip地址注册

instance-id:

−

{spring.cloud.client.ip-address}:

spring.cloud.client.ip−address:{server.port} #向组成中心注册服务ID

重新运行并测试

访问：http://localhost:9000/

3、服务续约时间设置

在服务的提供者，设置心跳间隔，设置续约到期时间

修改product_service当中的application.yml

server:

port: 9001 #端口

spring:

application:

datasource:

driver-class-name: com.mysql.jdbc.Driver

url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8

username: root

password: root

jpa:

database: MySQL

show-sql: true

open-in-view: true

#配置Eureka

eureka:

client:

service-url:

defaultZone: http://localhost:9000/eureka/

instance:

prefer-ip-address: true #使用ip地址注册

instance-id:

−

{spring.cloud.client.ip-address}:

spring.cloud.client.ip−address:{server.port} #向组成中心注册服务ID

lease-renewal-interval-in-seconds: 5 #向注册中心中注册服务id

lease-expiration-duration-in-seconds: 10 #续约到期的时间

重新启动

4、Eureka自我保护机制

eureka_server当中的application.yml当中配置，中配置关闭自我保护,和剔除服务间

server:

enable-self-preservation: false #关闭自我保护

eviction-interval-timer-in-ms: 4000 #剔除服务间隔

三、Eureka源码解析

=======================================================================

1、SpringBoot中的自动装载

（1）ImportSelector

ImportSelector接口是Spring导入外部配置的核心接口，在SpringBoot的自动化配置和@EnableXXX(功能性注解)中起到了决定性的作用。

当在@Configuration标注的Class上使用@Import引入了一个ImportSelector实现类后，会把实现类中返回的Class名称都定义为bean。

1)创建模块

2)创建对应的User实体类

package cn.itbluebox.bean;

import lombok.Data;

Bean对象

@Data

public class User {

private String username;

private Integer age;

}

3)创建UserConfiguration

package cn.itbluebox.bean;

import org.springframework.context.annotation.Bean;

没有Spring注解

public class UserConfiguration {

@Bean

public User getUser(){

return new User();

}

4)创建UserImportSelector

UserImportSelector接口继承ImportSelector,他和ImportSelector的区别在于装载bean的时机上,UserImportSelector需要等所有的@Configuration都执行完毕后才会进行装载。

package cn.itbluebox.bean;

import org.springframework.context.annotation.ImportSelector;

import org.springframework.core.type.AnnotationMetadata;

public class UserImportSelector implements ImportSelector {

@Override

public String[] selectImports(AnnotationMetadata annotationMetadata) {

//获取配置类的名称

return new String[]{UserConfiguration.class.getName()};//自动找到对应的类将其加载到Spring容器当中

}

5)创建EnableUserBean自定义注解

package cn.itbluebox.bean;

import org.springframework.context.annotation.Import;

import java.lang.annotation.*;

@Retention(RetentionPolicy.RUNTIME)

@Documented

@Target(ElementType.TYPE) //设置当前注解是可以配置到类上的注解

@Import(UserImportSelector.class)

public @interface EnableUserBean {

}

6)创建测试类运行

01）创建TestApplication

package cn.itbluebox.test;

import cn.itbluebox.bean.EnableUserBean;

import cn.itbluebox.bean.User;

import org.springframework.context.annotation.AnnotationConfigApplicationContext;

@EnableUserBean

public class TestApplication {

public static void main(String[] args) {

//获取Spring容器

AnnotationConfigApplicationContext ac =

new AnnotationConfigApplicationContext(TestApplication.class);

User user = ac.getBean(User.class);

System.out.println(user);

}

02）为了打印的时候有值，设置UserConfiguration初始化User的时候设置一些值

package cn.itbluebox.bean;

import org.springframework.context.annotation.Bean;

没有Spring注解

public class UserConfiguration {

@Bean

public User getUser(){

User user = new User();

user.setAge(12);

user.setUsername(“张三”);

return user;

}

03）运行测试

代码执行流程

-->@EnableUserBean --> UserImportSelector --> UserConfiguration --> User

（2）springBoot自动装载

SpringBoot开箱即用的特点，很大程度上归功于ImportSelector。接下来我们看下springBoot是如何在

spring的基础上做扩展的。

在SpringBoot中最重要的一个注解SpringBootApplication

自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，真正体系化！

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！

如果你觉得这些内容对你有帮助，可以扫码获取！！（备注Java获取）

最后的内容

在开头跟大家分享的时候我就说，面试我是没有做好准备的，全靠平时的积累，确实有点临时抱佛脚了，以至于我自己还是挺懊恼的。（准备好了或许可以拿个40k，没做准备只有30k+，你们懂那种感觉吗）

如何准备面试？

1、前期铺垫（技术沉积）

程序员面试其实是对于技术的一次摸底考试，你的技术牛逼，那你就是大爷。大厂对于技术的要求主要体现在：基础，原理，深入研究源码，广度，实战五个方面，也只有将原理理论结合实战才能把技术点吃透。

下面是我会看的一些资料笔记，希望能帮助大家由浅入深，由点到面的学习Java，应对大厂面试官的灵魂追问

这部分内容过多，小编只贴出部分内容展示给大家了，见谅见谅！

Java程序员必看《Java开发核心笔记（华山版）》

Redis学习笔记

Java并发编程学习笔记

四部分，详细拆分并发编程——并发编程+模式篇+应用篇+原理篇

Java程序员必看书籍《深入理解 ava虚拟机第3版》（pdf版）

大厂面试必问——数据结构与算法汇集笔记

其他像Spring，SpringBoot，SpringCloud，SpringCloudAlibaba，Dubbo，Zookeeper，Kafka，RocketMQ，RabbitMQ，Netty，MySQL，Docker，K8s等等我都整理好，这里就不一一展示了。

2、狂刷面试题

技术主要是体现在平时的积累实用，面试前准备两个月的时间再好好复习一遍，紧接着就可以刷面试题了，下面这些面试题都是小编精心整理的，贴给大家看看。

①大厂高频45道笔试题（智商题）

②BAT大厂面试总结（部分内容截图）

③面试总结

3、结合实际，修改简历

程序员的简历一定要多下一些功夫，尤其是对一些字眼要再三斟酌，如“精通、熟悉、了解”这三者的区别一定要区分清楚，否则就是在给自己挖坑了。当然不会包装，我可以将我的简历给你参考参考，如果还不够，那下面这些简历模板任你挑选：

以上分享，希望大家可以在金三银四跳槽季找到一份好工作，但千万也记住，技术一定是平时工作种累计或者自学（或报班跟着老师学）通过实战累计的，千万不要临时抱佛脚。

另外，面试中遇到不会的问题不妨尝试讲讲自己的思路，因为有些问题不是考察我们的编程能力，而是逻辑思维表达能力；最后平时要进行自我分析与评价，做好职业规划，不断摸索，提高自己的编程能力和抽象思维能力。《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！记（华山版）》

[外链图片转存中…(img-HFKs25IJ-1713288371256)]

Redis学习笔记

[外链图片转存中…(img-cq0twEWS-1713288371256)]

Java并发编程学习笔记

四部分，详细拆分并发编程——并发编程+模式篇+应用篇+原理篇

[外链图片转存中…(img-IXGXzra4-1713288371256)]

Java程序员必看书籍《深入理解 ava虚拟机第3版》（pdf版）

[外链图片转存中…(img-N4elcqLj-1713288371257)]

大厂面试必问——数据结构与算法汇集笔记

[外链图片转存中…(img-EhOcRzDn-1713288371257)]

其他像Spring，SpringBoot，SpringCloud，SpringCloudAlibaba，Dubbo，Zookeeper，Kafka，RocketMQ，RabbitMQ，Netty，MySQL，Docker，K8s等等我都整理好，这里就不一一展示了。

[外链图片转存中…(img-iuz2kcfi-1713288371257)]

2、狂刷面试题

①大厂高频45道笔试题（智商题）

[外链图片转存中…(img-XPvxAbKX-1713288371257)]

②BAT大厂面试总结（部分内容截图）

[外链图片转存中…(img-ZYi1dkWy-1713288371258)]

[外链图片转存中…(img-45l2TsfE-1713288371258)]

③面试总结

[外链图片转存中…(img-Oac0gmtN-1713288371258)]

[外链图片转存中…(img-hG7rT654-1713288371258)]

3、结合实际，修改简历

[外链图片转存中…(img-wXxUFf8p-1713288371259)]

另外，面试中遇到不会的问题不妨尝试讲讲自己的思路，因为有些问题不是考察我们的编程能力，而是逻辑思维表达能力；最后平时要进行自我分析与评价，做好职业规划，不断摸索，提高自己的编程能力和抽象思维能力。《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！

文章来源

评论可见，请评论后查看内容，谢谢！！！

您阅读本篇文章共花了：

金钥匙

Java之 Spring Cloud 微服务 Eureka （第一个阶段）【二】【SpringBoot项目实现商品服务器端是调用】

工地管理工程进度建筑施工 SaaS Java语言B/S智慧工地云平台源码（微服务+Java+Spring Cloud +UniApp +MySql）

Spring Cloud微服务实战技术文档太强了，从进阶到实战步骤都有

发表评论取消回复

金钥匙

Java之 Spring Cloud 微服务 Eureka （第一个阶段）【二】【SpringBoot项目实现商品服务器端是调用】

工地管理 工程进度 建筑施工 SaaS Java语言B/S智慧工地云平台源码（微服务+Java+Spring Cloud +UniApp +MySql）

Spring Cloud微服务实战技术文档太强了，从进阶到实战步骤都有

相关文章

发表评论取消回复

工地管理工程进度建筑施工 SaaS Java语言B/S智慧工地云平台源码（微服务+Java+Spring Cloud +UniApp +MySql）