微服务架构编码构建

叁歲伎倆 2023-10-11 20:31 135阅读 0赞

目录

一、约定 > 配置 > 编码

二、IDEA新建project工作空间

(一)微服务cloud整体聚合父工程Project

(二)父工程POM

(三)Maven工程落地细节复习

三、Rest微服务工程构建

(一)cloud-provider-payment8001 微服务提供者支付Module模块

(二)cloud-consumer-order80 微服务消费者订单Module模块


一、约定 > 配置 > 编码

二、IDEA新建project工作空间

(一)微服务cloud整体聚合父工程Project

1、New Project

1ea85cb045864ee0b52978fc24d16fee.png

2、聚合总父工程名字

372e4657b2754a00a14e3a1156a1a024.png

3、Maven选版本

41eb408a67c04257a9f0baccdbe5d7dc.png

4、工程名字

5da303c6c0df4530af833672375bd04a.png

5、字符编码

a69d76c59cd346f18a35b98559d05cdd.png

6、注解生效激活

ccb6fe7811c348dcb8418ab096e972bd.png

7、java编译版本选8

23612e56d88145cfaed4fb3803de1976.png

8、File Type过滤

8d6055d0fa8445b598d9d38cb136777b.png

(二)父工程POM

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  5. <groupId>com.atguigu.springcloud</groupId>
  6. <artifactId>mscloud03</artifactId>
  7. <version>1.0-SNAPSHOT</version>
  8. <packaging>pom</packaging>
  9. <!-- 统一管理jar包版本 -->
  10. <properties>
  11. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  12. <maven.compiler.source>1.8</maven.compiler.source>
  13. <maven.compiler.target>1.8</maven.compiler.target>
  14. <junit.version>4.12</junit.version>
  15. <log4j.version>1.2.17</log4j.version>
  16. <lombok.version>1.16.18</lombok.version>
  17. <mysql.version>5.1.47</mysql.version>
  18. <druid.version>1.1.16</druid.version>
  19. <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
  20. </properties>
  21. <!-- 子模块继承之后,提供作用:锁定版本+子modlue不用写groupId和version -->
  22. <dependencyManagement>
  23. <dependencies>
  24. <!--spring boot 2.2.2-->
  25. <dependency>
  26. <groupId>org.springframework.boot</groupId>
  27. <artifactId>spring-boot-dependencies</artifactId>
  28. <version>2.2.2.RELEASE</version>
  29. <type>pom</type>
  30. <scope>import</scope>
  31. </dependency>
  32. <!--spring cloud Hoxton.SR1-->
  33. <dependency>
  34. <groupId>org.springframework.cloud</groupId>
  35. <artifactId>spring-cloud-dependencies</artifactId>
  36. <version>Hoxton.SR1</version>
  37. <type>pom</type>
  38. <scope>import</scope>
  39. </dependency>
  40. <!--spring cloud alibaba 2.1.0.RELEASE-->
  41. <dependency>
  42. <groupId>com.alibaba.cloud</groupId>
  43. <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  44. <version>2.1.0.RELEASE</version>
  45. <type>pom</type>
  46. <scope>import</scope>
  47. </dependency>
  48. <dependency>
  49. <groupId>mysql</groupId>
  50. <artifactId>mysql-connector-java</artifactId>
  51. <version>${mysql.version}</version>
  52. </dependency>
  53. <dependency>
  54. <groupId>com.alibaba</groupId>
  55. <artifactId>druid</artifactId>
  56. <version>${druid.version}</version>
  57. </dependency>
  58. <dependency>
  59. <groupId>org.mybatis.spring.boot</groupId>
  60. <artifactId>mybatis-spring-boot-starter</artifactId>
  61. <version>${mybatis.spring.boot.version}</version>
  62. </dependency>
  63. <dependency>
  64. <groupId>junit</groupId>
  65. <artifactId>junit</artifactId>
  66. <version>${junit.version}</version>
  67. </dependency>
  68. <dependency>
  69. <groupId>log4j</groupId>
  70. <artifactId>log4j</artifactId>
  71. <version>${log4j.version}</version>
  72. </dependency>
  73. <dependency>
  74. <groupId>org.projectlombok</groupId>
  75. <artifactId>lombok</artifactId>
  76. <version>${lombok.version}</version>
  77. <optional>true</optional>
  78. </dependency>
  79. </dependencies>
  80. </dependencyManagement>
  81. <build>
  82. <plugins>
  83. <plugin>
  84. <groupId>org.springframework.boot</groupId>
  85. <artifactId>spring-boot-maven-plugin</artifactId>
  86. <configuration>
  87. <fork>true</fork>
  88. <addResources>true</addResources>
  89. </configuration>
  90. </plugin>
  91. </plugins>
  92. </build>
  93. </project>

(三)Maven工程落地细节复习

1、Maven中的DependencyManagement和Dependencies

dependencyManagement

Maven 使用dependencyManagement 元素来提供了一种管理依赖版本号的方式
通常会在一个组织或者项目的最顶层的父POM 中看到dependencyManagement 元素。

使用pom.xml 中的dependencyManagement 元素能让所有在子项目中引用一个依赖而不用显式的列出版本号。
Maven 会沿着父子层次向上走,直到找到一个拥有dependencyManagement 元素的项目,然后它就会使用这个dependencyManagement 元素中指定的版本号。

这样做的好处就是:如果有多个子项目都引用同一样依赖,则可以避免在每个使用的子项目里都声明一个版本号,这样当想升级或切换到另一个版本时,只需要在顶层父容器里更新,而不需要一个一个子项目的修改 ;另外如果某个子项目需要另外的一个版本,只需要声明version就可。

  • dependencyManagement里只是声明依赖,并不实现引入,因此子项目需要显示的声明需要用的依赖。
  • 如果不在子项目中声明依赖,是不会从父项目中继承下来的;只有在子项目中写了该依赖项,并且没有指定具体版本,才会从父项目中继承该项,并且version和scope都读取自父pom;
  • 如果子项目中指定了版本号,那么会使用子项目中指定的jar版本。

2、maven中跳过单元测试

(1)配置

  1. <build><!-- maven中跳过单元测试 -->
  2. <plugins>
  3. <plugin>
  4. <groupId>org.apache.maven.plugins</groupId>
  5. <artifactId>maven-surefire-plugin</artifactId>
  6. <configuration>
  7. <skip>true</skip>
  8. </configuration>
  9. </plugin>
  10. </plugins>
  11. </build>

(2)IDEA工具支持(推荐)

69f226c9434d4d83b37a650dcf797e1b.png

3、父工程创建完成执行mvn:install将父工程发布到仓库方便子工程继承

4、mysql驱动说明


com.mysql.jdbc.Driver和mysql-connector-java 5一起用。
com.mysql.cj.jdbc.Driver和mysql-connector-java 6 一起用。

com.mysql.cj.jdbc.Driver是mysql-connector-java 6 中的特性,相比mysql-connector-java 5 多了一个时区:serverTimezone,把数据源配置的驱动改一下就好了

org.gjt.mm.mysql.Driver是当时最好的MySQL JDBC,但不是MySQL公司的,然后MySQL将MM的JDBC驱动 收为官方的JDBC驱动,所以将驱动的package也改了,但还保留了org.gjt.mm.mysql.Driver这个路径的引用,也就是你使用新版的JDBC驱动时还可以通过这个来引用,打开下载的新版JDBC驱动的jar文件可以看到,只有一个文件的目录是org.gjt.mm.mysql,就是为了兼容而设计的。

三、Rest微服务工程构建

(一)cloud-provider-payment8001 微服务提供者支付Module模块

1、建cloud-provider-payment8001

2、改POM

  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>mscloud03</artifactId>
  7. <groupId>com.atguigu.springcloud</groupId>
  8. <version>1.0-SNAPSHOT</version>
  9. </parent>
  10. <modelVersion>4.0.0</modelVersion>
  11. <artifactId>cloud-provider-payment8001</artifactId>
  12. <dependencies>
  13. <dependency>
  14. <groupId>org.springframework.boot</groupId>
  15. <artifactId>spring-boot-starter-web</artifactId>
  16. </dependency>
  17. <dependency>
  18. <groupId>org.springframework.boot</groupId>
  19. <artifactId>spring-boot-starter-actuator</artifactId>
  20. </dependency>
  21. <dependency>
  22. <groupId>org.mybatis.spring.boot</groupId>
  23. <artifactId>mybatis-spring-boot-starter</artifactId>
  24. </dependency>
  25. <dependency>
  26. <groupId>com.alibaba</groupId>
  27. <artifactId>druid-spring-boot-starter</artifactId>
  28. <version>1.1.10</version>
  29. </dependency>
  30. <!--mysql-connector-java-->
  31. <dependency>
  32. <groupId>mysql</groupId>
  33. <artifactId>mysql-connector-java</artifactId>
  34. </dependency>
  35. <!--jdbc-->
  36. <dependency>
  37. <groupId>org.springframework.boot</groupId>
  38. <artifactId>spring-boot-starter-jdbc</artifactId>
  39. </dependency>
  40. <dependency>
  41. <groupId>org.springframework.boot</groupId>
  42. <artifactId>spring-boot-devtools</artifactId>
  43. <scope>runtime</scope>
  44. <optional>true</optional>
  45. </dependency>
  46. <dependency>
  47. <groupId>org.projectlombok</groupId>
  48. <artifactId>lombok</artifactId>
  49. <optional>true</optional>
  50. </dependency>
  51. <dependency>
  52. <groupId>org.springframework.boot</groupId>
  53. <artifactId>spring-boot-starter-test</artifactId>
  54. <scope>test</scope>
  55. </dependency>
  56. </dependencies>
  57. </project>

3、写YML

  1. server:
  2. port: 8001
  3. spring:
  4. application:
  5. name: cloud-payment-service
  6. datasource:
  7. type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型
  8. driver-class-name: org.gjt.mm.mysql.Driver # mysql驱动包 com.mysql.jdbc.Driver
  9. url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
  10. username: root
  11. password: 123456
  12. mybatis:
  13. mapperLocations: classpath:mapper/*.xml
  14. type-aliases-package: com.atguigu.springcloud.entities # 所有Entity别名类所在包

4、主启动

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

5、业务类

(1)建表sql

  1. CREATE TABLE `payment` (
  2. `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  3. `serial` varchar(200) DEFAULT '',
  4. PRIMARY KEY (`id`)
  5. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8

(2)entities

①主实体Payment

  1. @Data
  2. @AllArgsConstructor
  3. @NoArgsConstructor
  4. public class Payment implements Serializable
  5. {
  6. private Long id;
  7. private String serial;
  8. }

②Json封装体CommonResult

  1. @Data
  2. @AllArgsConstructor
  3. @NoArgsConstructor
  4. public class CommonResult<T>
  5. {
  6. private Integer code;
  7. private String message;
  8. private T data;
  9. public CommonResult(Integer code, String message)
  10. {
  11. this(code,message,null);
  12. }
  13. }

(3)dao

①接口PaymentDao

  1. @Mapper //import org.apache.ibatis.annotations.Mapper;
  2. public interface PaymentDao
  3. {
  4. public int create(Payment payment);
  5. public Payment getPaymentById(@Param("id") Long id);
  6. }

②mybaits的映射文件PaymentMapper.xml

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  3. <mapper namespace="com.atguigu.springcloud.dao.PaymentDao">
  4. <resultMap id="BaseResultMap" type="com.atguigu.springcloud.entities.Payment">
  5. <id column="id" property="id" jdbcType="BIGINT"/>
  6. <result column="serial" property="serial" jdbcType="VARCHAR"/>
  7. </resultMap>
  8. <insert id="create" parameterType="Payment" useGeneratedKeys="true" keyProperty="id">
  9. INSERT INTO payment(SERIAL) VALUES(#{serial});
  10. </insert>
  11. <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap" >
  12. SELECT * FROM payment WHERE id=#{id};
  13. </select>
  14. </mapper>

(4)service

①接口PaymentService

  1. public interface PaymentService
  2. {
  3. public int create(Payment payment);
  4. public Payment getPaymentById(@Param("id") Long id);
  5. }

②实现类

  1. @Service
  2. public class PaymentServiceImpl implements PaymentService
  3. {
  4. @Resource
  5. private PaymentDao paymentDao;
  6. @Override
  7. public int create(Payment payment)
  8. {
  9. return paymentDao.create(payment);
  10. }
  11. @Override
  12. public Payment getPaymentById(Long id)
  13. {
  14. return paymentDao.getPaymentById(id);
  15. }
  16. }

(5)controller

  1. @RestController
  2. @Slf4j
  3. public class PaymentController
  4. {
  5. @Resource
  6. private PaymentService paymentService;
  7. @PostMapping(value = "/payment/create")
  8. public CommonResult create(@RequestBody Payment payment)
  9. {
  10. int result = paymentService.create(payment);
  11. log.info("*****插入操作返回结果:" + result);
  12. if(result > 0)
  13. {
  14. return new CommonResult(200,"插入数据库成功",result);
  15. }else{
  16. return new CommonResult(444,"插入数据库失败",null);
  17. }
  18. }
  19. @GetMapping(value = "/payment/get/{id}")
  20. public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  21. {
  22. Payment payment = paymentService.getPaymentById(id);
  23. log.info("*****查询结果:{}",payment);
  24. if (payment != null) {
  25. return new CommonResult(200,"查询成功",payment);
  26. }else{
  27. return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  28. }
  29. }
  30. }

6、测试

(1)http://localhost:8001/payment/get/31

(2)postman模拟post

(二)cloud-consumer-order80 微服务消费者订单Module模块

1、建cloud-consumer-order80

2、改POM

  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>cloud190805</artifactId>
  7. <groupId>com.atguigu.springcloud</groupId>
  8. <version>1.0-SNAPSHOT</version>
  9. </parent>
  10. <modelVersion>4.0.0</modelVersion>
  11. <artifactId>cloud-consumer-order80</artifactId>
  12. <dependencies>
  13. <dependency>
  14. <groupId>org.springframework.boot</groupId>
  15. <artifactId>spring-boot-starter-web</artifactId>
  16. </dependency>
  17. <dependency>
  18. <groupId>org.springframework.boot</groupId>
  19. <artifactId>spring-boot-starter-actuator</artifactId>
  20. </dependency>
  21. <dependency>
  22. <groupId>org.springframework.boot</groupId>
  23. <artifactId>spring-boot-devtools</artifactId>
  24. <scope>runtime</scope>
  25. <optional>true</optional>
  26. </dependency>
  27. <dependency>
  28. <groupId>org.projectlombok</groupId>
  29. <artifactId>lombok</artifactId>
  30. <optional>true</optional>
  31. </dependency>
  32. <dependency>
  33. <groupId>org.springframework.boot</groupId>
  34. <artifactId>spring-boot-starter-test</artifactId>
  35. <scope>test</scope>
  36. </dependency>
  37. </dependencies>
  38. </project>

3、写YML

80端口_百度百科 (baidu.com)

  1. server:
  2. port: 80

4、主启动

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

5、业务类

(1)entities

与上面一致

(2)RestTemplate

RestTemplate提供了多种便捷访问远程Http服务的方法,
是一种简单便捷的访问restful服务模板类,是Spring提供的用于访问Rest服务的客户端模板工具集

(3)config配置类

  1. @Configuration
  2. public class ApplicationContextConfig
  3. {
  4. @Bean
  5. public RestTemplate restTemplate()
  6. {
  7. return new RestTemplate();
  8. }
  9. }

(4)controller

  1. @RestController
  2. public class OrderController
  3. {
  4. public static final String PaymentSrv_URL = "http://localhost:8001";
  5. @Autowired
  6. private RestTemplate restTemplate;
  7. @GetMapping("/consumer/payment/create") //客户端用浏览器是get请求,但是底层实质发送post调用服务端8001
  8. public CommonResult create(Payment payment)
  9. {
  10. return restTemplate.postForObject(PaymentSrv_URL + "/payment/create",payment,CommonResult.class);
  11. }
  12. @GetMapping("/consumer/payment/get/{id}")
  13. public CommonResult getPayment(@PathVariable Long id)
  14. {
  15. return restTemplate.getForObject(PaymentSrv_URL + "/payment/get/"+id, CommonResult.class, id);
  16. }
  17. }

6、测试

http://localhost/consumer/payment/get/1

发表评论

表情:
评论列表 (有 0 条评论,135人围观)

还没有评论,来说两句吧...

相关阅读

    相关 如何构建服务架构

    相信很多人对微服务架构都会产生这样一些疑问,例如我要何时使用微服务架构?又如何将应用程序分解为微服务?分解后,要如何去搭建微服务架构?同时,在微服务架构中,因为会涉及到多个组件

    相关 dubbo+zookeeper构建服务架构

    微服务架构成了当下的技术热点,实现微服务是要付出很大成本的,但也许是因为微服务的优点太过于吸引人,以至于大部分开发者都将它当成未来的发展趋势。 微服务架构的演进过程