1.搭建一个通用工程

1.1 pom 文件

<?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>spring-cloud-learning</artifactId>

        <groupId>org.maple</groupId>

        <version>0.0.1-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>ms-common-api</artifactId>

    <dependencies>

        <dependency>

            <groupId>org.projectlombok</groupId>

            <artifactId>lombok</artifactId>

        </dependency>

    </dependencies>

</project>

1.2 数据库表

Create Table

CREATE TABLE `dept` (

  `deptno` bigint(20) NOT NULL AUTO_INCREMENT,

  `dname` varchar(60) DEFAULT NULL,

  `db_source` varchar(60) DEFAULT NULL,

  PRIMARY KEY (`deptno`)

) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8

1.3 实体类

　　此处使用了 lombok,省去了getter/setter 等编写

package org.maple.entity;

import lombok.AllArgsConstructor;

import lombok.Data;

import lombok.NoArgsConstructor;

import lombok.experimental.Accessors;

import java.io.Serializable;

/**

 * @author mapleins

 * @Date 2019-01-08 21:35

 * @Desc 部门实体类

 **/

@AllArgsConstructor

@NoArgsConstructor

@Data

@Accessors(chain = true) //可以链式编程

public class Dept implements Serializable {

    private Long deptNo;

    private String dName;

    private String db_source;//来自哪个数据库

//    public static void main(String[] args) {

//        Dept dept = new Dept();

//        dept.setDeptNo(11l).setDName("技术部").setDb_source("dept"); //链式编程

//        System.out.println(dept);

//    }

}

2. 创建一个Department 的提供方，并且注册服务到 eureka server 上

　　实现了查找一个部门，查找所有部门，添加一个部门的接口

　　项目结构：

　　　　

2.1 pom 文件

<?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>spring-cloud-learning</artifactId>

        <groupId>org.maple</groupId>

        <version>0.0.1-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>ms-provider-dept-8001</artifactId>

    <dependencies>

        <dependency>

            <groupId>org.maple</groupId>

            <artifactId>ms-common-api</artifactId>

            <version>0.0.1-SNAPSHOT</version>

        </dependency>

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

        </dependency>

        <dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

        </dependency>

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>druid</artifactId>

        </dependency>

        <dependency>

            <groupId>ch.qos.logback</groupId>

            <artifactId>logback-core</artifactId>

        </dependency>

        <dependency>

            <groupId>org.mybatis.spring.boot</groupId>

            <artifactId>mybatis-spring-boot-starter</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-test</artifactId>

        </dependency>

    </dependencies>

</project>

2.2 编写 application.yml 文件

　　defaultZone 标识 注册到哪个 Eureka Server 上

server:

  port: 8001

eureka:

  client:

    service-url:

      defaultZone: http://eureka-server01:8761/eureka/,http://eureka-server02:8762/eureka/

mybatis:

  config-location: classpath:mybatis/mybatis.cfg.xml

  type-aliases-package: org.maple.entity

  mapper-locations: classpath:mybatis/mapper/**/*.xml

spring:

  application:

    name: ms-provider-dept

  datasource:

    type: com.alibaba.druid.pool.DruidDataSource

    driver-class-name: com.mysql.jdbc.Driver

    url: jdbc:mysql://localhost:3306/cloudDB01

    username: root

    password: root

    dbcp2:

      min-idle: 5

      initial-size: 5

      max-total: 5

      max-wait-millis: 200

2.3 编写 mybatis 配置文件，由于和spring整合后会将配置内容转移到 Spring 配置文件中，此处只是写出来

<?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>

    <settings>

        <setting name="cacheEnabled" value="true"/>

    </settings>

</configuration>

2.4 编写Dao层以及映射文件mapper

package org.maple.dao;

import org.apache.ibatis.annotations.Mapper;

import org.maple.entity.Dept;

import java.util.List;

/**

 * @author mapleins

 * @Date 2019-01-08 22:31

 * @Desc

 **/

@Mapper

public interface DeptDao {

    boolean addDept(Dept dept);

    Dept findById(Long deptNo);

    List<Dept> findAll();

}
<?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">

<!--namespace 名称空间

         作用：用于绑定接口，即使用namespace将映射文件和接口绑定，就不需要写实现类了

-->

<mapper namespace="org.maple.dao.DeptDao">

    <select id="findById" resultType="org.maple.entity.Dept">

        SELECT deptno deptNo,dname dName,db_source

        FROM dept

        WHERE deptno = #{deptNo}

    </select>

    <select id="findAll" resultType="org.maple.entity.Dept">

        SELECT deptno deptNo,dname dName,db_source

        FROM dept

    </select>

    <insert id="addDept">

        insert into dept(dname,db_source) VALUES (${dName},DATABASE());

    </insert>

</mapper>

2.5 编写Service层

package org.maple.service;

import org.maple.entity.Dept;

import java.util.List;

/**

 * @author mapleins

 * @Date 2019-01-08 22:41

 * @Desc

 **/

public interface DeptService {

    boolean add(Dept dept);

    Dept find(Long deptNo);

    List<Dept> list();

}
package org.maple.service.impl;

import org.maple.dao.DeptDao;

import org.maple.entity.Dept;

import org.maple.service.DeptService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import java.util.List;

/**

 * @author mapleins

 * @Date 2019-01-08 22:42

 * @Desc

 **/

@Service

public class DeptServiceImpl implements DeptService {

    @Autowired

    private DeptDao deptDao;

    @Override

    public boolean add(Dept dept) {

        return deptDao.addDept(dept);

    }

    @Override

    public Dept find(Long deptNo) {

        return deptDao.findById(deptNo);

    }

    @Override

    public List<Dept> list() {

        return deptDao.findAll();

    }

}

2.6 编写controller 层

package org.maple.controller;

import org.maple.entity.Dept;

import org.maple.service.DeptService;

import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.*;

import java.util.List;

/**

 * @author mapleins

 * @Date 2019-01-08 22:45

 * @Desc

 **/

@RestController

public class DeptController {

    @Autowired

    private DeptService service;

    @PostMapping("/dept/add")

    public boolean add(@RequestBody Dept dept){

        return service.add(dept);

    }

    @GetMapping("/dept/get/{id}")

    public Dept get(@PathVariable("id") Long id){

        return service.find(id);

    }

    @GetMapping("/dept/list")

    public List<Dept> list(){

        return service.list();

    }

}

2.7 编写启动类

　　此处添加 @EnableEurekaClient ,说明这是一个Eureka的客户端，并将这个工程注册到 Eureka注册中心上

package org.maple;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**

 * @author mapleins

 * @Date 2019-01-12 17:13

 * @Desc

 **/

@SpringBootApplication

@EnableEurekaClient

public class App_Provider_Dept_8001 {

    public static void main(String[] args) {

        SpringApplication.run(App_Provider_Dept_8001.class,args);

    }

}

2.8 启动工程

　　我们可以看到 eureka 注册中心出现了该服务的名字，说明注册成功

　　

　　服务的自己调自己也是成功的

　　

3. 服务的发现

3.1 在 Controller 层 注入 @DiscoveryClient ,就可以显示服务信息

    /**

     * 获取服务信息

     */

    @Autowired

    private DiscoveryClient client;

    @GetMapping("/dept/discovery")

    public Object discovery(){

        List<String> services = client.getServices();

        System.out.println("所有服务信息："+services);

        List<ServiceInstance> instances = client.getInstances("ms-provider-dept");

        for (ServiceInstance instance : instances) {

            System.out.println("===========serviceId:"+instance.getServiceId());

            System.out.println("===========host:"+instance.getHost());

            System.out.println("===========port:"+instance.getPort());

            System.out.println("===========uri:"+instance.getUri());

        }

        return this.client;

    }

　　控制台输出

　　　　

4. 配置 eureka info 中的信息

4.1 父工程pom配置

　　添加maven插件，将所有以  $[ ] 过滤

    <build>

        <!--设置info下的信息-->

        <resources>

            <resource>

                <directory>src\main\resources</directory>

                <filtering>true</filtering>

            </resource>

        </resources>

        <plugins>

            <plugin>

                <groupId>org.apache.maven.plugins</groupId>

                <artifactId>maven-resources-plugin</artifactId>

                <configuration>

                    <delimiters>

                        <delimiter>$[*]</delimiter>

                    </delimiters>

                </configuration>

            </plugin>

        </plugins>

    </build>

4.2 在当前服务添加依赖

        <!--管理监控-->

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-actuator</artifactId>

        </dependency>

4.3 修改application.yml

info:

  app.name: spring-cloud-learning

  company.name: mapleins

  build.artifactId: $[project.artifactId]

  build.version: $[project.version]

4.4 点进eureka界面的下列位置后

　　出现如下：

　　　　

5. 搭建一个消费者 来消费Department 的服务

　　工程结构：

　　　　

5.1 pom文件

<?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>spring-cloud-learning</artifactId>

        <groupId>org.maple</groupId>

        <version>0.0.1-SNAPSHOT</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>ms-consumer-dept-80</artifactId>

    <dependencies>

        <dependency>

            <groupId>org.maple</groupId>

            <artifactId>ms-common-api</artifactId>

            <version>0.0.1-SNAPSHOT</version>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

    </dependencies>

</project>

5.2 编写yml文件

server:

  port: 80

5.3 配置config

　　@Configuration 代替了以前的 application.xml

　　注入一个 RestTemplate 来实现restful 调用

package org.maple.cfgbean;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.web.client.RestTemplate;

/**

 * @author mapleins

 * @Date 2019-01-09 20:07

 * @Desc spring application.xml -> @Configuration

 **/

@Configuration

public class ConfigBean {

    @Bean

    public RestTemplate getRestTemplate(){

        return new RestTemplate();

    }

}

5.4 编写controller层

package org.maple.controller;

import org.maple.entity.Dept;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.client.RestTemplate;

import java.util.List;

/**

 * @author mapleins

 * @Date 2019-01-09 20:10

 * @Desc

 **/

@RestController

public class DeptController_Consumer {

    private static final String REST_URL_PREFIX= "http://localhost:8001";

    /**

     * 类似httpclient (url,requestMap,ResponseBean.class)

     * 请求地址，请求参数，http响应转换的对象类型

     */

    @Autowired

    private RestTemplate restTemplate;

    @RequestMapping("/consumer/dept/add")

    public boolean add(Dept dept){

        return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept,Boolean.class);

    }

    @RequestMapping("/consumer/dept/get/{id}")

    public Dept get(@PathVariable("id") Long id){

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id,Dept.class);

    }

    @RequestMapping("/consumer/dept/list")

    @SuppressWarnings("unchecked")

    public List<Dept> list(){

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list",List.class);

    }

    @RequestMapping("/consumer/dept/discovery")

    public Object discovery(){

        return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery",Object.class);

    }

}

5.5 编写启动类 并启动

package org.maple;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

/**

 * @author mapleins

 * @Date 2019-01-09 20:26

 * @Desc

 **/

@SpringBootApplication

public class App_Consumer_Dept_80 {

    public static void main(String[] args) {

        SpringApplication.run(App_Consumer_Dept_80.class, args);

    }

}

　　页面调用：

　　　　

最新文章

  1. json死循环问题
  2. partnerv2.1
  3. UNIX常用命令
  4. java获取文件名的三种方法
  5. jQuery中的事件机制深入浅出
  6. Moqui学习之代码分析mantle priceServices.xml
  7. 【C语言学习】-01 C基础
  8. iOS-申请开发证书流程
  9. 详细讲解JAVA中的IO流
  10. C# 或 JQuery导出Excel
  11. sql删除wordpress没用的postmeta记录
  12. cluster模块实现多进程-让我的代理服务速度飞起来了
  13. 查看MySQL数据库表的命令介绍
  14. Delphi Excel
  15. final、finally、finalize
  16. [USACO08JAN]haybale猜测Haybale Guessing
  17. springboot mybatis 多数据源配置
  18. mongodb &quot;Element &#39;{0}&#39; does not match any field or property of class&quot; 异常的解决方法
  19. java基础（4）继承和多态
  20. Java：类与对象概念

热门文章

  1. hdoj1007【几何】【未完待续】
  2. mongodb 安装问题
  3. 黑客攻防技术宝典web实战篇：攻击应用程序架构习题
  4. 第一篇 .NET高级技术之索引器
  5. Hibernate中的Query对象查询所有记录
  6. multiprocessing多进程模块
  7. 转 做了两款数据库监控工具（mysql and nosql），打算在近期开源
  8. 日历 php
  9. C# 对象复制
  10. 协程和I/O模型