正文

<Spring Cloud>入门二 Eureka Client

IP云
IP云V管理员/3 阅读
11/30
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

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);

    }

}

页面调用：

<Spring Cloud>入门二 Eureka Client的更多相关文章
  1. Spring Cloud 入门 之 Eureka 篇（一）

    原文地址:Spring Cloud 入门 之 Eureka 篇(一) 博客地址:http://www.extlight.com 一.前言 Spring Cloud 是一系列框架的有序集合.它利用 Sp ...

  2. Spring Cloud 入门教程 - Eureka服务注册与发现

    简介 在微服务中,服务注册与发现对管理各个微服务子系统起着关键作用.随着系统水平扩展的越来越多,系统拆分为微服务的数量也会相应增加,那么管理和获取这些微服务的URL就会变得十分棘手,如果我们每新加一个 ...

  3. <Spring Cloud>入门一 Eureka Server

    1.搭建父工程 主要是添加版本依赖,此处版本是: spring-boot  : 2.0.8.RELEASE spring-cloud : Finchley.SR2 <?xml version=& ...

  4. Spring Cloud 入门 之 Ribbon 篇（二）

    原文地址:Spring Cloud 入门 之 Ribbon 篇(二) 博客地址:http://www.extlight.com 一.前言 上一篇<Spring Cloud 入门 之 Eureka ...

  5. Spring Cloud 入门 之 Config 篇（六）

    原文地址:Spring Cloud 入门 之 Config 篇(六) 博客地址:http://www.extlight.com 一.前言 随着业务的扩展,为了方便开发和维护项目,我们通常会将大项目拆分 ...

  6. spring cloud 入门系列二：使用Eureka 进行服务治理

    服务治理可以说是微服务架构中最为核心和基础的模块,它主要用来实现各个微服务实例的自动化注册和发现. Spring Cloud Eureka是Spring Cloud Netflix 微服务套件的一部分 ...

  7. Spring Cloud 入门教程(二)： 配置管理

    使用Config Server,您可以在所有环境中管理应用程序的外部属性.客户端和服务器上的概念映射与Spring Environment和PropertySource抽象相同,因此它们与Spring ...

  8. Spring Cloud（二）：服务注册与发现 Eureka【Finchley 版】

    Spring Cloud(二):服务注册与发现 Eureka[Finchley 版]  发表于 2018-04-15 |  更新于 2018-05-07 |  上一篇主要介绍了相关理论,这一篇开始我们 ...

  9. Spring Cloud（二）：Eureka 服务注册中心

    前言 服务治理 随着业务的发展,微服务应用也随之增加,这些服务的管理和治理会越来越难,并且集群规模.服务位置.服务命名都会发生变化,手动维护的方式极易发生错误或是命名冲突等问题.而服务治理正是为了解决 ...

随机推荐
  1. Apache Thrift 在Windows下的安装与开发

    Windows下安装Thrift框架的教程很多.本文的不同之处在于,不借助Cygwin或者MinGW,只用VS2010,和Thrift官网下载的源文件,安装Thrift并使用. 先从官网 下载这两个文 ...

  2. 天空盒的制作方法 Max来生成天空盒的六张图片

    在虚拟现实技术中,需要产品展示,场景漫游等,只要想在内部有一个虚拟的3D天空,那么都要用到天空球:天空球目前基本做法主要有两种:分别是正方形的和球形的. 目前360度全景图主要用的是球形的,针对目前已 ...

  3. python __builtins__ map类 （44）

    44.'map',  根据提供的函数对指定序列做映射. class map(object) | map(func, *iterables) --> map object | | Make an ...

  4. bzoj 4551: [Tjoi2016&Heoi2016]树【并查集】

    看起来像是并查集,但是是拆集合,考虑时间倒流,先把标记都打上,然后把并查集做出来 每次到一个修改点就把这个点的计数s[u]--,当这个s为0时就把这个点和他的父亲合并(因为可能有多次标记) #incl ...

  5. 公司内网，无法使用yum在线下载，肿么办？

    1 配置上网代理 编辑/etc/yum.conf,增加如下属性: proxy=你的代理地址 proxy_user=你的用户名 proxy_password=你的密码 2 配置国内163 yum源 备份 ...

  6. P2024 [NOI2001]食物链

    第一种说法是"1 X Y",表示 X 和 Y 是同类. 第二种说法是"2 X Y",表示 X 吃 Y . 根据这句话 可以看出来这是一个种类并查集 种类并查集 ...

  7. bryce1010专题训练——划分树

    1.求区间第K大 HDU2665 Kth number /*划分树 查询区间第K大 */ #include<iostream> #include<stdio.h> #inclu ...

  8. Counting The Important Pairs CodeChef - TAPAIR

    https://vjudge.net/problem/CodeChef-TAPAIR 合法的删除方法: 第一种:桥边与其余任意边(1)桥*(桥-1)/2(两条桥边)(2)桥*(m-桥)(桥边+其他边) ...

  9. 1-3方法的重载（overload）

    之前已经写了一个方法sumInt用来计算两个int类型数字的和,如果要是想计算两个float类型数字的和呢?ok,那就再来写一个sumFloat方法,除此之外,还有long类型,double类型,如果 ...

  10. 1-2JDK的安装和环境变量设置

    JDK的下载和安装 可以去oracle官网里面下载JDK:http://www.oracle.com 英文不好的同学可以通过下面这个百度网盘的链接进行下载:http://pan.baidu.com/s ...

相关阅读

目录[+]