springcloud微服务（一）

短命女 2023-07-21 11:09 83阅读 0赞

springcloud微服务（一）

父依赖

  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.     <modelVersion>4.0.0</modelVersion>
  7.     <groupId>com.xiao</groupId>
  8.     <artifactId>springcloud-02</artifactId>
  9.     <version>1.0-SNAPSHOT</version>
  10.     <modules>
  11.         <module>springcloud-api</module>
  12.         <module>springcloud-provider-dept-8001</module>
  13.         <module>springcloud-consumer-dept-80</module>
  14.     </modules>
  15.     <!--打包方式  pom-->
  16.     <packaging>pom</packaging>
  18.     <properties>
  19.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  20.         <maven.compiler.source>1.8</maven.compiler.source>
  21.         <maven.compiler.target>1.8</maven.compiler.target>
  22.         <junit.version>4.12</junit.version>
  23.         <log4j.version>1.2.17</log4j.version>
  24.         <lombok.version>1.18.12</lombok.version>
  25.     </properties>
  27.     <dependencyManagement>
  28.         <dependencies>
  29.             <dependency>
  30.                 <groupId>org.springframework.cloud</groupId>
  31.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  32.                 <version>0.2.0.RELEASE</version>
  33.                 <type>pom</type>
  34.                 <scope>import</scope>
  35.             </dependency>
  36.             <!--springCloud的依赖-->
  37.             <dependency>
  38.                 <groupId>org.springframework.cloud</groupId>
  39.                 <artifactId>spring-cloud-dependencies</artifactId>
  40.                 <version>Greenwich.SR1</version>
  41.                 <type>pom</type>
  42.                 <scope>import</scope>
  43.             </dependency>
  44.             <!--SpringBoot-->
  45.             <dependency>
  46.                 <groupId>org.springframework.boot</groupId>
  47.                 <artifactId>spring-boot-dependencies</artifactId>
  48.                 <version>2.1.4.RELEASE</version>
  49.                 <type>pom</type>
  50.                 <scope>import</scope>
  51.             </dependency>
  52.             <!--数据库-->
  53.             <dependency>
  54.                 <groupId>mysql</groupId>
  55.                 <artifactId>mysql-connector-java</artifactId>
  56.                 <version>5.1.47</version>
  57.             </dependency>
  58.             <dependency>
  59.                 <groupId>com.alibaba</groupId>
  60.                 <artifactId>druid</artifactId>
  61.                 <version>1.1.10</version>
  62.             </dependency>
  63.             <!--SpringBoot 启动器-->
  64.             <dependency>
  65.                 <groupId>org.mybatis.spring.boot</groupId>
  66.                 <artifactId>mybatis-spring-boot-starter</artifactId>
  67.                 <version>1.3.2</version>
  68.             </dependency>
  69.             <!--日志测试~-->
  70.             <dependency>
  71.                 <groupId>ch.qos.logback</groupId>
  72.                 <artifactId>logback-core</artifactId>
  73.                 <version>1.2.3</version>
  74.             </dependency>
  75.             <dependency>
  76.                 <groupId>junit</groupId>
  77.                 <artifactId>junit</artifactId>
  78.                 <version>${
  79.     junit.version}</version>
  80.             </dependency>
  81.             <dependency>
  82.                 <groupId>log4j</groupId>
  83.                 <artifactId>log4j</artifactId>
  84.                 <version>${
  85.     log4j.version}</version>
  86.             </dependency>
  87.             <dependency>
  88.                 <groupId>org.projectlombok</groupId>
  89.                 <artifactId>lombok</artifactId>
  90.                 <version>${
  91.     lombok.version}</version>
  92.             </dependency>
  93.         </dependencies>
  94.     </dependencyManagement>
  96. </project>

服务实体类

依赖

  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.projectlombok</groupId>
  4.             <artifactId>lombok</artifactId>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>mysql</groupId>
  8.             <artifactId>mysql-connector-java</artifactId>
  9.         </dependency>
  10.     </dependencies>

实体类
这里主键是deptno是，自增，

  1. @Data
  2. @NoArgsConstructor
  3. @Accessors(chain = true) //链式写法
  4. public class Dept implements Serializable {
  7.     private Long deptno;
  8.     private String dname;
  9.     private String db_source;
  11.     public Dept(String dname) {
  13.         this.dname = dname;
  14.     }
  15. }

服务提供者

依赖

  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>springcloud-02</artifactId>
  7.         <groupId>com.xiao</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>springcloud-provider-dept-8001</artifactId>
  14.     <!--服务提供者-->
  15.     <dependencies>
  16.         <!--拿到实体类，配置springcloud-api-->
  17.         <!--我们需要拿到实体类，所以要配置api module-->
  18.         <dependency>
  19.             <groupId>com.xiao</groupId>
  20.             <artifactId>springcloud-api</artifactId>
  21.             <version>1.0-SNAPSHOT</version>
  22.         </dependency>
  23.         <!--junit-->
  24.         <dependency>
  25.             <groupId>junit</groupId>
  26.             <artifactId>junit</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>mysql</groupId>
  30.             <artifactId>mysql-connector-java</artifactId>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>com.alibaba</groupId>
  34.             <artifactId>druid</artifactId>
  35.             <version>1.1.18</version>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>ch.qos.logback</groupId>
  39.             <artifactId>logback-core</artifactId>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.mybatis.spring.boot</groupId>
  43.             <artifactId>mybatis-spring-boot-starter</artifactId>
  44.             <version>2.1.1</version>
  45.         </dependency>
  46.         <!--test-->
  47.         <dependency>
  48.             <groupId>org.springframework.boot</groupId>
  49.             <artifactId>spring-boot-test</artifactId>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>org.springframework.boot</groupId>
  53.             <artifactId>spring-boot-starter-web</artifactId>
  54.         </dependency>
  55.         <!--jetty-->
  56.         <dependency>
  57.             <groupId>org.springframework.boot</groupId>
  58.             <artifactId>spring-boot-starter-jetty</artifactId>
  59.         </dependency>
  60.         <!--热部署工具-->
  61.         <dependency>
  62.             <groupId>org.springframework.boot</groupId>
  63.             <artifactId>spring-boot-devtools</artifactId>
  64.             <version>2.1.8.RELEASE</version>
  65.         </dependency>
  66.     </dependencies>
  68. </project>

application配置

  1. server:
  2.   port: 8001
  3.   #mybatis配置
  4. #mybatis配置
  5. mybatis:
  6.   type-aliases-package: com.xiao.springcloud.pojo
  7.   #config-location: classpath:mybatis/mybatis-config.xml
  8.   mapper-locations: classpath:mybatis/mapper/*.xml
  11. #spring的配置
  12. spring:
  13.   application:
  14.     name: springcloud-provider-dept
  15.   datasource:
  16.     type: com.alibaba.druid.pool.DruidDataSource
  17.     driver-class-name: org.gjt.mm.mysql.Driver
  18.     url: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8
  19.     username: root
  20.     password: 123456

dao层

  1. @Mapper  //spring
  2. @Repository  //json
  3. public interface DeptDao {
  6.     public boolean addDept(Dept dept);
  8.     public Dept queryById(Long id);
  10.     public List<Dept> queryAll();
  12. }

mapper

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3.         PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="com.xiao.springcloud.dao.DeptDao">
  7.     <insert id="addDept" parameterType="Dept">
  8.         insert into dept (dname, db_source)
  9.         values (#{
  10.     dname},DATABASE())
  11.     </insert>
  13.     <select id="queryById" resultType="Dept" parameterType="Long">
  14.         select * from dept where deptno = #{
  15.     deptno};
  16.     </select>
  18.     <select id="queryAll" resultType="Dept">
  19.         select * from dept;
  20.     </select>
  22. </mapper>

service

  1. public interface DeptService {
  4.     public boolean addDept(Dept dept);
  6.     public Dept queryById(Long id);
  8.     public List<Dept> queryAll();
  10. }

serviceimpl

  1. @Service
  2. public class DeptServiceImpl implements DeptService {
  5.     @Autowired
  6.     private DeptDao deptDao;
  8.     @Override
  9.     public boolean addDept(Dept dept) {
  11.         return deptDao.addDept(dept);
  12.     }
  14.     @Override
  15.     public Dept queryById(Long id) {
  17.         return deptDao.queryById(id);
  18.     }
  20.     @Override
  21.     public List<Dept> queryAll() {
  23.         return deptDao.queryAll();
  24.     }
  25. }

controller

  1. package com.xiao.springcloud.controller;
  3. import com.xiao.springcloud.pojo.Dept;
  4. import com.xiao.springcloud.service.DeptService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.PostMapping;
  9. import org.springframework.web.bind.annotation.RestController;
  11. import java.util.List;
  13. /**
  14.  * @outhor liu
  15.  * @dare 2020/4/2 16:22
  16.  */
  17. //提供Restful服务！
  18. @RestController
  19. public class DeptController {
  22.     @Autowired
  23.     private DeptService deptService;
  24.     //获取一些配置的信息，得到具体的微服务！
  25.     //@Autowired
  26.     // private DiscoveryClient client;
  28.     @PostMapping("/dept/add")
  29.     public boolean addDept(Dept dept) {
  31.         return deptService.addDept(dept);
  32.     }
  34.     @GetMapping("/dept/get/{id}")
  35.     public Dept get(@PathVariable("id") Long id) {
  37.         Dept dept = deptService.queryById(id);
  38. //        if (dept == null) {
  40. //            throw new RuntimeException("Fail");
  41. //        }
  42.         return dept;
  43.     }
  45.     @GetMapping("/dept/list")
  46.     public List<Dept> queryAll() {
  48.         return deptService.queryAll();
  49.     }
  50. }

主启动

  1. */
  2. @SpringBootApplication
  3. public class DeptProvider {
  5.     public static void main(String[] args) {
  7.         SpringApplication.run(DeptProvider.class,args);
  8.     }
  9. }

服务消费者

依赖

  1. <!--服务消费者-->
  2.     <!--只需要导入web和实体类+热部署-->
  3.     <dependencies>
  4.         <dependency>
  5.             <groupId>com.xiao</groupId>
  6.             <artifactId>springcloud-api</artifactId>
  7.             <version>1.0-SNAPSHOT</version>
  8.         </dependency>
  9.         <dependency>
  10.             <groupId>org.springframework.boot</groupId>
  11.             <artifactId>spring-boot-starter-web</artifactId>
  12.         </dependency>
  13.         <!--热部署工具-->
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-devtools</artifactId>
  17.             <version>2.1.8.RELEASE</version>
  18.         </dependency>
  19.     </dependencies>

application配置

  1. server:
  2.   port: 80
  3. #80端口可以直接访问不用输入8080了

config配置

  1. //RestTemplate不能直接添加bean注解，所以我们需要手动创建
  2. @Configuration
  3. public class ConfigBean {
  4.      //@Configuration相当于spring中的applicationConfig.xml
  6.     //这里是手动把RestTemplate注入到bean中
  7.     @Bean
  8.     public RestTemplate getRestTemplate(){
  10.         return new RestTemplate();
  11.     }
  12. }

controller

  1. @RestController
  2. public class DeptConsumerController {
  6.     //理解，消费者不应该有service层
  7.     //resttemplate  我们可以直接调用，因为已经在config里面注册到bean中了
  8.     //resttemplate的参数只有三个（url,实体：map,Class<T> responseType:响应类型）
  9.     @Autowired
  10.     private RestTemplate restTemplate;
  12.     //把服务提供者的地址作为常量，定义出来
  13.     private static final String REST_URL_PREFIX = "http://localhost:8001";
  15.     //调用服务提供者里面的内容
  16.     @RequestMapping("/consumer/dept/add")
  17.     public boolean add(Dept dept){
  19.         return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept,Boolean.class);
  20.     }
  22.     @RequestMapping("/consumer/dept/get/{id}")
  23.     public Dept get(@PathVariable("id") Long deptno){
  25.         return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+deptno,Dept.class);
  26.     }
  28.     @RequestMapping("/consumer/dept/list")
  29.     public List<Dept> list(){
  31.         return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list",List.class);
  32.     }
  33. }

主启动

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

发表评论

表情：
评论列表 （有 0 条评论，83人围观）

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

相关阅读