胖虎的工具箱-编程导航 胖虎的工具箱-编程导航

SpringCloud-Eureka注册中心

2年前 (2022) 程序员胖胖胖虎阿
276 0 0

SpringCloud-Eureka注册中心

🍁博客主页：👉@不会压弯的小飞侠
✨欢迎关注：👉点赞👍收藏⭐留言✒
✨系列专栏：👉SpringCloud专栏
✨知足上进，不负野心。
🔥欢迎大佬指正，一起学习！一起加油！

SpringCloud-Eureka注册中心

目录

  • 🍁服务拆分及远程调用
    • 🔥服务拆分
    • 🔥服务远程调用
  • 🍁Eureka注册中心
    • 🔥 服务调用出现的问题
    • 🔥eureka的作用
    • 🔥搭建Eureka服务
    • 🔥注册user-service
    • 🔥模拟启动两个user-service
    • 🔥eureka服务发现-服务拉取

🍁服务拆分及远程调用

🔥服务拆分

  • 服务拆分注意事项
    • 1．单一职责:不同微服务，不要重复开发相同业务
    • 2．数据独立:不要访问其它微服务的数据库
    • 3．面向服务︰将自己的业务暴露为接口，供其它微服务调用

准备工作，创建一个Cloud-demo项目工程。

  • 实现功能
    • order-service根据id查询订单
    • order-user根据id查询用户
  • 项目结构

SpringCloud-Eureka注册中心

  • sql导入数据库
  • cloud-order.sql
CREATE TABLE `tb_order`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '订单id',
  `user_id` bigint(20) NOT NULL COMMENT '用户id',
  `name` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '商品名称',
  `price` bigint(20) NOT NULL COMMENT '商品价格',
  `num` int(10) NULL DEFAULT 0 COMMENT '商品数量',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `username`(`name`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 109 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

INSERT INTO `tb_order` VALUES (101, 1, 'Apple 苹果 iPhone 12 ', 699900, 1);
INSERT INTO `tb_order` VALUES (102, 2, '雅迪 yadea 新国标电动车', 209900, 1);
INSERT INTO `tb_order` VALUES (103, 3, '骆驼（CAMEL）休闲运动鞋女', 43900, 1);
INSERT INTO `tb_order` VALUES (104, 4, '小米10 双模5G 骁龙865', 359900, 1);
INSERT INTO `tb_order` VALUES (105, 5, 'OPPO Reno3 Pro 双模5G 视频双防抖', 299900, 1);
INSERT INTO `tb_order` VALUES (106, 6, '美的（Midea) 新能效 冷静星II ', 544900, 1);
INSERT INTO `tb_order` VALUES (107, 2, '西昊/SIHOO 人体工学电脑椅子', 79900, 1);
INSERT INTO `tb_order` VALUES (108, 3, '梵班（FAMDBANN）休闲男鞋', 31900, 1);
  • cloud-user.sql
CREATE TABLE `tb_user`  (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `username` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '收件人',
  `address` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '地址',
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `username`(`username`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 109 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

INSERT INTO `tb_user` VALUES (1, '柳岩', '湖南省衡阳市');
INSERT INTO `tb_user` VALUES (2, '文二狗', '陕西省西安市');
INSERT INTO `tb_user` VALUES (3, '华沉鱼', '湖北省十堰市');
INSERT INTO `tb_user` VALUES (4, '张必沉', '天津市');
INSERT INTO `tb_user` VALUES (5, '郑爽爽', '辽宁省沈阳市大东区');
INSERT INTO `tb_user` VALUES (6, '范兵兵', '山东省青岛市');
  • order-service具体代码如下：

order实体类

@Data
public class Order {
    private Long id;
    private Long price;
    private String name;
    private Integer num;
    private Long userId;
    private User user;
}

user实体类

@Data
public class User {
    private Long id;
    private String username;
    private String address;
}

OrderMapper接口

public interface OrderMapper {
    @Select("select * from tb_order where id = #{id}")
    Order findById(Long id);
}

OrderService

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;
    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        // 4.返回
        return order;
    }
}

OrderApplication

@MapperScan("cn.study.order.mapper")
@SpringBootApplication
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

}

application.yml

server:
  port: 8080
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/could_order?useSSL=false
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver
mybatis:
  type-aliases-package: cn.study.user.pojo
  configuration:
    map-underscore-to-camel-case: true
logging:
  level:
    cn.study: debug
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS

user-service项目的创建就不过多描述，跟order-service项目大致一样。
启动项目，进行测试：
SpringCloud-Eureka注册中心
SpringCloud-Eureka注册中心

🔥服务远程调用

  • 需求:根据订单id查询订单的同时，把订单所属的用户信息一起返回
  • 如何在java代码中发送http请求
  • 步骤

1.注册RestTemplate

  • 在order-service的OrderApplication中注册RestTemplate并注入spring容器
package cn.study.order;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@MapperScan("cn.study.order.mapper")
@SpringBootApplication
public class OrderApplication {

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

    /**
     * 创建RestTemplate注入spring容器
     * @return
     */
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }


}

2.服务远程调用RestTemplate

  • 修改order-service中的OrderService的queryOrderByld方法
package cn.study.order.service;

import cn.study.order.mapper.OrderMapper;
import cn.study.order.pojo.Order;
import cn.study.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private RestTemplate restTemplate;

    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        //2.利用RestTemplate发送http请求，查询用户
        //2.1URL路径
        String url="http://localhost:8081/user/"+order.getUserId();
        //2.2发送http请求，实现远程调用
        User user = restTemplate.getForObject(url, User.class);
        //3.封装user到order
        order.setUser(user);
        // 4.返回
        return order;
    }
}
  • 重启order微服务
  • http://localhost:8080/order/101
  • 实现了跨服务调用

SpringCloud-Eureka注册中心

  • 微服务调用方式
    • 基于RestTemplate发起的http请求实现远程调用
    • http请求做远程调用是与语言无关的调用，只要知道对方的ip、端口、接口路径、请求参数即可。

🍁Eureka注册中心

Eureka是Netflix的一个子模块，也是核心模块之一。Eureka是一个基于REST的服务，用于定位服务，以实现云端中间层服务发现和故障转移。服务注册与发现对于微服务架构来说是非常重要的，有了服务发现与注册，只需要使用服务的标识符，就可以访问到服务，而不需要修改服务调用的配置文件了。功能类似于dubbo的注册中心，比如Zookeeper。

  • 服务调用关系
    • 服务提供者:暴露接口给其它微服务调用
    • 服务消费者:调用其它微服务提供的接口
    • 提供者与消费者角色其实是相对的
    • 一个服务可以同时是服务提供者和服务消费者

🔥 服务调用出现的问题

  • 服务消费者该如何获取服务提供者的地址信息?
  • 如果有多个服务提供者，消费者该如何选择?
  • 消费者如何得知服务提供者的健康状态?
    SpringCloud-Eureka注册中心

🔥eureka的作用

  • Eureka有两个角色：
    • 一个是服务端：eureka-server，注册中心，负责记录和管理微服务
    • 一个是客户端：eureka-client，包括提供者和消费者，在前面的demo中，包含user和order。
  • 提供者user现在有三台服务器部署（用三个端口号代替），分别是8081、8082、8083，order只有一台服务器部署，8080，先在eureka的服务端进行服务信息的注册，每次当order请求的时候，eureka服务端都会把user的ip地址拉取下来给order，消费者利用负载均衡算法，从服务列表挑选一个，进行远程调用。

SpringCloud-Eureka注册中心

  • 消费者该如何获取服务提供者具体信息?
    • 服务提供者启动时向eureka注册自己的信息eureka保存这些信息
    • 消费者根据服务名称向eureka拉取提供者信息
  • 如果有多个服务提供者，消费者该如何选择?
    • 服务消费者利用负载均衡算法，从服务列表中挑选一个
  • 消费者如何感知服务提供者健康状态?
    • 服务提供者会每隔30秒向EurekaServer发送心跳请求，报告健康状态eureka会更新记录服务列表信息，心跳不正常会被剔除
    • 消费者就可以拉取到最新的信息

总结：

  • 在Eureka架构中，微服务角色有两类:
    • EurekaServer:服务端，注册中心
      • 记录服务信息
      • 心跳监控
  • EurekaClient:客户端
    • Provider:服务提供者，例如案例中的user-service
      • 注册自己的信息到EurekaServer
      • 每隔30秒向EurekaServer发送心跳
    • consumer:服务消费者，例如案例中的order-service
      • 根据服务名称从EurekaServer拉取服务列表
      • 基于服务列表做负载均衡，选中一个微服务后发起远程调用

🔥搭建Eureka服务

  • 创建项目，引入spring-cloud-starter-netflix-eureka-server的依赖
<dependencies>
        <!--eureka服务端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>
  • 编写启动类，添加@EnableEurekaServer注解
package cn.study.eureka;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@EnableEurekaServer // 自动装配
@SpringBootApplication
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class,args);
    }
}
  • 添加application.yml文件，编写下面的配置:
#服务端口
server:
  port: 8083
#服务名称
spring:
  application:
    name: eurekaservice
#eureka地址信息
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8083/eureka

注意：因为eureka也是一个微服务，所以要配置eureka的地址信息，将它自己也注册到eureka上。

启动eureka服务器，点击端口号8083直接访问浏览器
SpringCloud-Eureka注册中心

  • EUREKASERVER是服务的名称
  • Status是服务的状态
  • UP表示正常
  • DOWN表示宕机
  • DESKTOP-OK3TT7Q是计算机名

SpringCloud-Eureka注册中心

🔥注册user-service

  • 将user-service服务注册到EurekaServer步骤如下:

  • 1．在user-service项目引入spring-cloud-starter-netflix-eureka-client的依赖

<!--eureka客户端依赖-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
  • 2．在application.yml文件，编写下面的配置:
spring:
   application:
     name: userservice  #userservice的服务名称
# 注册服务到eureka上
eureka:
  client:
    service-url:
      # eureka的地址信息，注册到 eureka 上
      defaultZone: http://127.0.0.1:8083/eureka

注意：发现爆红，原因是yml中不能出现两段spring，合并就Ok了。

  • 重启这三个服务，访问eureka查看注册进来的服务

SpringCloud-Eureka注册中心

将order-service服务注册到EurekaServer步骤如上，这里就不过多叙述了。

🔥模拟启动两个user-service

将user-service多次启动，模拟多实例部署，但为了避免端口冲突，需要修改端口设置:

  • 1.选中UserApplication，右键–>Copy Configuration服务复制配置

SpringCloud-Eureka注册中心

  • 2.更改服务名称，写上-Dserver.port=8082，注意避开端口冲突

SpringCloud-Eureka注册中心

  • 3.启动UserApplication2服务

SpringCloud-Eureka注册中心

  • 4.重新访问eureka，可以看到user-service有两个端口

SpringCloud-Eureka注册中心

🔥eureka服务发现-服务拉取

  • 在eureka-server中拉取user-service服务的实例列表，并且实现负载均衡。

  • 1.修改OrderService的代码，修改访问的url路径，用服务名代替ip、端口

package cn.study.order.service;

import cn.study.order.mapper.OrderMapper;
import cn.study.order.pojo.Order;
import cn.study.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private RestTemplate restTemplate;

    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        //2.利用RestTemplate发送http请求，查询用户
        //2.1URL路径
       /* String url="http://localhost:8081/user/"+order.getUserId();*/
        String url="http://userservice/user/"+order.getUserId();
        //2.2发送http请求，实现远程调用
        User user = restTemplate.getForObject(url, User.class);
        //3.封装user到order
        order.setUser(user);
        // 4.返回
        return order;
    }
}

  • 注意:order-service的service层，是order去拉取user，userservice对应的是user-service的yml文件中spring.application.name服务名称

  • 2.在order-service项目的启动类OrderApplication中的RestTemplate添加负载均衡注解：@LoadBalanced

@MapperScan("cn.study.order.mapper")
@SpringBootApplication
public class OrderApplication {

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

    /**
     * 创建RestTemplate注入spring容器
     * @return
     */
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}
  • 两个user-service都有查询实现了负载均衡。

SpringCloud-Eureka注册中心
SpringCloud-Eureka注册中心

  • 注意：如果在项目的类路径下存在Spring Cloud Ribbon相关的类，需要通过配置关闭Ribbon功能，因为Spring Cloud默认优先使用Ribbon：
spring:
  cloud:
    loadbalancer:
      ribbon:
        enabled: false

总结：

  • 1.搭建EurekaServer
    • 引入eureka-server依赖
    • 添加@EnableEurekaServer注解·在application.yml中配置eureka地址
  • 2.服务注册
    • 引入eureka-client依赖
    • 在application.yml中配置eureka地址
  • 3.服务发现
    • 引入eureka-client依赖
    • 在application.yml中配置eureka地址
    • 给RestTemplate添加@LoadBalanced注解
    • 用服务提供者的服务名称远程调用
版权声明：程序员胖胖胖虎阿 发表于 2022年9月2日 下午1:16。
转载请注明：SpringCloud-Eureka注册中心 | 胖虎的工具箱-编程导航

相关文章

IDEA安装及激活破解教程(IDEA2019 破解教程,成功激活)
程序员胖胖胖虎阿
122
IntelliJ IDEA2021永久激活码(IDEA永久永久激活码激活破解教程)
程序员胖胖胖虎阿
707
idea的全新 激活码(IntelliJ IDEA最新永久免费激活码,全年更新)
程序员胖胖胖虎阿
210
java面试题,各大企业常见的java笔试题及答案(精华)
程序员胖胖胖虎阿
428
idea的全新激活工具(IntelliJ IDEA2019破解教程,永久激活IDEA)
程序员胖胖胖虎阿
138
【Vegas原创】修改oracle用户缺省主目录
程序员胖胖胖虎阿
303

暂无评论

暂无评论...
致力于称为最好的程序员导航网站

友链申请 免责声明 关于我们

Copyright © 2022  胖虎的工具箱-编程导航   陇ICP备2022001249号