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

    一、父工程依赖管理

    1. "1.0" encoding="UTF-8"?>
    2. "http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     4.0.0
    6.  
    7.     org.mumu
    8.     eureka
    9.     pom
    10.     1.0
    11.     
    12.         <module>commonmodule>
    13.         <module>consumermodule>
    14.         <module>springcloud-service-providermodule>
    15.     
    16.  
    17.     
    18.         UTF-8
    19.         1.8
    20.         1.8
    21.         4.12
    22.         1.2.17
    23.         5.1.47
    24.         1.16.18
    25.         1.1.16
    26.         1.3.0
    27.     
    28.     
    29.         
    30.             
    31.                 org.springframework.cloud
    32.                 spring-cloud-starter-netflix-eureka-client
    33.                 2.2.1.RELEASE
    34.             
    35.             
    36.                 org.springframework.cloud
    37.                 spring-cloud-starter-netflix-eureka-server
    38.                 2.2.1.RELEASE
    39.             
    40.             
    41.                 org.apache.maven.plugins
    42.                 maven-project-info-reports-plugin
    43.                 3.0.0
    44.             
    45.             
    46.                 org.springframework.boot
    47.                 spring-boot-dependencies
    48.                 2.2.2.RELEASE
    49.                 pom
    50.                 import
    51.             
    52.             
    53.                 mysql
    54.                 mysql-connector-java
    55.                 ${mysql.version}
    56.                 runtime
    57.             
    58.             
    59.             
    60.                 com.alibaba
    61.                 druid-spring-boot-starter
    62.                 1.1.10
    63.             
    64.             
    65.                 org.mybatis.spring.boot
    66.                 mybatis-spring-boot-starter
    67.                 ${mybatis.spring.boot.version}
    68.             
    69.             
    70.                 junit
    71.                 junit
    72.                 ${junit.version}
    73.             
    74.         
    75.     
    76.  
    77.     
    78.         
    79.             
    80.                 org.springframework.boot
    81.                 spring-boot-maven-plugin
    82.                 
    83.                     true
    84.                 
    85.             
    86.         
    87.     
    88.

    二、搭建公共模块common

    放一些pojo类

    1. 依赖引入

    1. "1.0" encoding="UTF-8"?>
    2. "http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     
    6.         eureka
    7.         org.mumu
    8.         1.0
    9.     
    10.     4.0.0
    11.     springcloud-service-common
    12.     1.0
    13.     
    14.         8
    15.         8
    16.     
    17.     
    18.         
    19.             org.projectlombok
    20.             lombok
    21.             1.18.30
    22.         
    23.     
    24.

    2.实体类

    1.  
    2. @Data // 省略写get set方法
    3. @NoArgsConstructor //提供无参数的构造函数
    4. @AllArgsConstructor //提供带所有参数的构造函数
    5. public class Payment implements Serializable {
    6.  
    7.     private long id;
    8.     private String serial;
    9. }

    三、搭建服务提供方provider

    1.依赖引入

    1. "1.0" encoding="UTF-8"?>
    2. "http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     
    6.         eureka
    7.         org.mumu
    8.         1.0
    9.     
    10.     4.0.0
    11.  
    12.     springcloud-service-provider
    13.     1.0
    14.     org.mumu
    15.  
    16.     
    17.         8
    18.         8
    19.     
    20.  
    21.     
    22.         
    23.             org.mumu
    24.             springcloud-service-common
    25.             1.0
    26.         
    27.         
    28.             org.springframework.boot
    29.             spring-boot-starter-web
    30.         
    31.         
    32.             org.springframework.boot
    33.             spring-boot-starter-actuator
    34.         
    35.         
    36.             org.mybatis.spring.boot
    37.             mybatis-spring-boot-starter
    38.         
    39.         
    40.             com.alibaba
    41.             druid-spring-boot-starter
    42.         
    43.         
    44.         
    45.             mysql
    46.             mysql-connector-java
    47.         
    48.         
    49.         
    50.             org.springframework.boot
    51.             spring-boot-starter-jdbc
    52.         
    53.         
    54.             org.springframework.boot
    55.             spring-boot-devtools
    56.             runtime
    57.             true
    58.         
    59.         
    60.             org.projectlombok
    61.             lombok
    62.             true
    63.         
    64.         
    65.             org.springframework.boot
    66.             spring-boot-starter-test
    67.             test
    68.         
    69.         
    70.         
    71.             org.springframework.cloud
    72.             spring-cloud-starter-netflix-eureka-client
    73.         
    74.     
    75.

    2.配置类

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

    3.编写启动类

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

    4. 编写业务逻辑

    （1）整合mybatis

    dao层

    1. public interface PaymentDao {
    2.  
    3.     //根据id查询payment信息
    4.     public Payment findById(long id);
    5.  
    6.     //新增payment信息
    7.     public void add(Payment payment);
    8. }

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

    1. "1.0" encoding="UTF-8" ?>
    2. "-//mybatis.org//DTD Mapper 3.0//EN"
    3.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
    4. "org.mumu.dao.PaymentDao">
    5.  
    6.     
    7.     
    8.  
    9.     
    10.     "add" parameterType="payment">
    11.         INSERT INTO `payment`(`id`,`serial`) VALUES(#{id},#{serial})
    12.

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

    1. "1.0" encoding="UTF-8"?>
    2. "-//mybatis.org//DTD Config 3.0//EN"
    3.         "http://mybatis.org/dtd/mybatis-3-config.dtd">
    5.     
    6.     
    7.         <package name="org.mumu.pojo">package>
    8.

    （2）Service

    1. @Service
    2. public class PaymentServiceImpl implements PaymentService {
    3.  
    4.     @Resource
    5.     PaymentDao paymentDao;
    6.  
    7.     @Override
    8.     public Payment findById(long id) {
    9.         return paymentDao.findById(id);
    10.     }
    11.  
    12.     @Override
    13.     public void add(Payment payment) {
    14.         paymentDao.add(payment);
    15.     }
    16.  
    17.     @Override
    18.     public void save(Payment payment) {
    19.         paymentDao.add(payment);
    20.     }
    21. }

    5.定义控制器

    1. @RestController
    2. @RequestMapping("provider")
    3. public class PaymentController {
    4.     @Resource
    5.     PaymentService paymentService;
    6.     @Value("${server.port}")
    7.     String port;
    8.  
    9.     @RequestMapping("findById")
    10.     public Result findById(@RequestParam("id") long id){
    11.         try {
    12.             Thread.sleep(3000);
    13.         } catch (InterruptedException e) {
    14.             e.printStackTrace();
    15.         }
    16.         Payment payment = paymentService.findById(id);
    17.         return new Result<>(200,"数据查询成功,当前服务端口号是:" + this.port,payment);
    18.     }
    19. }

    四、搭建服务消费方consumer

    1.依赖引入

    2.         
    3.             org.mumu
    4.             springcloud-service-common
    5.             1.0
    6.         
    7.         
    8.             org.springframework.boot
    9.             spring-boot-starter-web
    10.         
    11.         
    12.             org.springframework.boot
    13.             spring-boot-starter-actuator
    14.         
    15.         
    16.             org.springframework.boot
    17.             spring-boot-devtools
    18.             runtime
    19.             true
    20.         
    21.         
    22.             org.projectlombok
    23.             lombok
    24.             true
    25.         
    26.         
    27.             org.springframework.boot
    28.             spring-boot-starter-test
    29.             test
    30.         
    31.         
    32.         
    33.             org.springframework.cloud
    34.             spring-cloud-starter-netflix-eureka-client
    35.         
    36.

    2.配置类

    1. server:
    2.   port: 80
    3. spring:
    4.   application:
    5.     name: service-consumer
    6. eureka:
    7.   client:
    8.     register-with-eureka: true # 允许将当前服务注册到eureka注册中心
    9.     fetch-registry: true # 允许当前微服务拉取注册中心中的服务信息
    10.     service-url:
    11.       defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/  # eureka注册中心的地址
    12.

    3.启动类

    1. @SpringBootApplication
    2. @EnableDiscoveryClient
    3. public class ConsumerApplication {
    4.     public static void main(String[] args) {
    5.         SpringApplication.run(ConsumerApplication.class,args);
    6.     }
    7. }

    4.注入RestTemplate组件到ioc容器

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

    5.定义控制器

    1. @RestController
    2. @RequestMapping("consumer")
    3. @Slf4j
    4. public class PaymentController {
    5.  
    6.    @Resource
    7.    RestTemplate restTemplate;
    8.  
    9.  
    10.     @RequestMapping("findById/{id}")
    11.     public Result findById(@PathVariable("id") long id){
    12.         String url = "http://localhost:8001/provider/findById?id=" + id; //维护服务提供方的ip+端口
    13.         Result result = restTemplate.getForObject(url, Result.class);
    14.         return result;
    15.     }
    16. }

    五、搭建服务注册中心

    1.引入依赖server

    1.     
    2.         
    3.             javax.servlet
    4.             javax.servlet-api
    5.             4.0.1 
    6.         
    7.         
    8.         
    9.             org.springframework.cloud
    10.             spring-cloud-starter-netflix-eureka-server
    11.         
    12.  
    13.         
    14.         
    15.             org.springframework.boot
    16.             spring-boot-starter-web
    17.         
    18.  
    19.         
    20.             org.springframework.boot
    21.             spring-boot-starter-actuator
    22.         
    23.  
    24.         
    25.             org.springframework.boot
    26.             spring-boot-devtools
    27.             runtime
    28.             true
    29.         
    30.

    2.配置类

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

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

    1. server:
    2.   port: 7001
    3. # 配置eureka服务端
    4. eureka:
    5.   client:
    6.     register-with-eureka: false  # 禁止自己注册自己
    7.     fetch-registry: false  # 禁止抓取注册中心中的服务信息
    8.     service-url:
    9.       defaultZone: http://localhost:7001/eureka/  # eureka服务端的地址

    3.启动类

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

    六、启动

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

  • 相关阅读:
    web大作业 静态网页 HTML+CSS+JavaScript橙色的时尚服装购物商城
    spring cloud 全家桶 简单介绍
    【MySql进阶】索引详解（一）：索引数据页结构
    Vue开发环境安装
    【配置文件】Redis配置文件解读和持久化
    Spring Cloud Alibaba 工程搭建
    【C++】：list容器的基本使用
    PS文字创建工作路径矢量化后变细，导出的svg也变细的解决方案
    Vue项目devServer.proxy代理配置详解
    Mysql进阶-视图篇
  • 原文地址：https://blog.csdn.net/Candy___i/article/details/134216934