springboot 之集成springcloud eureka

Java
361
0
0
2023-03-03
SpringBoot+thymeleaf+ajax实现局部刷新详情
上一篇
springboot 之集成kafka
下一篇
标签   SpringBoot SpringCloud

前言

一直没机会做spring生态圈的框架，公司选择的是一些小众的微服务，鉴于此考虑，丰富自己的技术栈，花了两天时间从网上各网站上学习了springboot一些基础知识。 本章只介绍springboot微服务集成springcloud，以及其eureka组件，将前一章的springboot微服务框架作为springcloud分布式架构中的子微服务，用springcloud管理。

环境准备

  • IntelliJ IDEA
  • 前一章中搭建的微服务框架
  • 前一章之后，对目录结构进行了整改

img

工程目录下新建demo目录.png 将以下目录结构移动到demo目录下：

img

目录移动.png

img

移动后如下.png 移动完之后，删掉idea的配置文件：.idea、***.iml，然后关掉idea，重新打开，open选择此工程，重新生成配置文件。 open之后，配置SDK，然后你会发现demo下的pom并没有被idea的maven管理起来，你需要将其添加到此project的modules中，操作如下：

img

导入modules.png

img

选择需要导入的包.png

img

选择import-maven-finish.png 导入完成后如下结构：

img

导入结果.png 以上操作一般用于用idea对目录结构进行整改，请酌情使用。

开始集成springcloud

通过idea搭建eureka server

  1. 在工程名上右键新建modules：

img

新建modules.png

img

选择spring Initializr.png

img

输入artifact.png

img

勾选Eureka Server.png

img

finish.png 完成后idea会自动帮你把module导入到此工程中，并将对应功能的包标识为相应的颜色

img

pom.xml.png 可以看到pom.xml中生成的spring-cloud.version是Hoxton.SR1，此版本适配于springboot 2.2.x版本，稍后再demo中集成eureka client时，也使用这个版本。

  1. 将默认生成的application.properties修改为application.yml，并配置内容：

img

application.yml.png

server:
  port: 8082

#eueka 主机名
eureka:
  instance:
    hostname: eureka-service
  client:
    #不注册自己
    register-with-eureka: false
    #获取服务
    fetch-registry: false
    #提供者和消费者的注册地址
    service-url:
      defaultZone: http://localhost:8082/eureka/
  1. 最后在EurekaApplication前加上注解@EnableEurekaServer，就可以启动了，idea会自动将EurekaApplication添加到springboot启动services管理中，如果未检测，可以手动添加，右键EurekaApplication，选择Create 'EurekaApplication'...，就可以将其加入到Services中。

img

运行结果.png

img

eureka管理界面.png

在demo微服务中集成eureka client

  1. demo下pom中添加依赖

img

依赖配置.png

img

依赖配置.png

        <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    <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>
  1. 配置demo的application.yml

img

图片.png

  application:
    name: provider
eureka:
  instance:
    prefer-ip-address: true
  client:
    service-url:
      defaultZone: http://localhost:8082/eureka/
  1. 在DemoApplication前配置@EnableDiscoveryClient注解，标识当前应用是可被Eureka Server发现的，并在其中增加Bean，对restTemplate注解成启用负载均衡

img

DemoApplication

package com.example.demo;

import lombok.extern.slf4j.Slf4j;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.web.client.RestTemplate;
import springfox.documentation.swagger2.annotations.EnableSwagger2;

@SpringBootApplication
@EnableSwagger2
@MapperScan("com.example.demo.mapper")
@EnableScheduling
@EnableTransactionManagement
@Slf4j
@EnableDiscoveryClient
public class DemoApplication {

    public static void main(String[] args) {
        log.info("DemoApplication run enter...");
        SpringApplication.run(DemoApplication.class, args);
    }

    //启用负载均衡，默认算法是轮询
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}
  1. 在controller下定义两个接口，用于接口间通过注册发现调用接口，此示例中使用demo微服务提供的两个接口，模拟成两个微服务，接口调用通过Eureka提供的接口互相访问。

img

producer.png

img

consumer.png

package com.example.demo.controller;
import com.example.demo.entity.User;
import com.example.demo.service.UserService;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * 类功能描述：<br>
 * <ul>
 * <li>类功能描述1<br>
 * <li>类功能描述2<br>
 * <li>类功能描述3<br>
 * </ul>
 * 修改记录：<br>
 * <ul>
 * <li>修改记录描述1<br>
 * <li>修改记录描述2<br>
 * <li>修改记录描述3<br>
 * </ul>
 *
 * @author xuefl
 * @version 5.0 since 2020-01-15
 */
@RequestMapping("/producer")
@RestController
public class ProducerController {

    @Autowired
    private UserService userService;

    @GetMapping("/get_user")
    @ApiOperation(value="get_user",httpMethod = "GET",notes="test get_user",produces = MediaType.APPLICATION_JSON_VALUE)
    public List<User> getAllUser(){
        return userService.selectAll();
    }
}
package com.example.demo.controller;

import com.example.demo.entity.User;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.List;

/**
 * 类功能描述：<br>
 * <ul>
 * <li>类功能描述1<br>
 * <li>类功能描述2<br>
 * <li>类功能描述3<br>
 * </ul>
 * 修改记录：<br>
 * <ul>
 * <li>修改记录描述1<br>
 * <li>修改记录描述2<br>
 * <li>修改记录描述3<br>
 * </ul>
 *
 * @author xuefl
 * @version 5.0 since 2020-01-15
 */
@RequestMapping("/consumer")
@RestController
public class ConsumerController {
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/get_user")
    @ApiOperation(value="get_user",httpMethod = "GET",notes="test get_user",produces = MediaType.APPLICATION_JSON_VALUE)
    public List<User> index(){
        return restTemplate.getForObject("http://provider/api/producer/get_user",
                List.class);
    }
}

以获取用户列表接口为例，producer为微服务a提供的接口，consumer为微服务b提供的接口，producer是真正访问数据库查询用户列表的微服务，consumer通过访问a微服务配置的application 的name：provider来调用接口，例如http://provider/api/producer/get_user； 此教程省略了mvn自动下载包的过程。

  1. 启动DemoApplication，会自动注册到EurekaApplication中

img

启动日志.png Eureka管理界面中可以看到多了一个instance

img

Eureka Server管理界面.png 打开swagger界面，调用consumer的接口，可以通过producer查询到响应结果

img

接口测试.png

SpringBoot+thymeleaf+ajax实现局部刷新详情
上一篇
springboot 之集成kafka
下一篇