# 外部配置開啟
# logging.config=./logback.xml
#業務日期
mock.date: "2020-12-18"

  #模擬資料傳送模式
mock.type: "http"
  #http模式下，傳送的地址
mock.url: "http://hadoop101:8081/applog"

#mock:
#  kafka-server: "hdp1:9092,hdp2:9092,hdp3:9092"
#  kafka-topic: "ODS_BASE_LOG"

#啟動次數
mock.startup.count: 1000
  #裝置最大值
mock.max.mid: 20
  #會員最大值
mock.max.uid: 50
  #商品最大值
mock.max.sku-id: 10
  #頁面平均訪問時間
mock.page.during-time-ms: 20000
  #錯誤概率 百分比
mock.error.rate: 3
  #每條日誌傳送延遲 ms
mock.log.sleep: 100
  #商品詳情來源  使用者查詢，商品推廣，智慧推薦, 促銷活動
mock.detail.source-type-rate: "40:25:15:20"

#領取購物券概率
mock.if_get_coupon_rate: 75

#購物券最大id
mock.max.coupon-id: 3

  #搜尋關鍵詞  
mock.search.keyword: "圖書,小米,iphone11,電視,口紅,ps5,蘋果手機,小米盒子"
 

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;

@SpringBootApplication
public class GmallMockLogApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(GmallMockLogApplication.class, args);
        MockTask mockTask = context.getBean(MockTask.class);
        mockTask.mainTask();
    }
}
 

server:
  port: 8081
#kafka
spring:
  kafka:
    bootstrap-servers: 192.168.88.71:9092,192.168.88.72:9092,192.168.88.73:9092
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
 

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author zhangbao
 * @date 2021/5/16 11:33
 **/
@RestController
@Slf4j
public class LoggerController {

    @Autowired
    KafkaTemplate kafkaTemplate;
    @RequestMapping("/applog")
    public String logger(String param){
        log.info(param);
        kafkaTemplate.send("ods_base_log",param);
        return param;
    }
}

#在 server 內部配置
location /
{
        proxy_pass http://www.logserver.com;
}
#切記：在 server 外部配置反向代理
upstream www.logserver.com{
        server hadoop101:8081 weight=1;
        server hadoop102:8081 weight=2;
        server hadoop103:8081 weight=3;
}

  #模擬資料傳送模式
mock.type: "http"
  #http模式下，傳送的地址
mock.url: "http://hadoop101/applog"

#!/bin/bash

JAVA_HOME=/opt/module/jdk1.8.0_144/bin/java
APPNAME=gmall-logger-0.0.1-SNAPSHOT.jar

case $1 in
"start"){
        for i in hadoop101 hadoop102 hadoop103
        do
                echo "================$i================="
                ssh $i "$JAVA_HOME -Xms32m -Xmx64m -jar /opt/software/applog/$APPNAME >/dev/null 2>&1 &"
        done
        echo "===============NGINX================="
        /opt/module/nginx/sbin/nginx
};;
"stop"){
        echo "===============NGINX================="
        /opt/module/nginx/sbin/nginx -s stop
        for i in hadoop101 hadoop102 hadoop103
        do
                echo "================$i==============="
                ssh $i "ps -ef|grep $APPNAME |grep -v grep|awk '{print \$2}'|xargs kill" >dev/null 2>&1
        done
};;
esac