<parent>
    <groupId>com.nova</groupId>
    <artifactId>nova-nove</artifactId>
    <version>1.5.0-RELEASE</version>
</parent>


<dependencies>
    <dependency>
        <groupId>com.nova</groupId>
        <artifactId>nova-core</artifactId>
    </dependency>
    
</dependencies>


<build>
	<!--此为项目名称-->
    <finalName>nova-consumer</finalName>
    <resources>
        <resource>
            <directory>${basedir}/src/main/resources</directory>
            <filtering>true</filtering>
            <includes>
                <include>**/*</include>
            </includes>
        </resource>
    </resources>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-surefire-plugin</artifactId>
            <configuration>
                <skip>true</skip>
                <testFailureIgnore>true</testFailureIgnore>
            </configuration>
        </plugin>
    </plugins>
</build>

<dependency>
 <groupId>com.nova</groupId>
 <artifactId>nova-kafka</artifactId>
</dependency>

package com.nova.service;

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * Created by luqiang on 2018/3/13.
 */
@Service("testKafkaService")
public class TestKafkaService {

    @Resource
    private KafkaTemplate<String,String> kafkaTemplate;


    public String sendKafkaMsg(){
        kafkaTemplate.send("testqiang","测试kafka基础组件"+System.currentTimeMillis());
        return "发送消息完成";
    }
}

package com.nova.service;

import org.springframework.kafka.annotation.KafkaHandler;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * Created by luqiang on 2018/3/13.
 * 因kafka为批量拉取同步消费，如果对性能有要求，请开启异步消费
 */
@Component
@KafkaListener(topics = "testMsg")
public class TestKafkaListener {

    @KafkaHandler
    public void getMessage(String data){
        System.out.println("接收到消息："+data);
    }
}

<dependency>
    <groupId>com.nova</groupId>
    <artifactId>nova-rabbitmq</artifactId>
</dependency>

package com.nova.service;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * Created by luqiang on 2018/3/13.
 */
@Service
public class TestRabbitmqService {

    @Resource
    private RabbitTemplate rabbitTemplate;

    public String sendMQ(){

        rabbitTemplate.convertAndSend("testMQ","测试MQ基础服务");
        return "发送MQ基础测试";
    }

}

package com.nova.service;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * Created by luqiang on 2018/3/13.
 * 因kafka为批量拉取同步消费，如果对性能有要求，请开启异步消费
 */
@Component
@RabbitListener(queues = "testMQ")
public class TestRabbitistener {

    @RabbitHandler
    public void getMessage(String data){
        System.out.println("接收到消息："+data);
    }
}

<dependency>
 <groupId>com.nova</groupId>
 <artifactId>nova-redis</artifactId>
</dependency>

package com.nova.service;

import com.nova.redis.utils.RedefineClusterUtils;
import org.springframework.stereotype.Service;

/**
 * Created by luqiang on 2018/3/13.
 */
@Service
public class TestRedisService {

	//此demo 使用封装RedefineClusterUtils ，也可以使用原生 private RedisTemplate<String, String> redisTemplate
    public String testRedis(){

        RedefineClusterUtils.saveString("testKey","对Redis数据进行测试");
        return RedefineClusterUtils.getString("testKey");
    }

}

<dependency>
 <groupId>com.nova</groupId>
 <artifactId>nova-jdbc</artifactId>
</dependency>

<dependency>
    <groupId>com.nova</groupId>
    <artifactId>nova-core</artifactId>
</dependency>

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

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

package com.nova.config;

import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;

/**
 * Created by luqiang on 2018/3/13.
 */
@Configuration
@EnableFeignClients(basePackages = "com.nova")
public class FeignConfig {


}

package com.nova.service;

import com.nova.dto.User;
import com.nova.fallback.RedefineServiceFallback;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.*;

/**
 * Created by luqiang on 2018/3/12.
 */
@FeignClient(value = "nova-provider")
@Component("feignConsumer")
public interface FeignConsumer {

    @RequestMapping("/provider/testP")
    public String testP();

    @RequestMapping(value = "/provider/testPR",method = RequestMethod.GET)
    public String testPR(@RequestParam("name") String name);

    @RequestMapping(value = "/provider/testPH",method = RequestMethod.GET)
    public String testPH(@RequestHeader("name") String name, @RequestHeader("age") String age);

    @RequestMapping(value = "/provider/testPB",method = RequestMethod.POST)
    public String testPB(@RequestBody User user);

    @RequestMapping(value = "/provider/testPRedis",method = RequestMethod.GET)
    public String testPRedis();

    @RequestMapping(value = "/provider/testPRabbit",method = RequestMethod.GET)
    public String testPRabbit();

}

<dependency>
    <groupId>com.nova</groupId>
    <artifactId>nova-core</artifactId>
</dependency>

spring.application.name=nova-demo
server.port=8081
log.home=/tmp/nova/logs/nova-demo

spring.cloud.config.profile=@nova.config.profile@
spring.cloud.config.label=@nova.config.label@
#注册自己并声明从哪个配置中心获取配置
spring.cloud.config.discovery.enabled=true
spring.cloud.config.discovery.service-id=REDEFINE-CONFIG
#eureka 注册地址
eureka.client.serviceUrl.defaultZone=@nova.eureka.serviceurl@
POM中的profile

<profiles>
    <profile>
        <id>local</id>
        <properties>
            <nova.eureka.serviceurl>http://localhost:8999/eureka/</nova.eureka.serviceurl>
            <nova.eureka.instance.hostname>localhost</nova.eureka.instance.hostname>
            <nova.nova.config.profile>dev</nova.nova.config.profile>
            <nova.nova.config.label>master</nova.nova.config.label>
        </properties>

    </profile>
    <profile>
        <id>dev</id>
        <properties>
            <nova.eureka.serviceurl>http://39.104.13.81:8090/eureka/</nova.eureka.serviceurl>
            <nova.eureka.instance.hostname>HB-DEV-APP-SERVER-01</nova.eureka.instance.hostname>
            <nova.nova.config.profile>dev</nova.nova.config.profile>
            <nova.nova.config.label>master</nova.nova.config.label>
        </properties>
        <activation>
            <activeByDefault>true</activeByDefault>
        </activation>
    </profile>
    <profile>
        <id>test</id>
        <properties>
            <nova.eureka.serviceurl>http://149.129.130.68:8090/eureka/</nova.eureka.serviceurl>
            <nova.eureka.instance.hostname>YD-TEST-APP-SERVER-01</nova.eureka.instance.hostname>
            <nova.nova.config.profile>dev</nova.nova.config.profile>
            <nova.nova.config.label>master</nova.nova.config.label>
        </properties>
    </profile>
</profiles>

<dependency>
 <groupId>com.nova</groupId>
 <artifactId>nova-core</artifactId>
</dependency>

package global.nova.welike.gateway.filter;

import com.alibaba.fastjson.JSON;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.netflix.zuul.util.ZuulRuntimeException;
import org.springframework.util.StreamUtils;

import javax.annotation.PostConstruct;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * AccessTokenFilter
 *
 * @author zhangjunjie | 2018-03-15
 */
public class TestPostFilter extends ZuulFilter {



    @Override
    public String filterType() {
        return "post";
    }

    @Override
    public int filterOrder() {
        return 999;
    }

    @Override
    public boolean shouldFilter() {
        RequestContext context = RequestContext.getCurrentContext();
        InputStream stream = context.getResponseDataStream();
        try {
            String body = StreamUtils.copyToString(stream, Charset.forName("UTF-8"));
            Map<String,Object> map = (Map<String, Object>) JSON.parse(body);
            context.setResponseBody(body);
            if(500 == (Integer) map.get("status")){
                return true;
            }
        } catch (IOException e) {

        }
        return false;
    }

    @Override
    public Object run() {
        RequestContext context = RequestContext.getCurrentContext();
		//TODO
        return null;
    }

    ZuulException findZuulException(Throwable throwable) {
        if (throwable.getCause() instanceof ZuulRuntimeException) {
            // this was a failure initiated by one of the local filters
            return (ZuulException) throwable.getCause().getCause();
        }

        if (throwable.getCause() instanceof ZuulException) {
            // wrapped zuul exception
            return (ZuulException) throwable.getCause();
        }

        if (throwable instanceof ZuulException) {
            // exception thrown by zuul lifecycle
            return (ZuulException) throwable;
        }

        // fallback, should never get here
        return new ZuulException(throwable, HttpServletResponse.SC_INTERNAL_SERVER_ERROR, null);
    }
}

package global.nova.welike.gateway.controller;

import org.springframework.boot.autoconfigure.web.ErrorController;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * Created by luqiang on 2018/4/3.
 */
@RestController
public class ErrorHandlerController implements ErrorController {

    /**
     * 出异常后进入该方法，交由下面的方法处理
     */
    @Override
    public String getErrorPath() {
        return "/error";
    }

    @RequestMapping("/error")
    public String error(HttpServletRequest request, HttpServletResponse response) {
        System.out.println(request.getAttribute("javax.servlet.error.exception"));
        System.out.println(request.getAttribute("javax.servlet.error.status_code"));
        System.out.println(request.getAttribute("javax.servlet.error.message"));
        return "出现异常";
    }
}

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

对于延迟队列有两种实现模式，一种就是rabbitmq_delayed_message_exchange 插件，另一种就是基于TTL+DLX 实现，因为rabbitmq_delayed_message_exchange是非官方的，缺乏大面积生产实践，并且出现了一些小问题，所有我们此次选用后一种模式。

<dependency>
 <groupId>com.nova</groupId>
 <artifactId>nova-rabbitmq</artifactId>
</dependency>

package global.nova.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Created by luqiang on 2018/5/11.
 */
@Configuration
public class RabbitConfig {


    /**
     * 实际消费队列
     * @return
     */
    @Bean
    public Queue queue() {
        return new Queue("consumer");
    }


    /**
     * DLX交换机
     * @return
     */
    @Bean
    DirectExchange delayExchange() {
        return new DirectExchange("delayExchange");
    }


    /**
     * 组建前置队列，注意consumer-pre 为前置队列名称，delayExchange 为交换机名称，
     * consumer 为实际队列名称，5000为超时时间
     * @return
     */
    @Bean
    Queue delayQueuePerQueueTTL() {
        return QueueBuilder.durable("consumer-pre")
                .withArgument("x-dead-letter-exchange", "delayExchange")
                .withArgument("x-dead-letter-routing-key", "consumer")
                .withArgument("x-message-ttl", 5000)
                .build();
    }


    /**
     * 绑定交换机和队列
     * @return
     */
    @Bean
    public Binding dlxBinding() {
        return BindingBuilder.bind(queue()).to(delayExchange()).with("consumer");
    }
}

@RabbitListener(queues = "consumer")
@Component
public class RabbitmqService {

    @RabbitHandler
    public void consumer(String data){
        System.out.println(data);
    }

}

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
 }
}

package global.nova.watchdog.po;

import java.io.Serializable;
import java.util.List;

/**
 * Created by luqiang on 2018/5/28.
 */
public class PageModel<T> implements Serializable {
    private static final long serialVersionUID = 8776788184840922942L;
    private List<T> datas;
    private int rowCount;
    private int pageSize = 100;
    private int pageNo = 1;
    private int skip = 0;

    public PageModel() {
    }

    public int getTotalPages() {
        return (this.rowCount + this.pageSize - 1) / this.pageSize;
    }

    public List<T> getDatas() {
        return this.datas;
    }

    public void setDatas(List<T> datas) {
        this.datas = datas;
    }

    public int getRowCount() {
        return this.rowCount;
    }

    public void setRowCount(int rowCount) {
        this.rowCount = rowCount;
    }

    public int getPageSize() {
        return this.pageSize;
    }

    public void setPageSize(int pageSize) {
        this.pageSize = pageSize;
    }

    public int getSkip() {
        this.skip = (this.pageNo - 1) * this.pageSize;
        return this.skip;
    }

    public void setSkip(int skip) {
        this.skip = skip;
    }

    public int getPageNo() {
        return this.pageNo;
    }

    public void setPageNo(int pageNo) {
        this.pageNo = pageNo;
    }
}

 

/**
 * 获取应用接口列表详情统计数据
 *
 * @return
 */
@Override
public PageModel<UltronSpan> getInterfaceDatasByName(String serviceName,String interfaceName, int pageNo) {


    PageModel<UltronSpan> pageModel = new PageModel<>();
    pageModel.setPageNo(pageNo);

    Criteria criteria = Criteria.where("localEndpoint.serviceName").is(serviceName).and("name").is(interfaceName);
    Query query = new Query(criteria);
    int count = (int) mongoTemplate.count(query, "nova-trace");
    pageModel.setRowCount(count);
    query.with(new Sort(Sort.Direction.DESC, "timestamp"));
    query.skip(pageModel.getSkip()).limit(pageModel.getPageSize());
    List<UltronSpan> result = mongoTemplate.find(query, UltronSpan.class, "nova-trace");
    pageModel.setDatas(result);

    return pageModel;
}

<dependency>
 <groupId>com.nova</groupId>
 <artifactId>nova-version</artifactId>
</dependency>

server {
    listen 80;
    listen 443 ssl;
    server_name localhost;
 
    ssl_certificate server.crt;
    ssl_certificate_key server.key;
 
    location / {
        proxy_pass http://localhost:8080;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
        proxy_set_header X-Forwarded-Port $server_port;
    }
}

<dependency>
<groupId>com.nova</groupId>
<artifactId>nova-hive</artifactId>
</dependency>

@Autowired
@Qualifier("hiveJdbcTemplate")
JdbcTemplate hiveJdbcTemplate;

@Resource
private RedefineTracer novaTracer;

novaTracer.addTag("myname","test12345");
novaTracer.addTag("myname1","test12345");
novaTracer.addTag("myname2","test12345");
novaTracer.addTag("myname3","test12345");
novaTracer.addTag("myname4","test12345");