原生cloud+netflix与alibaba cloud架构默

作者: 机灵鬼鬼 | 来源:发表于2020-12-04 20:33 被阅读0次

pc电脑：4核 16G
cloud版本：Hoxton.SR9
boot版本：2.3.5.RELEASE
压测场景：间隔1ms，10000个请求
neftlix全套：hystrix、open feign、eureka、undertow
压测结果：内存持续上升gc间隔时长很长，cup利用率不高，线程数较高，跑完耗时36分钟

image.png

单调控制台

image.png

阿里全套：sentinel、open feign、nacos、undertow
压测结果：内存变化均匀gc间隔一分钟一次，cup利用率较好，线程数较低，跑完耗时5分钟。

nacos+feign+undertow（10000个请求间隔1ms访问）.jpg

丰富控制台

更关键的是阿里的sentinel的多维度的监控控制台

image.png

因此我选择使用阿里的全套
下面开撸代码

image.png

父类takeout3-cloud的pom.xml

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <packaging>pom</packaging>
    <modules>
        <module>takeout-api</module>
        <module>takeout-product-provider-8080</module>
        <module>takeout-consumer-feign-80</module>
    </modules>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.lppz.cloud</groupId>
    <artifactId>takeout3-cloud</artifactId>
    <version>1.0.1-SNAPSHOT</version>
    <name>takeout3-cloud</name>
    <description>takeout3 project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR9</spring-cloud.version>
        <com-alibaba-cloud.version>2.2.2.RELEASE</com-alibaba-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>${com-alibaba-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
        <repository>
            <id>alimaven</id>
            <name>aliyun maven</name>
            <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
        </repository>
    </repositories>

</project>

takout-api

1、pom.xml

<?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>takeout3-cloud</artifactId>
        <groupId>com.lppz.cloud</groupId>
        <version>1.0.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.lppz.cloud</groupId>
    <artifactId>takout-api</artifactId>
    <packaging>jar</packaging>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--undertow替换boot默认的tomcat内嵌容器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-tomcat</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-undertow</artifactId>
        </dependency>
    </dependencies>
    <build>
        <finalName>takeout3-api</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <skip>true</skip>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

2、关键代码

package com.lppz.cloud.api.service;

import com.lppz.cloud.api.entities.DataChannel;
import com.lppz.cloud.api.entities.RespData;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

/**
 * 使用Feign的注解+接口的形式来进行服务调用
 */
//feign与注册入Eureka的微服务建立连接, 每一个地址有异常都会调用fallback中的同名方法做兜底

@FeignClient(value="takeout3-provider-product",fallbackFactory = ApiServiceFallBackFactory.class)
public interface DataChannelClientService {
    //这里映射真正的业务DataChannelController入口地址：“/channel/{id}”
    @RequestMapping(method = RequestMethod.GET, value = "/channel/{id}")
    public RespData getDataChannelById(@PathVariable("id")int id);

    @RequestMapping(method = RequestMethod.POST, value = "/channel")
    public RespData insertDataChannel(DataChannel dataChannel) ;

    @RequestMapping(method = RequestMethod.POST, value = "/channel/update")
    public RespData updateDataChannel(DataChannel dataChannel) ;

    @RequestMapping(method = RequestMethod.POST, value = "/channel/delete")
    public RespData deleteDataChannel(DataChannel dataChannel) ;
}

takeout-consumer-feign-80

1.pom.xml配置

<?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>takeout3-cloud</artifactId>
        <groupId>com.lppz.cloud</groupId>
        <version>1.0.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>takeout-consumer-feign-80</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.lppz.cloud</groupId>
            <artifactId>takout-api</artifactId>
            <version>1.0.1-SNAPSHOT</version>
        </dependency>

        <!-- alibaba nacos sentinel -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <!--openfeign客户端负载均衡引入-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
        </dependency>
    </dependencies>

</project>

2、application.yml配置

server:
  port: 80

spring:
  cloud:
    nacos:
      discovery:
        server-addr: 10.101.x.x:8848  #nacos注册中心地址
  application:
    name: comsumer_feign
feign:
  client:
    config:
      default:
        connectTimeout: 5000 #连接超时时间
        readTimeout: 5000    #请求与响应的时间间隔阈值
  okhttp:
    enabled: true  #开启 okhttp client代替feign的默认client
  sentinel:
    enabled: true #开启Fegin对sentinel的支持

3、关键代码

package com.lppz.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableDiscoveryClient  //告诉feign客户端，具体的微服务
@EnableFeignClients(basePackages = "com.lppz.cloud") //open Feign的客户端负载均衡
public class Consumer_App_Feign_80 {

    public static void main(String[] args) {
        SpringApplication.run(Consumer_App_Feign_80.class, args);
    }

}

package com.lppz.cloud.controller;

import com.lppz.cloud.api.entities.DataChannel;
import com.lppz.cloud.api.entities.RespData;
import com.lppz.cloud.api.service.DataChannelClientService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@RestController
public class DataChannelController_Feign {

    @Autowired
    private DataChannelClientService service;

    @RequestMapping(value = "/consumer/channel/{id}",method = RequestMethod.GET)
    public RespData getDataChannelById(@PathVariable("id") int id) {
        //去找微服务的入口地址，就是第二步里的@FeignClient(value="TAKEOUT3-PROVIDER-PRODUCT")的“/channel/{id}”
        return service.getDataChannelById(id);
    }
    @RequestMapping(value = "/consumer/channel",method = RequestMethod.POST)
    public RespData insertDataChannel(DataChannel dataChannel) throws Exception {
        return service.insertDataChannel(dataChannel);
    }
    @RequestMapping(value = "/consumer/channel/update",method = RequestMethod.POST)
    public RespData updateDataChannel(DataChannel dataChannel) throws Exception {

        return service.updateDataChannel(dataChannel);

    }
    @RequestMapping(value = "/consumer/channel/delete",method = RequestMethod.POST)
    public RespData deleteDataChannel(DataChannel dataChannel) throws Exception {

        return service.deleteDataChannel(dataChannel);

    }
}

takeout-product-provider-8080

1、pom.xml配置

<?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>takeout3-cloud</artifactId>
        <groupId>com.lppz.cloud</groupId>
        <version>1.0.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>takeout-product-provider-8080</artifactId>


    <dependencies>
        <dependency>
            <groupId>com.lppz.cloud</groupId>
            <artifactId>takout-api</artifactId>
            <version>1.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.2.3</version>
        </dependency>
        <!--将provider注册进入nacos的配置-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!--服务容错-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.2</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--配置文件书写提示-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

2、application.yml配置

server:
  port: 8080
  undertow:
    # 以下的配置会影响buffer,这些buffer会用于服务器连接的IO操作,有点类似netty的池化内存管理
    # 每块buffer的空间大小,越小的空间被利用越充分
    buffer-size: 1024
    # 是否分配的直接内存
    direct-buffers: true
    threads:
      io: 4  # 设置IO线程数, 它主要执行非阻塞的任务,它们会负责多个连接, 默认设置每个CPU核心一个线程
      worker: 20 # 阻塞任务线程池, 当执行类似servlet请求阻塞操作, undertow会从这个线程池中取得线程,它的值设置取决于系统的负载
spring:
  application:
    name: takeout3-provider-product  #微服务对外暴露的名字
  datasource:
    url: jdbc:mysql://192.168.x.x:3306/omso2o
    username: xx1
    password: xx2
    driver-class-name: com.mysql.cj.jdbc.Driver
    type: com.alibaba.druid.pool.DruidDataSource
    initialSize: 5
    maxActive: 100
    minIdle: 5
    maxWati: 60000
    minEvictableIdleTimeMillis: 300000
    maxPoolPreparedStatementPerConnectionSize: 100
    poolPreparedStatements: true
    validationQuery: select 1 for dual
    testOnBorrow: false
    testOnReturn: false
    testWhileIdle: true
    filters: stat,wall
    # sql合并，慢查询定义为5s
    connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
  cloud:
    nacos:
      discovery:
        server-addr: 10.101.x.x:8848  #nacos注册中心地址
    sentinel:
      transport:
        dashboard: 192.168.x.x:8080   #配置Sentinel DashBoard地址
        port: 8722                  #微服务向Sentinel控制台开发的端口
        clientIp: 10.28.x.x      #解析:暴露的微服务所在机器ip，该配置项多用于多网卡环境，如果多网卡环境必须制定clientIp，否则就会Sentinel控制台有可能找不到

mybatis:
  mapper-locations: classpath:mybatis/mapper/*.xml
  config-location: classpath:mybatis/mybatis-config.xml
info:
  app.name: lppz takeout version 3.0
  company.name: lppz.com
  build.artifactId: takeout3-cloud
  build.version: 1.0.1-SNAPSHOT

management:
  endpoints:
    web:
      exposure:
        include: "*"

3、关键代码

package com.lppz.cloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient  //该微服务的所有对外暴露的服务统一注册在nacos中
public class ProductApplication_8080 {
    public static void main(String[] args) {

        SpringApplication.run(ProductApplication_8080.class, args);
    }

}

package com.lppz.cloud.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.lppz.cloud.api.entities.RespData;
import com.lppz.cloud.service.DataChannelService;

import com.lppz.cloud.api.entities.DataChannel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 此入口就是我们当前微服务的统一入口
 * consumer-feign需要的商品数据，都要从该入口
 * 统一获取。
 */
@RestController
public class DataChannelController {
    private static final Logger logger= LoggerFactory.getLogger(DataChannelController.class);
    @Autowired
    DataChannelService dataChannelService;//此处只是服务的调用样例，未来这里会集中很多关于商品数据的service
    // 原函数
    @SentinelResource(value = "getDataChannelById")
    @GetMapping("/channel/{id}")
    public RespData getDataChannelById(@PathVariable("id") int id) {
        DataChannel dc= dataChannelService.getDataChannelById(id);
        RespData res=RespData.getDefaultSuccRespData();
        if(null!=dc){
            res.setData(dc);
        }
        return res;
    }
    @SentinelResource(value = "insertDataChannel")
    @PostMapping("/channel")
    public RespData insertDataChannel(DataChannel dataChannel){

        DataChannel newdataChannel = null;
        RespData res=RespData.getDefaultSuccRespData();
        try {
            newdataChannel = dataChannelService.insertDataChannel(dataChannel);
            res.setData(newdataChannel);
        } catch (Exception e) {
            e.printStackTrace();
//            throw  new MyException("2000",e.getMessage());
            res.setMsg(e.getMessage());
            res.setCode(RespData.ERROR_CODE);
        }
        return res;
    }
    @SentinelResource(value = "deleteDataChannel")
    @PostMapping("/channel/delete")
    public RespData deleteDataChannel(DataChannel dataChannel) {
        RespData res=RespData.getDefaultSuccRespData();
        int cnt=0;
        try {
            cnt= dataChannelService.deleteDataChannel(dataChannel);
        } catch (Exception e) {
            e.printStackTrace();
            res.setMsg(e.getMessage());
            res.setCode(RespData.ERROR_CODE);
        }
        return res;
    }
    @SentinelResource(value = "updateDataChannel")
    @PostMapping("/channel/update")
    public RespData updateDataChannel(DataChannel dataChannel) {
        RespData res=RespData.getDefaultSuccRespData();
        int cnt=0;
        try {
            cnt= dataChannelService.updateDataChannel(dataChannel);
        } catch (Exception e) {
            e.printStackTrace();
            res.setMsg(e.getMessage());
            res.setCode(RespData.ERROR_CODE);
        }
        return res;
    }

}

原生cloud+netflix与alibaba cloud架构默

单调控制台

丰富控制台

父类takeout3-cloud的pom.xml

takout-api

1、pom.xml

2、关键代码

takeout-consumer-feign-80

1.pom.xml配置

2、application.yml配置

3、关键代码

takeout-product-provider-8080

1、pom.xml配置

2、application.yml配置

3、关键代码

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读