前言
一直没机会做spring生态圈的框架，公司选择的是一些小众的微服务，鉴于此考虑，丰富自己的技术栈，花了两天时间从网上各网站上学习了springboot一些基础知识。
本章只介绍springboot微服务集成springcloud，以及其eureka组件，将前一章的springboot微服务框架作为springcloud分布式架构中的子微服务，用springcloud管理。
环境准备
- IntelliJ IDEA
- 前一章中搭建的微服务框架
-
前一章之后，对目录结构进行了整改
工程目录下新建demo目录.png
将以下目录结构移动到demo目录下：
目录移动.png
移动后如下.png
移动完之后，删掉idea的配置文件：.idea、***.iml，然后关掉idea，重新打开，open选择此工程，重新生成配置文件。
open之后，配置SDK，然后你会发现demo下的pom并没有被idea的maven管理起来，你需要将其添加到此project的modules中，操作如下：
导入modules.png
选择需要导入的包.png
选择import-maven-finish.png
导入完成后如下结构：
导入结果.png
以上操作一般用于用idea对目录结构进行整改，请酌情使用。
开始集成springcloud
通过idea搭建eureka server
-
在工程名上右键新建modules：
新建modules.png
选择spring Initializr.png
输入artifact.png
勾选Eureka Server.png
finish.png
完成后idea会自动帮你把module导入到此工程中，并将对应功能的包标识为相应的颜色
pom.xml.png
可以看到pom.xml中生成的spring-cloud.version是Hoxton.SR1，此版本适配于springboot 2.2.x版本，稍后再demo中集成eureka client时，也使用这个版本。 -
将默认生成的application.properties修改为application.yml，并配置内容：
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/
-
最后在EurekaApplication前加上注解@EnableEurekaServer，就可以启动了，idea会自动将EurekaApplication添加到springboot启动services管理中，如果未检测，可以手动添加，右键EurekaApplication，选择Create 'EurekaApplication'...，就可以将其加入到Services中。
运行结果.png
eureka管理界面.png
在demo微服务中集成eureka client
-
demo下pom中添加依赖
依赖配置.png
依赖配置.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>
-
配置demo的application.yml
图片.png
application:
name: provider
eureka:
instance:
prefer-ip-address: true
client:
service-url:
defaultZone: http://localhost:8082/eureka/
-
在DemoApplication前配置@EnableDiscoveryClient注解，标识当前应用是可被Eureka Server发现的，并在其中增加Bean，对restTemplate注解成启用负载均衡
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();
}
}
-
在controller下定义两个接口，用于接口间通过注册发现调用接口，此示例中使用demo微服务提供的两个接口，模拟成两个微服务，接口调用通过Eureka提供的接口互相访问。
producer.png
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自动下载包的过程。
-
启动DemoApplication，会自动注册到EurekaApplication中
启动日志.png
Eureka管理界面中可以看到多了一个instance
Eureka Server管理界面.png
打开swagger界面，调用consumer的接口，可以通过producer查询到响应结果
接口测试.png
我的博客即将同步至腾讯云开发者社区，邀请大家一同入驻：https://cloud.tencent.com/developer/support-plan?invite_code=mmfmf1mhr7vc
