当前位置：移动技术网 > IT编程>开发语言>Java > SpringCloud+Eureka+Feign+Ribbon的简化搭建流程和CRUD练习

SpringCloud+Eureka+Feign+Ribbon的简化搭建流程和CRUD练习

2019年12月21日 | 移动技术网IT编程 | 我要评论

作者:程序猿的月光宝盒

环境:win10--idea2019--jdk8

1.搭建eureka服务模块

1.1 新建eureka服务模块(sping initializr)

取名为eureka-server,并添加如下dependencies:

1.2 配置`application.properties`

#配置端口
server.port=8761

#spring 的应用名=一般是模块名
spring.application.name=eureka-server

#当前模块是否注册为eureka的客户端
# --->因为当前应用应该是服务端
# --->所以选false
eureka.client.register-with-eureka=false

#既然不是客户端,那么是否
# 在server center 注册?
# --->不要,因为当前应用本来就是server
eureka.client.fetch-registry=false
#------------------------------------------
#eureka.客户端.服务url.默认区域,${server.port} 动态获取port-->即第1行的8761
eureka.client.serviceurl.defaultzone=http://localhost:${server.port}/eureka

1.3 在启动类前加上注解`@enableeurekaserver`

//启用eureka服务器
@enableeurekaserver
@springbootapplication
public class eurekaserverapplication {
    public static void main(string[] args) {
        springapplication.run(eurekaserverapplication.class, args);
    }
}

1.4 开启启动器,并访问,测试是否正确配置eureka的服务端

本机访问http://www.lhsxpumps.com/_localhost:8761/

有画面则说明启动成功

2.编写公共的实体类模块

2.1 新建普通maven-quickstart工程

2.2 在pom文件中添加lombok坐标(用于简化实体类)

  <dependencies>
    <dependency>
      <groupid>junit</groupid>
      <artifactid>junit</artifactid>
      <version>4.12</version>
    </dependency>
    <dependency>
      <groupid>org.projectlombok</groupid>
      <artifactid>lombok</artifactid>
      <version>1.18.10</version>
    </dependency>
  </dependencies>

2.3 编写实体类

@data
@allargsconstructor
@noargsconstructor
public class dept implements serializable {
    private integer deptno;
    private string dname;
    private string loc;
}

@data
@allargsconstructor
@noargsconstructor
public class emp implements serializable {
    private integer empno;
    private string ename;
    private string job;
    private integer mgr;
    private java.sql.date hiredate;
    private double sal;
    private double comm;
    private integer deptno;
}

2.4 然后用maven打包工具先`clean`然后再`install`打包到本地仓库

2.4.1 检查本地仓库是否有对应的jar

如上图,有就行了...

3. 编写provider-one模块

3.1 新建`spring initializr` 工程

3.2 在pom中加入公共实体类的依赖,并修改数据库驱动版本号为5.1.38

<dependency>
            <groupid>cn.kgc</groupid>
            <artifactid>employee-common</artifactid>
            <version>1.0-snapshot</version>
</dependency>

<dependency>
            <groupid>mysql</groupid>
            <artifactid>mysql-connector-java</artifactid>
            <!--修改版本号-->
            <version>5.1.38</version>
</dependency>

3.3 编写实体类的mapper

deptmapper.java

@mapper
public interface deptmapper {
    @select("select * from dept")
    list<map<string,object>>selalldeptdata();
}

3.4 编写service

deptservice.java

public interface deptservice {
    list<map<string,object>> optiondata();
}

3.5 编写serviceimpl

deptserviceimpl.java

@service
public class deptserviceimpl implements deptservice {
    @autowired
    private deptmapper deptmapper;
    @override
    public list<map<string, object>> optiondata() {
        return deptmapper.selalldeptdata();
    }
}

3.6 编写中心控制类

centercontroller.java

@restcontroller
public class centercontroller {
    @autowired
    private deptservice deptservice;
    @getmapping("/optiondata.do")
    public list<map<string, object>> optiondata() {
        return deptservice.optiondata();
    }
}

3.7 编写配置文件

application.properties

#服务端口号
server.port=8762
#应用名
spring.application.name=provider
#eureka客户端服务url默认区域
eureka.client.serviceurl.defaultzone=http://localhost:8761/eureka/

#数据源驱动类名
spring.datasource.driver-class-name=com.mysql.jdbc.driver
#数据源url,www.52cc.monster为我的服务器,但是可能在国外,time out 恶心死我了  还是用回localhost或者国内阿里的
spring.datasource.url=jdbc:mysql://www.52cc.monster:3306/kh75
#数据源用户名
spring.datasource.username=root
#数据源密码
spring.datasource.password=****

#后期会写mapper.xml,这里先注释
#mybatis.mapper-locations=classpath:mapper/*.xml

#给实体类起别名,同样这里先注释
#mybatis.type-aliases-package=cn.kgc.vo

3.8 在启动类上加注解

provideroneapplication.java

//启用eureka客户端
@enableeurekaclient
//mapper扫描,对应的mapper包
@mapperscan("cn.kgc.mapper")
@springbootapplication
public class provideroneapplication {
    public static void main(string[] args) {
        springapplication.run(provideroneapplication.class, args);
    }
}

4.编写consumer模块

4.1 新建`spring initializr` 工程

4.2 在pom中加入公共实体类的依赖

<dependency>
            <groupid>cn.kgc</groupid>
            <artifactid>employee-common</artifactid>
            <version>1.0-snapshot</version>
</dependency>

4.3 编写feign类

centerfeign.java

/**
 * 是consumer调用provider（需要指定provider的名字）
 * 请求的清单列表：规定调用地址、参数、返回值
 */
@feignclient(name = "provider")
public interface centerfeign {
    @getmapping("/optiondata.do")
    public list<map<string, object>> optiondata();
}

4.4 编写中心控制类`centercontroller`

centercontroller.java

@restcontroller
public class centercontroller  {
    @autowired
    private centerfeign centerfeign;
    @getmapping("/optiondata-consumer.do")
    public list<map<string, object>> optiondata() {
        return centerfeign.optiondata();
    }
}

4.5 编写配置文件

application.properties

#端口号
server.port=8764
#应用名
spring.application.name=consumer
#eureka客户端服务url默认区域
eureka.client.serviceurl.defaultzone=http://localhost:8761/eureka/
#下线名称.ribbon.nf加载平衡规则类名,这里先注释
#provider.ribbon.nfloadbalancerruleclassname=com.netflix.loadbalancer.randomrule

4.6在启动类上添加注解

consumerapplication.java

//开启feign客户端
@enablefeignclients
//开启eureka客户端
@enableeurekaclient
@springbootapplication
public class consumerapplication {
    public static void main(string[] args) {
        springapplication.run(consumerapplication.class, args);
    }
}

5.用postman测试接口

已查出数据....

6. 重复以上3.3-4中步骤,建立新的mapper

6.1 更新provider-one模块

empmapper.java

public interface empmapper {
    @select(
            "<script>" +
            "    select d.dname,d.loc,e.* from emp e,dept d where e.deptno=d.deptno" +
            "    <if test='deptno!=-1 and deptno!=null'>" +
            "        and e.deptno=#{deptno}" +
            "    </if>" +
            "    <if test='empno!=null'>" +
            "        and e.empno=#{empno}" +
            "    </if>" +
            "</script>" )
    list<map<string,object>> selempdata(emp emp);

    @insert("insert into emp(empno,ename,sal,job,deptno) values(#{empno},#{ename},#{sal},#{job},#{deptno})")
    integer insert(emp emp);

    @update("update emp set ename=#{ename},sal=#{sal},job=#{job},deptno=#{deptno} where empno=#{empno}")
    integer updemp(emp emp);

    @delete("delete from emp where empno=#{empno}")
    integer delempbyprimarykey(integer empno);
}

empservice.java

public interface empservice {

    list<map<string,object>> showempdata(emp emp);

    integer add(emp emp);

    integer edit(emp emp);

    integer del(integer empno);
}

empserviceimpl.java

@service
@transactional
public class empserviceimpl implements empservice {
    @autowired
    private empmapper empmapper;
    @override
    public list<map<string, object>> showempdata(emp emp) {
        return empmapper.selempdata(emp);
    }

    @override
    public integer add(emp emp) {
        return empmapper.insert(emp);
    }

    @override
    public integer edit(emp emp) {
        return empmapper.updemp(emp);
    }

    @override
    public integer del(integer empno) {
        return empmapper.delempbyprimarykey(empno);
    }
}

更新中心控制类

centercontroller.java

@restcontroller
public class centercontroller {
    @autowired
    private deptservice deptservice;
    @autowired
    private empservice empservice;
    @getmapping("/optiondata.do")
    public list<map<string, object>> optiondata() {
        return deptservice.optiondata();
    }

    @postmapping("/showempdata.do")
    //feign：不支持对象传参,所以要用@requestbody
    public list<map<string, object>> showempdata(@requestbody emp emp) {
        return empservice.showempdata(emp);
    }

    @postmapping("/add.do")
    public integer add(@requestbody emp emp) {
        return empservice.add(emp);
    }

    @postmapping("/edit.do")
    public integer edit(@requestbody  emp emp) {
        return empservice.edit(emp);
    }

    @getmapping("/del.do")
    public integer del(@requestparam("empno") integer empno) {
        return empservice.del(empno);
    }
}

6.2 更新consumer模块

更新feign类

@feignclient(name = "provider")
public interface centerfeign {
    @getmapping("/optiondata.do")
    public list<map<string, object>> optiondata();

    @postmapping("/showempdata.do")
    //feign：不支持对象传参,所以要用@requestbody
    public list<map<string, object>> showempdata(@requestbody emp emp);

    @postmapping("/add.do")
    public integer add(@requestbody emp emp);

    @postmapping("/edit.do")
    public integer edit(@requestbody  emp emp);

    @getmapping("/del.do")
    public integer del(@requestparam("empno") integer empno);
}

更新consumer的controller

@restcontroller
public class centercontroller{
    @autowired
    private centerfeign centerfeign;

    @getmapping("/optiondata-consumer.do")
    public list<map<string, object>> optiondata() {
        return centerfeign.optiondata();
    }

    @postmapping("/showempdata-consumer.do")
    public list<map<string, object>> showempdata(@requestbody emp emp) {
        return centerfeign.showempdata(emp);
    }

    @postmapping("/add-consumer.do")
    public integer add(@requestbody emp emp) {
        return centerfeign.add(emp);
    }

    @postmapping("/edit-consumer.do")
    public integer edit(@requestbody emp emp) {
        return centerfeign.edit(emp);
    }

    @getmapping("/del-consumer.do")
    public integer del(@requestparam("empno") integer empno) {
        return centerfeign.del(empno);
    }
}

再用postman测试,都没有问题

注意,这里测试的都是http://localhost:8764/xxx-consumer.do的url

xxx为consumer的controller中的mapping映射

7. 新建provider-two模块

步骤和3一样,就名改成two

7.1 在pom中加入公共实体类的依赖,并修改数据库驱动版本号为5.1.38

<dependency>
            <groupid>cn.kgc</groupid>
            <artifactid>employee-common</artifactid>
            <version>1.0-snapshot</version>
</dependency>

<dependency>
            <groupid>mysql</groupid>
            <artifactid>mysql-connector-java</artifactid>
            <!--修改版本号-->
            <version>5.1.38</version>
</dependency>

7.2 把one的cn.kgc下的包都扒拉过来

7.3 再更新启动类,加注解,也直接扒拉

//启用eureka客户端
@enableeurekaclient
//mapper扫描,对应的mapper包
@mapperscan("cn.kgc.mapper")
@springbootapplication
public class providertwoapplication {

    public static void main(string[] args) {
        springapplication.run(providertwoapplication.class, args);
    }

}

7.4 再更新配置文件`application.properties`,也直接扒拉,把端口号改一改

#服务端口号
server.port=8763
#应用名
spring.application.name=provider
#eureka客户端服务url默认区域
eureka.client.serviceurl.defaultzone=http://localhost:8761/eureka/

#数据源驱动类名
spring.datasource.driver-class-name=com.mysql.jdbc.driver
#数据源url
spring.datasource.url=jdbc:mysql:///kh75
#数据源用户名
spring.datasource.username=root
#数据源密码
spring.datasource.password=admin



#后期会写mapper.xml,这里先注释
#mybatis.mapper-locations=classpath:mapper/*.xml

#给实体类起别名,同样这里先注释
#mybatis.type-aliases-package=cn.kgc.vo

8. 更新consumer中的配置文件,把原来注释的下线放出来

application.properties

#端口号
server.port=8764
#应用名
spring.application.name=consumer
#eureka客户端服务url默认区域
eureka.client.serviceurl.defaultzone=http://localhost:8761/eureka/
#下线名称.ribbon.nf加载平衡规则类名,默认是轮询,现在改为随机,randomrule:随机选择一个服务节点
provider.ribbon.nfloadbalancerruleclassname=com.netflix.loadbalancer.randomrule

9. 为了看清楚是不是随机,在这加控制台打印

9.1 在provider-one 的控制类的 `/showempdata.do`中加打印

   @postmapping("/showempdata.do")
    //feign：不支持对象传参,所以要用@requestbody
    public list<map<string, object>> showempdata(@requestbody emp emp) {
        system.out.println("provider-one>>>>"+emp);
        return empservice.showempdata(emp);
    }

9.2 在provider-two 的控制类的 `/showempdata.do`中加打印

    @postmapping("/showempdata.do")
    //feign：不支持对象传参,所以要用@requestbody
    public list<map<string, object>> showempdata(@requestbody emp emp) {
        system.out.println("provide-two>>>>"+emp);
        return empservice.showempdata(emp);
    }

9.3 这里只用postman测 `/showempdata-consumer.do` 测10次看后台打印是不是随机的

9.3.1 结果

one:有6个

two:有4个

所以负载均衡策略是随机的

那现在把上面的注释

#下线名称.ribbon.nf加载平衡规则类名,这里先注释provider.ribbon.nfloadbalancerruleclassname=com.netflix.loadbalancer.randomrule

还是测10次,结果:

one:5次

two:5次

为了防止巧合,再测10次一共20次,结果:

one:10次

two:10次

所以,以下这句话起作用了

#下线名称.ribbon.nf加载平衡规则类名,这里先注释provider.ribbon.nfloadbalancerruleclassname=com.netflix.loadbalancer.randomrule

10.整体结构图

10.1`employee-common`

10.2`eureka-server`

10.3`employee-common`

10.4`provider-one`

10.5`provider-two`

10.6`consumer`

11.拓展,ribbon提供的7种负载均衡策略:

ribbon提供了多钟负载均衡策略:
1 weightedresponsetimerule:根据响应时间分配一个weight(权重,大小的概念),响应时间和weight成反比
2.roundrobinrule:轮询选择服务节点(默认的负载均衡策略)
3.randomrule:随机选择一个服务节点
4.zoneavoidancerule:综合考虑服务节点所在区域的性能和服务节点的可用性来选择服务节点
5.retryrule:重试机制.在一个配置时间段内,当选择服节点不成功时会一直尝试重新选择
6.bestavailablerule:选择一个并发请求最小的服务器节点.
7.availabilityfilteringrule:过滤掉因为一直连接失败而被标记为circuit tripped的服务节点和那些高并发的服务节点(active connections超过配置值)

您可能感兴趣的文章:

如对本文有疑问，点击进行留言回复！！

ScrollView和RecyclerView的滑动事件处理

View的事件传递不做重复性的说明，关键函数在viewGroup的dispatchTouchEvent中，可参考... [阅读全文]
android获取局域网设备的ip和对应的mac地址

近期公司有项目要获取到同一局域网下的设备ip和mac，问了度娘2天，网上大师们的项目不是跑不起来就是没有反应总结... [阅读全文]
解决App启动之前的白屏问题

本来想在项目中加一个启动时的闪屏效果，结果发现闪屏效果有了，但是却使在App初始化的白屏之后才有闪屏，用户体验很... [阅读全文]
配置JAVA环境+安装Android Studio全过程+踩坑记录

两年前课上学过安卓开发，现在打算重新拾起，但是电脑已经重装了一遍，所以AS重新下+Java环境重新配。1.配置J... [阅读全文]
Android - TextView - 动态显示数据

效果动态显示，随机生成99以内的数字Java更改UI界面 Handler线程生成随机数 Random.nextI... [阅读全文]
Android P Camera2当SD卡被拔出来自动切换到内部存储

需求： Camera2 当拔出SD卡后，设备一直提示“无法访问SD卡”，体验不好修改方法：依据现有流程中的当内部... [阅读全文]
android 多个edittext 判空监听让Button动态是否可点击

工具类package com.sinochem.www.car.owner.utils;/** * Create... [阅读全文]
Dimen 自动生成

package com;import android.util.Log;import java.io.Buffe... [阅读全文]
AndroidStudio编译so库

步骤1.新建工程com.example.jnitest2.新建JniTest.java (MainActivit... [阅读全文]
Android开源项目滚轮选择器WheelPicker的基本用法总结

1. 添加依赖在Project的build.gradle中，添加maven { url ‘https:jitpa... [阅读全文]

网友评论


验证码：

SpringCloud+Eureka+Feign+Ribbon的简化搭建流程和CRUD练习

2019年12月21日 | 移动技术网IT编程 | 我要评论

环境:win10--idea2019--jdk8

1.搭建eureka服务模块

1.1 新建eureka服务模块(sping initializr)

1.2 配置application.properties

1.3 在启动类前加上注解@enableeurekaserver

1.4 开启启动器,并访问,测试是否正确配置eureka的服务端

2.编写公共的实体类模块

2.1 新建普通maven-quickstart工程

2.2 在pom文件中添加lombok坐标(用于简化实体类)

2.3 编写实体类

2.4 然后用maven打包工具先clean然后再install打包到本地仓库

2.4.1 检查本地仓库是否有对应的jar

3. 编写provider-one模块

3.1 新建spring initializr 工程

3.2 在pom中加入公共实体类的依赖,并修改数据库驱动版本号为5.1.38

3.3 编写 实体类的mapper

3.4 编写service

3.5 编写serviceimpl

3.6 编写中心控制类

3.7 编写配置文件

3.8 在启动类上加注解

4.编写consumer模块

4.1 新建spring initializr 工程

4.2 在pom中加入公共实体类的依赖

4.3 编写feign类

4.4 编写中心控制类centercontroller

4.5 编写配置文件

4.6在启动类上添加注解

5.用postman测试接口

6. 重复以上3.3-4中步骤,建立新的mapper

6.1 更新provider-one模块

6.2 更新consumer模块

7. 新建provider-two模块

7.1 在pom中加入公共实体类的依赖,并修改数据库驱动版本号为5.1.38

7.2 把one的cn.kgc下的包都扒拉过来

7.3 再更新启动类,加注解,也直接扒拉

7.4 再更新配置文件application.properties,也直接扒拉,把端口号改一改

8. 更新consumer中的配置文件,把原来注释的下线放出来

9. 为了看清楚是不是随机,在这加控制台打印

9.1 在provider-one 的控制类的 /showempdata.do中加打印

9.2 在provider-two 的控制类的 /showempdata.do中加打印

9.3 这里只用postman测 /showempdata-consumer.do 测10次看后台打印是不是随机的

9.3.1 结果

10.整体结构图

10.1employee-common

10.2eureka-server

10.3employee-common

10.4provider-one

10.5provider-two

10.6consumer

11.拓展,ribbon提供的7种负载均衡策略:

您可能感兴趣的文章:

相关文章:

网友评论

1.2 配置`application.properties`

1.3 在启动类前加上注解`@enableeurekaserver`

2.4 然后用maven打包工具先`clean`然后再`install`打包到本地仓库

3.1 新建`spring initializr` 工程

3.3 编写实体类的mapper

4.1 新建`spring initializr` 工程

4.4 编写中心控制类`centercontroller`

7.4 再更新配置文件`application.properties`,也直接扒拉,把端口号改一改

9.1 在provider-one 的控制类的 `/showempdata.do`中加打印

9.2 在provider-two 的控制类的 `/showempdata.do`中加打印

9.3 这里只用postman测 `/showempdata-consumer.do` 测10次看后台打印是不是随机的

10.1`employee-common`

10.2`eureka-server`

10.3`employee-common`

10.4`provider-one`

10.5`provider-two`

10.6`consumer`