Springboot搭建微服务案例之Eureka注册中心

一、父工程依赖管理

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.mumu</groupId><artifactId>eureka</artifactId><packaging>pom</packaging><version>1.0</version><modules><module>common</module><module>consumer</module><module>springcloud-service-provider</module></modules><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><junit.version>4.12</junit.version><log4j.version>1.2.17</log4j.version><mysql.version>5.1.47</mysql.version><lombok.version>1.16.18</lombok.version><druid.version>1.1.16</druid.version><mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version></properties><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId><version>2.2.1.RELEASE</version></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId><version>2.2.1.RELEASE</version></dependency><dependency><groupId>org.apache.maven.plugins</groupId><artifactId>maven-project-info-reports-plugin</artifactId><version>3.0.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>2.2.2.RELEASE</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version><scope>runtime</scope></dependency><!--        <!- druid->--><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.10</version></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>${mybatis.spring.boot.version}</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>${junit.version}</version></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><addResources>true</addResources></configuration></plugin></plugins></build></project>

二、搭建公共模块common

放一些pojo类

1. 依赖引入

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>eureka</artifactId><groupId>org.mumu</groupId><version>1.0</version></parent><modelVersion>4.0.0</modelVersion><artifactId>springcloud-service-common</artifactId><version>1.0</version><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target></properties><dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.30</version></dependency></dependencies></project>

2.实体类


@Data // 省略写get set方法
@NoArgsConstructor //提供无参数的构造函数
@AllArgsConstructor //提供带所有参数的构造函数
public class Payment implements Serializable {private long id;private String serial;
}

三、搭建服务提供方provider

1.依赖引入

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>eureka</artifactId><groupId>org.mumu</groupId><version>1.0</version></parent><modelVersion>4.0.0</modelVersion><artifactId>springcloud-service-provider</artifactId><version>1.0</version><groupId>org.mumu</groupId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target></properties><dependencies><dependency><groupId>org.mumu</groupId><artifactId>springcloud-service-common</artifactId><version>1.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId></dependency><!--mysql-connector-java--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!--jdbc--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--eureka-client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency></dependencies></project>

2.配置类

server:port: 8001 #配置服务端口号
spring:application:name: service-provider # 配置服务提供方的名称datasource:  # 配置连接数据库的基本信息driver-class-name: com.mysql.jdbc.Driver   # 驱动url: jdbc:mysql://localhost:3306/cloud2023  # 连接数据库的urlusername: root   # 连接数据库的用户名password: 123456   # 连接数据库的密码
mybatis:config-location: classpath:/mybatis/sqlMapConfig.xml   # 引入mybatis的核心配置文件mapper-locations: classpath:/mybatis/mapper/*.xml  # 引入mybatis的映射文件
eureka:client:register-with-eureka: true # 允许将当前服务注册到eureka注册中心fetch-registry: true # 允许当前微服务拉取注册中心中的服务信息service-url:defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/  # eureka注册中心的地址

3.编写启动类

@SpringBootApplication
@MapperScan(basePackages = "com.xq.dao")
@EnableDiscoveryClient //开启服务发现的功能
public class ProviderApplication {public static void main(String[] args) {SpringApplication.run(ProviderApplication.class,args);}
}

4. 编写业务逻辑

（1）整合mybatis

dao层

public interface PaymentDao {//根据id查询payment信息public Payment findById(long id);//新增payment信息public void add(Payment payment);
}

创建dao接口的映射文件还有mybatis的核心配置文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="org.mumu.dao.PaymentDao"><!--根据id查询payment信息--><select id="findById" parameterType="long" resultType="payment">SELECT * FROM `payment` WHERE id = #{id}</select><!--新增payment信息--><insert id="add" parameterType="payment">INSERT INTO `payment`(`id`,`serial`) VALUES(#{id},#{serial})</insert>
</mapper>

配置 MyBatis 的类型别名，简化 MyBatis 映射文件中的配置 

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN""http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration><!--取别名--><typeAliases><package name="org.mumu.pojo"></package></typeAliases>
</configuration>

（2）Service

@Service
public class PaymentServiceImpl implements PaymentService {@ResourcePaymentDao paymentDao;@Overridepublic Payment findById(long id) {return paymentDao.findById(id);}@Overridepublic void add(Payment payment) {paymentDao.add(payment);}@Overridepublic void save(Payment payment) {paymentDao.add(payment);}
}

5.定义控制器

@RestController
@RequestMapping("provider")
public class PaymentController {@ResourcePaymentService paymentService;@Value("${server.port}")String port;@RequestMapping("findById")public Result<Payment> findById(@RequestParam("id") long id){try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}Payment payment = paymentService.findById(id);return new Result<>(200,"数据查询成功,当前服务端口号是:" + this.port,payment);}
}

四、搭建服务消费方consumer

1.依赖引入

<dependencies><dependency><groupId>org.mumu</groupId><artifactId>springcloud-service-common</artifactId><version>1.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--eureka-client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency></dependencies>

2.配置类

server:port: 80
spring:application:name: service-consumer
eureka:client:register-with-eureka: true # 允许将当前服务注册到eureka注册中心fetch-registry: true # 允许当前微服务拉取注册中心中的服务信息service-url:defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/  # eureka注册中心的地址

3.启动类

@SpringBootApplication
@EnableDiscoveryClient
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class,args);}
}

4.注入RestTemplate组件到ioc容器

使用 RestTemplate 这个 Java 客户端组件来实现服务的远程调用。所以我们需要将
RestTemplate 使用 Java 配置类进行注入： 
@Configuration
public class MyConfig {@Beanpublic RestTemplate restTemplate(){return new RestTemplate();}}

5.定义控制器

@RestController
@RequestMapping("consumer")
@Slf4j
public class PaymentController {@ResourceRestTemplate restTemplate;@RequestMapping("findById/{id}")public Result<Payment> findById(@PathVariable("id") long id){String url = "http://localhost:8001/provider/findById?id=" + id; //维护服务提供方的ip+端口Result result = restTemplate.getForObject(url, Result.class);return result;}
}

五、搭建服务注册中心

1.引入依赖server

    <dependencies><dependency><groupId>javax.servlet</groupId><artifactId>javax.servlet-api</artifactId><version>4.0.1</version> <!-- 使用与Tomcat 9.0.29 兼容的版本 --></dependency><!--eureka服务端依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency><!--web启动器--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency></dependencies>

2.配置类

这里不需要要进行服务注册，因为这个模块的server模块

负责对其他Client进行服务注册

server:port: 7001
# 配置eureka服务端
eureka:client:register-with-eureka: false  # 禁止自己注册自己fetch-registry: false  # 禁止抓取注册中心中的服务信息service-url:defaultZone: http://localhost:7001/eureka/  # eureka服务端的地址

3.启动类

@SpringBootApplication
@EnableEurekaServer // 标识当前服务是Eurkea服务端
public class EurekaServerApplication {public static void main(String[] args) {SpringApplication.run(EurekaServerApplication.class,args);}
}

六、启动

访问地址：http://localhost:7001

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/164896.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

擎创动态 | 开箱即用！擎创科技联合中科可控推出大模型一体机

擎创动态 | 开箱即用！擎创科技联合中科可控推出大模型一体机

一、金融行业大模型一体机发布 10月26日至27日&#xff0c;2023金融科技安全与创新大会顺利召开。会上&#xff0c;中科可控联合擎创科技、卓世科技、文因互联、百川智能、捷通华声、智谱华章、易道博识等9大厂商&#xff0c;发布了9款金融行业大模型一体机&#xff0c;为金融…
阅读更多...
SpringBoot 学习笔记(四) - 原理篇

SpringBoot 学习笔记(四) - 原理篇

一、自动配置 1.1 bean加载方式 bean的加载方式1 - xml方式声明bean 导入依赖&#xff1a; <dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.3.9</ver…
阅读更多...
aosp定制android系统

aosp定制android系统

目录 AOSP 准备工作(配置) 确定机型和版本 初始化 git安装 curl安装 同步源码 环境变量 创建aosp目录 指定同步版本 解下来安装编译需要的依赖 编译aosp源码 刷入系统 AOSP 全称 Android Open Source Project 是指Android开源项目&#xff0c;它是由Google主导的…
阅读更多...
【JavaEE】HTTP协议（什么是HTTP？、HTTP格式、form表单和ajax构造HTTP）

【JavaEE】HTTP协议（什么是HTTP？、HTTP格式、form表单和ajax构造HTTP）

一、什么是HTTP协议&#xff1f; 1.1 HTTP (全称为 “超文本传输协议”) 是一种应用非常广泛的 应用层协议 1.2 理解HTTP协议的工作过程 当我们在浏览器中输入一个 “网址”, 此时浏览器就会给对应的服务器发送一个 HTTP 请求. 对方服务器收到这个请求之后, 经过计算处理, 就…
阅读更多...
四万字Spark性能优化宝典

四万字Spark性能优化宝典

导读 发现一篇好文&#xff0c;分享给大家。 全文分为四个部分&#xff0c;基本涵盖了所有Spark优化的点&#xff0c;全文较长&#xff0c;建议收藏后PC端查看或工作中问题troubleshooting。 《Spark性能优化&#xff1a;开发调优篇》 《Spark性能优化&#xff1a;资源调优…
阅读更多...
linux继续循环案例测试ping网络，目录下的文件权限循环输出

linux继续循环案例测试ping网络，目录下的文件权限循环输出

第一&#xff1a;查看本机ip #ip addr 通过脚本访问本机ip1-100&#xff0c;是否可以ping通&#xff0c;并显示结果&#xff0c;上图 知识点 ping -c 数字1 -w 数字1&#xff0c;向目的ip发送1个数据包&#xff0c;等待1秒&#xff0c;无回复中止 &>/dev/null 知…
阅读更多...
鸿蒙开发工具DevEco Studio的下载和安装

鸿蒙开发工具DevEco Studio的下载和安装

一、DevEco Studio概述 1、简介 HUAWEI DevEco Studio&#xff08;获取工具请单击链接下载&#xff0c;以下简称DevEco Studio&#xff09;是基于IntelliJ IDEA Community开源版本打造&#xff0c;为运行在HarmonyOS和OpenHarmony系统上的应用和服务&#xff08;以下简称应用…
阅读更多...
GIS开发入门，TopoJSON格式是什么？TopoJSON格式与GeoJSON格式有什么不同？

GIS开发入门，TopoJSON格式是什么？TopoJSON格式与GeoJSON格式有什么不同？

TopoJSON介绍 TopoJSON是一种几何拓扑结构的地理数据格式，它使用拓扑结构来表示地理对象，可以更有效地压缩和转移数据，从而加快数据加载速度。 TopoJSON格式构成 TopoJSON文件由三部分组成，transform、objects和arcs组成。transform描述了变换参数； objects描述地理实体…
阅读更多...
【无代码】【VR开发】【Unity】【VRTK】4-导入VRTK Tilia Package

【无代码】【VR开发】【Unity】【VRTK】4-导入VRTK Tilia Package

【导入VRTK V4】 VRTK的Tilia Package包含了一整套空间开发方案。导入后你可以在PackageManager中看到它们。 所有的Tilia包都可以在如下页面找到： https://www.vrtk.io/tilia.html Tilia包有一个安装器，可以让你仅仅安装需要的包。包的种类很多，按照适用方向分类。 点击H…
阅读更多...
基于SpringBoot+Redis的前后端分离外卖项目-苍穹外卖(一)

基于SpringBoot+Redis的前后端分离外卖项目-苍穹外卖(一)

熟悉项目环境 1. 苍穹外卖项目介绍1.1 项目介绍1.2 技术选型 2. 开发环境搭建2.1 前端环境2.2 后端环境搭建2.3 Git版本控制2.4 nginx反向代理和负载均衡 3.登录功能4. Swagger4.1 介绍4.2 使用步骤4.3 常用注解 1. 苍穹外卖项目介绍 1.1 项目介绍 苍穹外卖是专门为餐饮企业&…
阅读更多...
MCU常见通信总线串讲（四）—— SPI总线协议

MCU常见通信总线串讲（四）—— SPI总线协议

&#x1f64c;秋名山码民的主页 &#x1f602;oi退役选手&#xff0c;Java、大数据、单片机、IoT均有所涉猎&#xff0c;热爱技术&#xff0c;技术无罪 &#x1f389;欢迎关注&#x1f50e;点赞&#x1f44d;收藏⭐️留言&#x1f4dd; 获取源码&#xff0c;添加WX 目录 前言一…
阅读更多...
智能网联汽车基础软件信息安全需求分析

智能网联汽车基础软件信息安全需求分析

目录 1.安全启动 2.安全升级 3.安全存储 4.安全通信 5.安全调试 6.安全诊断 7.小结 1.安全启动 对于MCU&#xff0c;安全启动主要是以安全岛BootROM为信任根&#xff0c;在MCU启动后&#xff0c;用户程序运行前&#xff0c;硬件加密模块采用逐级校验、并行校验或者混合校…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023