美文网首页
5、data-provide-service-config-cl

5、data-provide-service-config-cl

作者: knock | 来源:发表于2020-07-12 23:19 被阅读0次

    模块结构

    image.png

    .................................................................................................

    模块代码

    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>spring-cloud</artifactId>
        <groupId>com.yyd.cloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>data-provide-client-8005</artifactId>

    <dependencies>

        <!--springcloud-config依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>

        <!-- SpringCloud Eureka 注册中心依赖  客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <!-- actutor完善监控信息(erekua的status指向网页的信息依赖)-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>


        <!-- spirngboot测试依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-test</artifactId>
        </dependency>

        <!-- springboot的web依赖-->
        <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>

        <!-- web服务 替代tomcat -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-undertow</artifactId>
        </dependency>

        <!-- Hystrix依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

    </dependencies>


    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
                <configuration>
                    <!--指定打包方式 loader.path使用-->
                    <layout>ZIP</layout>
                    <!--去除在生产环境中不变的依赖，只包含业务代码-->
                    <includes>
                        <include>
                            <groupId>com.yyd.cloud</groupId>
                            <artifactId>*</artifactId>
                        </include>
                    </includes>
                </configuration>
            </plugin>

            <!--拷贝依赖jar到lib-->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-dependency-plugin</artifactId>
                <executions>
                    <execution>
                        <id>copy-dependencies</id>
                        <phase>package</phase>
                        <goals>
                            <goal>copy-dependencies</goal>
                        </goals>
                        <configuration>
                            <outputDirectory>${project.build.directory}/lib</outputDirectory>
                            <overWriteReleases>false</overWriteReleases>
                            <overWriteSnapshots>false</overWriteSnapshots>
                            <overWriteIfNewer>true</overWriteIfNewer>
                        </configuration>
                    </execution>
                </executions>
            </plugin>


            <!--拷贝资源文件 copy-resources, config固定 -->
            <plugin>
                <artifactId>maven-resources-plugin</artifactId>
                <executions>
                    <execution>
                        <id>copy-resources</id>
                        <phase>package</phase>
                        <goals>
                            <goal>copy-resources</goal>
                        </goals>
                        <configuration>
                            <resources>
                                <resource>
                                    <directory>src/main/resources</directory>
                                </resource>
                            </resources>
                            <outputDirectory>${project.build.directory}/config</outputDirectory>
                        </configuration>
                    </execution>
                </executions>
            </plugin>

            <!--拷贝target下的jar到targets-->
            <plugin>
                <artifactId>maven-antrun-plugin</artifactId>
                <executions>
                    <execution>
                        <id>copy-lib-target</id>
                        <phase>package</phase>
                        <configuration>
                            <tasks>
                                <copy todir="../targets">
                                    <fileset dir="target">
                                        <include name="*.jar"/>
                                    </fileset>
                                </copy>
                            </tasks>
                        </configuration>
                        <goals>
                            <goal>run</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>

        </plugins>

        <!-- 排除资源文件 -->
        <resources>
            <resource>
                <filtering>true</filtering>
                <directory>src/main/resources</directory>
                <excludes>
                    <exclude>**/*.yml</exclude>
                </excludes>
            </resource>
        </resources>
    </build>
</project>

    .................................................................................................

    DockerFile

    # 基础 JRE 镜像
FROM registry.cn-hangzhou.aliyuncs.com/ydyan/cloud:v0.1
MAINTAINER 13270809619@163.com

WORKDIR /root/data-provide-client-8005

ENV APP_HOME=/root/data-provide-client-8005
ENV MAIN_JAR=data-provide-client-8005-1.0-SNAPSHOT.jar
ENV JVMOPTIONS="-Xms128M -Xmx1G"
#声明容器端口
ENV EXPOSE_PORT=8005
ENV CONFIG_LABEL=master
ENV ENV_TYPE=dev

# 修改时区，使得容器时间为北京时间
RUN echo "Asia/Shanghai" > /etc/timezone

# 将所需项目文件复制进入容器中
ADD target/$MAIN_JAR $APP_HOME/
ADD target/lib/ $APP_HOME/lib/
ADD target/config/ $APP_HOME/config/

# 运行项目

CMD java $JVMOPTIONS -jar  -Dloader.path=$APP_HOME,$APP_HOME/lib -Dfile.encoding=UTF-8 $APP_HOME/$MAIN_JAR

EXPOSE $EXPOSE_PORT


#---docker服务---
#docker pull centos:7
#docker tag 37bb9c63c8b2 registry-vpc.cn-hangzhou.aliyuncs.com/acs/agent:0.7-dfb6816   镜像改名
#docker build -t yd-cloud:v0.1 .
#docker run -d -p 9001:9001 -p 9002:9002 yd-cloud:v0.1
#docker run -d -p 10001:8888(本机:容器) -name springboot(容器名称) -v /usr/local/bigdata/dockerlogs/:/usr/local/logs/ yd-cloud:v0.1
#docker ps -a (全部容器) |docker ps (运行中容器)
#docker exec -it 8b /bin/bash  （进入容器）
#docker logs -f -t --tail 500 容器名称/容器id 查看docker日志
#docker images 查看镜像
#docker kill 容器名称/容器id
#docker rm 容器名称/容器id
#docker rmi 镜像id
#docker image rm -f 镜像id

    .................................................................................................
    resources
    application-prod.yml

    prod.name:  prodname

    .................................................................................................
    bootstrap.yml

    server:
  port: 8005

# http://localhost:9001/personnel/refresh
# webhooks 提交推送
management:
  endpoint:
    health:
      show-details: always
  endpoints:
    web:
      exposure:
        include: "*"
      base-path: /


#spring配置
spring:
  application:
    name: data-provide
  cloud:
    config:
      label: master
      profile: dev
      name: service-config
      discovery:
        enabled: true
        service-id:  service-config
  profiles:
    active: prod
#Eureka的配置，服务注册到哪里
eureka:
  client:
    service-url:
      #做集群需要关联集群的eureka服务器的地址,其实端口号都应该是7001，
      #关联的只是服务器地址，这里因为只有一台电脑，就用了端口号代替
      #集群模式  defaultZone: http://127.0.0.1:7001/eureka/,http://127.0.0.1:7002/eureka/,http://127.0.0.1:7003/eureka/
      #单机模式  defaultZone: http://127.0.0.1:7001/eureka/
      defaultZone: http://127.0.0.1:7001/eureka/
    # 此应用为注册中心，false：不向注册中心注册自己
    register-with-eureka: true
    # 注册中心职责是维护服务实例，false：不检索服务
    fetch-registry: true
  instance:
    instance-id: data-provide-client  #实例化id 集群id

#info配置
info:
  app.name: data-provide
  company.name: com.yyd

    .................................................................................................

    logback.xml

    <configuration scanPeriod="10 seconds" debug="true">
    <!-- 彩色日志依赖的渲染类 -->
    <conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter"/>
    <conversionRule conversionWord="wex"
                    converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter"/>
    <conversionRule conversionWord="wEx"
                    converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter"/>

    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <encoder charset="UTF-8">
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} [%file : %line] - %msg%n</pattern>
        </encoder>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <!-- rollover daily 配置日志所生成的目录以及生成文件名的规则 -->
            <fileNamePattern>logs/data-provide-8005-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
            <timeBasedFileNamingAndTriggeringPolicy
                    class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                <!-- 单个日志文件最大100MB -->
                <maxFileSize>100MB</maxFileSize>
            </timeBasedFileNamingAndTriggeringPolicy>
            <!-- 日志文件保存15天 -->
            <maxHistory>15</maxHistory>
        </rollingPolicy>
        <prudent>false</prudent>
    </appender>

    <!-- 彩色日志格式 -->
    <property name="CONSOLE_LOG_PATTERN"
              value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
    <!-- Console 输出设置 -->
    <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
            <charset>utf8</charset>
        </encoder>
    </appender>

    <!--<springProfile name="dev,test,prod">-->
    <!--<root level="INFO">-->
    <!--<appender-ref ref="CONSOLE"/>-->
    <!--<appender-ref ref="FILE"/>-->
    <!--</root>-->
    <!--&lt;!&ndash;<logger name="com.yyd.mapper" level="DEBUG"/>&ndash;&gt;-->
    <!--</springProfile>-->

    <root level="INFO">
        <appender-ref ref="CONSOLE"/>
        <appender-ref ref="FILE"/>
    </root>
</configuration>

    java
    ConfigBean.java

    package com.yyd.dataprovide.config;

import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/***
 * @ClassName: ConfigBean
 * @Description: TODO
 * @author: yanyd
 * @Date: 7:54 2020/5/31
 * @version : V1.0
 */
@Slf4j
@Configuration
public class ConfigBean {

    /**
     * 增加一个servlet,将8001服务注册到dashboard流监控
     * @return
     */
    @Bean
    public ServletRegistrationBean servletRegistrationBean() {
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());
        registrationBean.addUrlMappings("/actuator/hystrix.stream");
        registrationBean.setName("HystrixMetricsStreamServlet");
        return registrationBean;
    }



}

    RequestController.java

    package com.yyd.dataprovide.controller;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.yyd.dataprovide.service.RequestService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.*;

import java.util.HashMap;
import java.util.Map;

/***
 * @ClassName: RequestController
 * @Description: TODO
 * @author: yanyd
 * @Date: 1:51 2020/5/31
 * @version : V1.0
 */
@RefreshScope
@Slf4j
@RequiredArgsConstructor
@RestController
@RequestMapping("/request")
public class RequestController {

    private final RequestService requestService;
    @Value("${web-site.url}")
    private  String url;
    @Value("${prod.name}")
    private  String prodName;

    @GetMapping(value = "/config")
    public String config() {
        return  url+"    "+prodName;
    }

    @HystrixCommand(fallbackMethod = "requestPostHystrix")//使用监控必须添加 HystrixCommand
    @PostMapping(value = "/data", produces = {"application/json;charset=utf-8"})
    public Map requestPost(@RequestBody Map map) {
        int i = 1 / 0;
        return requestService.requestPost(map);
    }

    @HystrixCommand(fallbackMethod = "requestGetHystrix")//使用监控必须添加 HystrixCommand
    @GetMapping(value = "/data/{param}")
    public Map requestGet(@PathVariable("param") String param) {
        int i = 1 / 0;
        return requestService.requestGet(param);
    }

    @HystrixCommand(fallbackMethod = "requestGetHystrix")//使用监控必须添加 HystrixCommand
    @GetMapping(value = "/data/v1/{param}")
    public Map requestGet1(@PathVariable("param") String param) {
        int i = 1 / 0;
        return requestService.requestGet(param);
    }

    //服务熔断(对get方法做熔断处理)
    public Map requestGetHystrix(@PathVariable("param") String param, Throwable throwable) {
        throwable.printStackTrace();
        HashMap<String, Object> map = new HashMap<>();
        map.put("param", param);
        map.put("hystrix", "get request hystrix");
        return map;
    }

    //服务熔断(对post方法做熔断处理)
    public Map requestPostHystrix(@RequestBody Map map, Throwable throwable) {
        throwable.printStackTrace();
        map.put("hystrix", "pos request hystrix");
        return map;
    }
}

    RequestServiceImpl.java

    package com.yyd.dataprovide.service.impl;

import com.yyd.dataprovide.service.RequestService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;

/***
 * @ClassName: RequestServiceImpl
 * @Description: TODO
 * @author: yanyd
 * @Date: 1:55 2020/5/31
 * @version : V1.0
 */
@Service
@Slf4j
public class RequestServiceImpl implements RequestService {

    @Override
    public Map requestPost(Map map) {
        map.put("msg", "post request success (*╹▽╹*)！");
        map.put("req","8004");
        return map;
    }

    @Override
    public Map requestGet(String param) {
        HashMap<String, Object> map = new HashMap<String, Object>();
        map.put("msg", "get request success (*╹▽╹*)！");
        map.put("param",param);
        map.put("req","8004");
        return map;
    }
}

    RequestService.java

    package com.yyd.dataprovide.service;

import java.util.Map;

/***
 * @ClassName: RequestService
 * @Description: TODO
 * @author: yanyd
 * @Date: 1:55 2020/5/31
 * @version : V1.0
 */
public interface RequestService {

    /**
     * post
     * @param map
     * @return
     */
    Map requestPost(Map map);

    /**
     * post
     * @param
     * @return
     */
    Map requestGet(String param);
}

    DataProvideApplication.java

    package com.yyd.dataprovide;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/***
 * @ClassName: DataProvideApplication
 * @Description: TODO
 * @author: yanyd
 * @Date: 0:48 2020/5/31
 * @version : V1.0
 */

@EnableCircuitBreaker   //添加对熔断的支持
@EnableEurekaClient     //在服务启动之后自动注册到eureka中
@EnableDiscoveryClient  //服务发现
@SpringBootApplication
public class DataProvideApplication {
    public static void main(String[] args) {
        SpringApplication.run(DataProvideApplication.class, args);
    }
}

    相关文章

      网友评论

          本文标题：5、data-provide-service-config-cl

          本文链接：https://www.haomeiwen.com/subject/vqjncktx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|5、data-provide-service-config-cl|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！