aillamsun / Genesis

Genesis. Is a Spring Cloud Project

技术架构

genesis 是一个基于Spring cloud(Camden.SR1) Spring Boot(1.4.1.RELEASE) Mybatis(3.3.0) 通用Mapper 通用分页Pagehelper完成的一个基础组件架构， 使用Spring Cloud Eureka、Feign、Zuul、Spring config、Zipkin、Sleuth、Hystrix Turbine、Hystrix Dashboard...

MAVEN模块说明

1. 基础组件说明

2. Spring Cloud(genesis-microservices)组件说明

3. Spring(genessis-spring)扩展组件说明

4. Examples(genesis-examples) 提供真是服务使用

5. 分布式事务Example(更新中....)(genesis-transaction-examples) 提供LCN分布式事务功能实现 |

架构图(目前待完善)

后续会更新架构图出去，暂时先这样看着... 焦灼中..........

服务中心HA说明

• 1,（C:\Windows\System32\drivers\etc\hosts文件）

127.0.0.1 discovery1
127.0.0.1 discovery2
127.0.0.1 discovery3

• 2,每个配置里面都有一个application.properties，本机为了方便在idea工具启动 所以使用了两个项目

• 3,以后线上可以使用一个工程即可 如下：

application-chengdu-1.properties

spring.application.name=eureka-server-clustered
server.port=8761
eureka.instance.hostname=discovery1
eureka.client.serviceUrl.defaultZone=http://${security.user.name}:${security.user.password}@discovery2:8762/eureka/,http://${security.user.name}:${security.user.password}@discovery3:8763/eureka/

application-chengdu-2.properties

spring.application.name=eureka-server-clustered
server.port=8762
eureka.instance.hostname=discovery2
eureka.client.serviceUrl.defaultZone=http://${security.user.name}:${security.user.password}@discovery1:8761/eureka/,http://${security.user.name}:${security.user.password}@discovery3:8763/eureka/

application-chengdu-3.properties

spring.application.name=eureka-server-clustered
server.port=8763
eureka.instance.hostname=discovery3
eureka.client.serviceUrl.defaultZone=http://${security.user.name}:${security.user.password}@discovery1:8761/eureka/,http://${security.user.name}:${security.user.password}@discovery2:8762/eureka/

命令启动格式1：

java -jar discovery-1.0.0.jar  --spring.profiles.active=chengdu-1
java -jar discovery-1.0.0.jar --spring.profiles.active=chengdu-2
java -jar discovery-1.0.0.jar --spring.profiles.active=chengdu-3

命令修改为：

java -jar discovery-1.0.0.jar

效果图:

访问discovery1

监控视图测试

使用说明：

Spring boot Admin 监控

• 数据库脚本 genesis-common-config resources/db/下面spring-cloud-test.sql
• 首先启动：genesis-microservices-monitor 端口 8060
• 启动 genesis-provider-goods 端口 8081

访问 http://localhost:8060 admin UI 访问 http://localhost:8081/goods

效果图

Hystrix-dashboard 监控

• 数据库脚本 genesis-common-config resources/db/下面spring-cloud-test.sql
• 首先启动：genesis-microservices-discovery
• 启动genesis-microservices-hystrix-dashboard 端口 8051
• 启动genesis-provider-by-feign 端口8080

访问 http://localhost:8051 在地址栏输入:http://localhost:8080/hystrix.stream

效果图

Hystrix Turbine 监控

• 数据库脚本 genesis-common-config resources/db/下面spring-cloud-test.sql
• 首先启动：genesis-microservices-discovery
• genesis-provider-goods,genesis-provider-order
• genesis-provider-by-feign,genesis-provider-by-ribbon
• genesis-microservices-hystrix-dashboard 端口 8051
• 启动genesis-microservices-hystrix-turbine 端口 8052
• 分别启动 genesis-provider-goods 端口8081 、genesis-provider-order 端口 8083

访问http://localhost:8051 输入框输入：http://localhost:8052/turbine.stream 分别访问 feign ribbon

效果图1

确认：

效果图2

服务跟踪监控Zipkin、Sleuth 测试

使用说明：

项目启动

• 启动 Zipkin Server 服务 genesis-microservices-zipkin 端口 8091
• 启动 Zipkin Server 服务demo genesis-microservices-sleuth 端口 8092
• 启动测试 Zipkin、Sleuth 服务提供者 genesis-sleuth-zipkin-demo 端口 8093
• 直接调用 8092 Controller接口即可

跟踪列表效果图

跟踪详细信息效果图

Zuul 和 Feign 测试

使用说明：

1,项目启动：

• 数据库脚本 genesis-common-config resources/db/下面spring-cloud-test.sql
• 首先启动：genesis-microservices-discovery
• 测试Fegin可以启动genesis-provider-by-feign。前提启动genesis-provider-good、genesis-provider-order
• 测试Zuul可以启动genesis-provider-by-zuul 。前提启动genesis-provider-good、genesis-provider-order
• genesis-provider-by-feign提供swgger UI 通过API文档Try 就可以了

API 文档访问测试

使用说明：

1,项目启动：

• 启动API genesis-provider-by-feign访问http://localhost:8080/swagger-ui.html

分布式事务基于Spring Cloud + LCN

LCN

首先感谢LCN提供

LCN

使用说明：

1,项目启动：

• 首先启动 tx-manager tx-manager

效果图

• 启动 tx-user-ms 和 tx-user-money-ms

测试

• 访问 http://localhost:8011/user/save

Controller

@RequestMapping(value = "/save",method = RequestMethod.POST)
    public int save() {
        return userService.save();
    }

Service

    @TxTransaction
    @Transactional
    public int save() {

        User user = new User();
        user.setUserName("Test Tx");
        user.setPassword("11111");
        int rs1 = userMapper.insert(user);
        /**
         * 保存 余额 分布式服务
         */
        int rs2 = userMoneyClient.save();

        /**
         * 抛出异常
         */
        int v = 100 / 0;
        return rs1 + rs2;
    }

UserMoneyClient

@FeignClient(name = "genesis-tx-user-money-ms", configuration = TransactionRestTemplateConfiguration.class)
public interface UserMoneyClient {

    @RequestMapping(value = "/user-money/save",method = RequestMethod.POST)
    int save();
}