IT评测·应用市场-qidao123.com

标题: day03-搭建微服务基础环境02 [打印本页]
作者: 盛世宏图    时间: 2023-4-4 20:08
标题: day03-搭建微服务基础环境02
搭建微服务基础环境02

3.创建使用会员微服务模块-service consumer

3.1需求分析

浏览器向service consumer请求某个数据，service consumer会去向service provider请求数据，然后将service provider返回的数据返回给浏览器。
添加数据同理。
3.2思路分析

3.3实现步骤

3.3.1创建Module&完成配置

步骤同上一篇的2.3.1
（1）创建Module：member-service-consumer-80
（2）在子模块的pom.xml文件中加入相关的依赖：
因为这个模块不需要直接操作数据库，相比于之间的子模块，减少了和数据库相关的依赖。
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="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.     <parent>
  6.         <artifactId>E-Commerce-Center</artifactId>
  7.         <groupId>com.li.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>member-service-consumer-80</artifactId>
  14.     <properties>
  15.         <maven.compiler.source>8</maven.compiler.source>
  16.         <maven.compiler.target>8</maven.compiler.target>
  17.     </properties>
  19.    
  20.     <dependencies>
  21.         
  22.         <dependency>
  23.             <groupId>org.springframework.boot</groupId>
  24.             <artifactId>spring-boot-starter-web</artifactId>
  25.         </dependency>
  27.         
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-actuator</artifactId>
  31.         </dependency>
  33.         
  34.         <dependency>
  35.             <groupId>org.projectlombok</groupId>
  36.             <artifactId>lombok</artifactId>
  37.         </dependency>
  38.     </dependencies>
  39. </project>
复制代码
（3）创建resources/application.yml
  1. server:
  2.   port: 80
  3. spring:
  4.   application:
  5.     name: member-service-consumer-80
复制代码
（4）创建启动类
  1. package com.li.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. /**
  7. * @author 李
  8. * @version 1.0
  9. */
  10. @SpringBootApplication
  11. public class MemberConsumerApplication {
  12.     public static void main(String[] args) {
  13.         SpringApplication.run(MemberConsumerApplication.class,args);
  14.     }
  15. }
复制代码
测试，启动成功：
3.3.1业务实现

3.3.1.1utils层

创建工具类Result.java（略，见2.3.3.1）
3.3.1.2Entity层

Member.java
  1. package com.li.springcloud.entity;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. /**
  8. * @author 李
  9. * @version 1.0
  10. */
  11. @Data
  12. @AllArgsConstructor
  13. @NoArgsConstructor
  14. //因为对象在网络中以流的形式传递，这里最好实现Serializable接口
  15. public class Member implements Serializable{
  16.     private Long id;
  17.     private String name;
  18.     private String pwd;
  19.     private String mobile;
  20.     private String email;
  21.     private Integer gender;
  22. }
复制代码
3.3.1.3注入RestTemplate

RestTemplate 基本介绍：RestTemplate 是 Spring 提供的用于访问Rest服务的模板类，它提供来了许多便捷访问远程 Http 服务的方法。
通过 RestTemplate，我们可以向另一个微服务模块发出 Http 请求（支持 Restful 风格），去调用该模块的 Controller 提供的 API 接口，就像浏览器发出请求调用该 API 接口一样。
RestTemplate 官网：RestTemplate (Spring Framework 5.2.2.RELEASE API)
创建配置类，注入RestTemplate对象：
  1. package com.li.springcloud.config;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.web.client.RestTemplate;
  7. /**
  8. * @author 李
  9. * @version 1.0
  10. * 注入RestTemplate Bean
  11. */
  12. @Configuration
  13. public class CustomInitBean {
  14.     @Bean
  15.     public RestTemplate getRestTemplate() {
  16.         return new RestTemplate();
  17.     }
  18. }
复制代码
3.3.1.4Controller层

MemberConsumerController.java：
  1. package com.li.springcloud.controller;
  3. import com.li.springcloud.entity.Member;
  4. import com.li.springcloud.utils.Result;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.springframework.stereotype.Controller;
  7. import org.springframework.validation.annotation.Validated;
  8. import org.springframework.web.bind.annotation.GetMapping;
  9. import org.springframework.web.bind.annotation.PathVariable;
  10. import org.springframework.web.bind.annotation.PostMapping;
  11. import org.springframework.web.bind.annotation.RestController;
  12. import org.springframework.web.client.RestTemplate;
  14. import javax.annotation.Resource;
  16. /**
  17. * @author 李
  18. * @version 1.0
  19. */
  20. @RestController
  21. @Slf4j
  22. public class MemberConsumerController {
  23.     @Resource
  24.     private RestTemplate restTemplate;
  26.     //定义一个基础的url
  27.     public static final String MEMBER_SERVICE_PROVIDER_URL =
  28.             "http://localhost:10000";
  30.     //添加对象到数据库表中
  31.     @PostMapping("/member/consumer/save")
  32.     public Result<Member> save(Member member) {
  33.         log.info("service-consumer member={}", member);
  34.         /**
  35.          * MEMBER_SERVICE_PROVIDER_URL + "/member/save"：就是向对应子模块发出的完整url请求
  36.          * member：就是通过 restTemplate 发出的 post 请求携带的数据（对象）
  37.          * Result.class：就是返回的对象类型
  38.          */
  39.         return restTemplate.postForObject
  40.                 (MEMBER_SERVICE_PROVIDER_URL + "/member/save",
  41.                         member,
  42.                         Result.class);
  43.     }
  45.     //根据id调用服务接口，返回member对象信息
  46.     @GetMapping("/member/consumer/get/{id}")
  47.     public Result<Member> getMemberById(@PathVariable("id") Integer id) {
  48.         return restTemplate.getForObject
  49.                 (MEMBER_SERVICE_PROVIDER_URL + "/member/get/" + id,
  50.                         Result.class);
  51.     }
  52. }
复制代码
3.3.1完成测试

分别启动两个子模块（service consumer、service provider）
（1）测试save方法：postman以表单形式发出数据：
结果显示添加成功，但是我们在数据库中看到的确是空值：
原因是因为使用RestTemplate，它会将数据以json格式发送。解决方法是在服务模块对应方法参数中使用@RequestBody注解，将接收的json格式数据转换成对象。
最好实体类实现Serializable，支持可序列化
重新启动模块，使用postman发送数据：数据库添加成功。
（2）浏览器测试getMemberById方法：
测试通过。
3.4注意事项和使用细节

当SpringCloud的服务有多个时，管理多个服务的启动使用右上角的run会不好管理，我们可以使用Run Dashboard：idea中如何开启Dashboard
4.创建共用模块-供其他模块使用

4.1需求分析

我们在 consumer 和 provider 模块都使用到了 Member 和 Result 类，我们可以将它们抽取到共用模块（e_commerce_center_common-api），使用Maven 打包成 jar包，其他模块需要使用直接引入依赖即可。
4.2思路分析

4.3实现步骤

4.3.1创建Module&完成配置

（1）创建Module--e_commerce_center_common-api
（2）在本模块的pom.xml引入公共的依赖
  1.     <dependencies>
  2.         
  3.         <dependency>
  4.             <groupId>org.projectlombok</groupId>
  5.             <artifactId>lombok</artifactId>
  6.             
  7.             <optional>true</optional>
  8.         </dependency>
  9.     </dependencies>
复制代码
4.3.2抽取共用的API/类

创建多个子模块都要使用的公共类，注意路径要和其他模块的路径相同。
4.3.3使用Maven打包成jar

（1）按如下步骤进行打包：
（2）成功后会在target目录下生成对应的jar包：
并且maven-archiver下的pom.properties中生成了项目对应的坐标：
  1. #Generated by Maven
  2. #Tue Apr 04 19:38:29 CST 2023
  3. version=1.0-SNAPSHOT
  4. groupId=com.li.springcloud
  5. artifactId=e_commerce_center_common-api
复制代码
4.3.4工程重构

（1）在 member-service-provider-10000 模块删除当前模块的 entity 包和 utils 包
（2）在 member-service-provider-10000 的 pom.xml 引入公共模块：
  1. <dependency>
  2.     <groupId>com.li.springcloud</groupId>
  3.     <artifactId>e_commerce_center_common-api</artifactId>
  4.     <version>1.0-SNAPSHOT</version>
  5. </dependency>
复制代码
然后点击刷新Maven，这样就可以引入之前打包好的jar包代码了。
（3）同理，在 member-service-consumer-80 模块中也删除 entity 和 utils 包，然后在本模块的 pom.xml 文件中也引入公共模块，然后刷新。
4.3.5完成测试

分别启动 member-service-provider-10000 和 member-service-consumer-80 两个子模块，在浏览器中发送请求进行测试：
如下，测试成功，工程进行重构之后没有问题，公共模块引入各个模块之后依然可以工作。
之后如果多个模块还有公共的类，依然可以通过这种方式来抽取共用的API/类，然后通过引入公共模块的方式来简化代码。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/) Powered by Discuz! X3.4