P1离线数仓_LogServer

怼烎@ 2022-11-25 13:22 124阅读 0赞

### 文章目录 ###

*  1 多Module的创建
 *   *  1.1 Maven
     *  1.2 添加Module
     *  1.3 pom管理
 *  2 code
 *   *  2.1 客户端
     *  2.2 服务端
     *   *  log写入本地
     *  3 打包到Server
     *   *   *  只打包log-server

# 1 多Module的创建 #

## 1.1 Maven ##

首先创建普通Maven项目

## 1.2 添加Module ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70]

## 1.3 pom管理 ##

多Module的

在主工程pom中配置

</dependencyManagement>

并配置详细版本  
子工程中的pom文件不需要再进行配置版本

# 2 code #

## 2.1 客户端 ##

**Access**

public class Access {
        
    
        private int id;
        private String name;
        private String time;
    
        @Override
        public String toString(){
        
            return id + "\t" + name + "\t" + time;
        }

**UploadUtils**

package utils;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.HttpURLConnection;
    import java.net.MalformedURLException;
    import java.net.URL;
    
    
    public class UploadUtils {
        
    
    
        public static void upload(String path,String log){
        
    
            try {
        
                URL url = new URL(path);
                HttpURLConnection connection = (HttpURLConnection) url.openConnection();
    
                // GET POST
                connection.setRequestMethod("POST");
                connection.setDoOutput(true);
    
    
                // json数据==>application/json
                connection.setRequestProperty("Content-Type","application/text");
    
                OutputStream out = connection.getOutputStream();
                out.write(log.getBytes());
                out.flush();
                out.close();
    
                int responseCode = connection.getResponseCode();
                System.out.println(responseCode);
            } catch (MalformedURLException e) {
        
                e.printStackTrace();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
    
        }
        }

## 2.2 服务端 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70 1]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70 2]  
**LogController**

import org.apache.log4j.Logger;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    
    @Controller
    public class LogController {
        
    
        private static final Logger logger = Logger.getLogger("LogController");
    
        @PostMapping(value = "/upload")
        @ResponseBody
        public void upload(@RequestBody String log) {
        
            System.out.println(log);
            logger.info(log);
        }
    }

**MokeData**

package utils;
    
    import domian.Access;
    import org.junit.Test;
    
    import javax.xml.crypto.Data;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import static java.lang.String.format;
    
    public class MockData {
        
    
        public static final String URL = "http://localhost:9527/log/upload";
        SimpleDateFormat format  = new SimpleDateFormat("HH:mm:ss");
    
        @Test
        public void testUpload() throws InterruptedException {
        
            for(int i = 1; i <= 1000; i++){
        
                Thread.sleep(1000);
                Access access = new Access();
                access.setName("ifeng"+i);
                access.setId(i);
                access.setTime(format.format(new Date()));
    
    
                System.out.println(access);
                UploadUtils.upload(URL,access.toString());
            }
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70 3]

### log写入本地 ###

**log4j.properties**

log4j.appender.ingrate=org.apache.log4j.DailyRollingFileAppender
    log4j.appender.ingrate.file=../logs/access.log
    log4j.appender.ingrate.DatePattern='.'yyyy-MM-dd
    log4j.appender.ingrate.layout=org.apache.log4j.PatternLayout
    log4j.appender.ingrate.layout.ConversionPattern=%m%n
    log4j.rootLogger=info,ingrate

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center]

## 3 打包到Server ##

**package**  
很神奇的 pom下的这一段需要删掉  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 1]

**上传到Server**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 2]  
**执行jar包**

java -jar ../lib/ifeng-log-1.0.jar

**nohup**  
![在这里插入图片描述][20200812131635825.png_pic_center]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 3]  
没有主类

#### 只打包log-server ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 4]  
显示已经启动  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 5]  
启动Mockdata  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 6]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 7]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70]: /images/20221124/5859255a28a740679638f3c27273b033.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70 1]: /images/20221124/9c111ad9d8f743bfa933d25521cdc4ea.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70 2]: /images/20221124/5ee3dcdbad894b129c3c3465830eaca1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70 3]: /images/20221124/79940406f34940f08c0cf1b6f086eb6e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/44ca349a04414921b388e18b468d03a4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/bf6d05c6dfab42be963e7a9428c00525.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221124/4b8b79b92f784e4b82345766cb92dc70.png
[20200812131635825.png_pic_center]: /images/20221124/2c583df94c564f4d9a68dffcc0a39b05.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221124/1a94a46fd71f446988faf7147022774f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221124/8eed5c1b37704ab598e380aca46d4a5a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221124/f3711553f41b4d31bb383d5d6bf84e6f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221124/07c5ffb932864dfe80063be4fb9633af.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTM4MTgzMw_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221124/aa6f81e9776648879bbf2d20776321ca.png