图文精华

About云-梭伦科技»专题 › 技术学习(版主发帖区) › 大数据学习 › Hive|数据仓库 › 连载型› 企业级数据仓库构建（二）
分享

企业级数据仓库构建（二）

levycui 2020-9-9 22:57:32 发表于 连载型 [显示全部楼层] 只看大图 回帖奖励 阅读模式 关闭右栏 0 3869
本帖最后由 levycui 于 2020-9-9 22:59 编辑
问题导读：
1、如何进行埋点数据处理？
2、事件日志数据如何设计表？
3、如何使用数据生成脚本？
4、如何配置日志打印Logback？



上一篇：企业级数据仓库构建（一）

一、数据生成模块
1）埋点数据基本格式
  • 公共字段：基本所有安卓手机都包含的字段
  • 业务（事件）字段：埋点上报的字段，有具体的业务类型
示例如下
20200428092148276.png

2）示例日志（服务器时间戳 | 日志）如下
注意：事件字段包含多个用户行为数据
20200428092250499.png

3）事件日志数据
【3.1】商品列表页(loading)
事件名称：loading

2020-09-09_225528.jpg

【3.2】商品点击(display)
事件标签：display
2020-09-09_225606.jpg

【3.3】商品详情页(newsdetail)
事件名称：newsdetail
2020-09-09_225647.jpg

【3.4】广告(ad)
事件名称：ad

2020-09-09_225717.jpg

【3.5】消息通知(notification)
事件名称：notification
2020-09-09_225746.jpg
【3.7】评论（comment）
事件名称：comment
2020-09-09_225816.jpg
【3.8】收藏（favorites）
事件名称：favorites
2020-09-09_225849.jpg

2020-09-09_225919.jpg

【3.11】启动日志数据
事件标签: start
2020-09-09_225953.jpg

2020-09-09_230040.jpg
4）数据生成脚本
【4.1】架构图
2020-09-09_230118.jpg

【4.2】流程
1）创建Maven工程
2）导入依赖
  1. <!--版本号统一-->

  2.     <properties>

  3.         <slf4j.version>1.7.20</slf4j.version>

  4.         <logback.version>1.0.7</logback.version>

  5.     </properties>

  6.     <dependencies>

  7.         <!--阿里巴巴开源 json 解析框架-->

  8.         <dependency>

  9.             <groupId>com.alibaba</groupId>

  10.             <artifactId>fastjson</artifactId>

  11.             <version>1.2.51</version>

  12.         </dependency>

  13.         <!--日志生成框架-->

  14.         <dependency>

  15.             <groupId>ch.qos.logback</groupId>

  16.             <artifactId>logback-core</artifactId>

  17.             <version>${logback.version}</version>

  18.         </dependency>

  19.         <dependency>

  20.             <groupId>ch.qos.logback</groupId>

  21.             <artifactId>logback-classic</artifactId>

  22.             <version>${logback.version}</version>

  23.         </dependency>

  24.     </dependencies>

  25. 

  26.     <!--编译打包插件-->

  27.     <build>

  28.         <plugins>

  29.             <plugin>

  30.                 <artifactId>maven-compiler-plugin</artifactId>

  31.                 <version>2.3.2</version>

  32.                 <configuration>

  33.                     <source>1.8</source>

  34.                     <target>1.8</target>

  35.                 </configuration>

  36.             </plugin>

  37.             <plugin>

  38.                 <artifactId>maven-assembly-plugin </artifactId>

  39.                 <configuration>

  40.                     <descriptorRefs>

  41.                         <descriptorRef>jar-with-dependencies</descriptorRef>

  42.                     </descriptorRefs>

  43.                     <archive>

  44.                         <manifest>

  45.                             <!--主方法全限定名-->

  46.                             <mainClass>com.zsy.appclient.AppMain</mainClass>

  47.                         </manifest>

  48.                     </archive>

  49.                 </configuration>

  50.                 <executions>

  51.                     <execution>

  52.                         <id>make-assembly</id>

  53.                         <phase>package</phase>

  54.                         <goals>

  55.                             <goal>single</goal>

  56.                         </goals>

  57.                     </execution>

  58.                 </executions>

  59.             </plugin>

  60.         </plugins>

  61.     </build>
复制代码

3）编写bean对象
  • 用户后台活跃 AppActive_background.java
  1. package com.zsy.bean;

  2. /**

  3.  * 用户后台活跃

  4.  */

  5. public class AppActive_background {

  6.     private String active_source;//1=upgrade,2=download(下载),3=plugin_upgrade

  7. 

  8.     public String getActive_source() {

  9.         return active_source;

  10.     }

  11. 

  12.     public void setActive_source(String active_source) {

  13.         this.active_source = active_source;

  14.     }

  15. }

复制代码
广告AppAd.java

  1. package com.zsy.bean;

  2. /**

  3.  * 广告

  4.  */

  5. public class AppAd {

  6. 

  7.     private String entry;//入口：商品列表页=1  应用首页=2 商品详情页=3

  8.     private String action;//动作： 广告展示=1 广告点击=2

  9.     private String contentType;//Type: 1 商品 2 营销活动

  10.     private String displayMills;//展示时长 毫秒数

  11.     private String itemId; //商品id

  12.     private String activityId; //营销活动id

  13. 

  14. 

  15.     public String getEntry() {

  16.         return entry;

  17.     }

  18. 

  19.     public void setEntry(String entry) {

  20.         this.entry = entry;

  21.     }

  22. 

  23.     public String getAction() {

  24.         return action;

  25.     }

  26. 

  27.     public void setAction(String action) {

  28.         this.action = action;

  29.     }

  30. 

  31.     public String getActivityId() {

  32.         return activityId;

  33.     }

  34. 

  35.     public void setActivityId(String activityId) {

  36.         this.activityId = activityId;

  37.     }

  38. 

  39.     public String getContentType() {

  40.         return contentType;

  41.     }

  42. 

  43.     public void setContentType(String contentType) {

  44.         this.contentType = contentType;

  45.     }

  46. 

  47.     public String getDisplayMills() {

  48.         return displayMills;

  49.     }

  50. 

  51.     public void setDisplayMills(String displayMills) {

  52.         this.displayMills = displayMills;

  53.     }

  54. 

  55.     public String getItemId() {

  56.         return itemId;

  57.     }

  58. 

  59.     public void setItemId(String itemId) {

  60.         this.itemId = itemId;

  61.     }

  62. }

  63. 

复制代码

公共日志 AppBase.java
  1. package com.zsy.bean;

  2. /**

  3.  * 公共日志

  4.  */

  5. public class AppBase{

  6. 

  7.     private String mid; // (String) 设备唯一标识

  8.     private String uid; // (String) 用户uid

  9.     private String vc;  // (String) versionCode，程序版本号

  10.     private String vn;  // (String) versionName，程序版本名

  11.     private String l;   // (String) 系统语言

  12.     private String sr;  // (String) 渠道号，应用从哪个渠道来的。

  13.     private String os;  // (String) Android系统版本

  14.     private String ar;  // (String) 区域

  15.     private String md;  // (String) 手机型号

  16.     private String ba;  // (String) 手机品牌

  17.     private String sv;  // (String) sdkVersion

  18.     private String g;   // (String) gmail

  19.     private String hw;  // (String) heightXwidth，屏幕宽高

  20.     private String t;   // (String) 客户端日志产生时的时间

  21.     private String nw;  // (String) 网络模式

  22.     private String ln;  // (double) lng经度

  23.     private String la;  // (double) lat 纬度

  24. 

  25.     public String getMid() {

  26.         return mid;

  27.     }

  28. 

  29.     public void setMid(String mid) {

  30.         this.mid = mid;

  31.     }

  32. 

  33.     public String getUid() {

  34.         return uid;

  35.     }

  36. 

  37.     public void setUid(String uid) {

  38.         this.uid = uid;

  39.     }

  40. 

  41.     public String getVc() {

  42.         return vc;

  43.     }

  44. 

  45.     public void setVc(String vc) {

  46.         this.vc = vc;

  47.     }

  48. 

  49.     public String getVn() {

  50.         return vn;

  51.     }

  52. 

  53.     public void setVn(String vn) {

  54.         this.vn = vn;

  55.     }

  56. 

  57.     public String getL() {

  58.         return l;

  59.     }

  60. 

  61.     public void setL(String l) {

  62.         this.l = l;

  63.     }

  64. 

  65.     public String getSr() {

  66.         return sr;

  67.     }

  68. 

  69.     public void setSr(String sr) {

  70.         this.sr = sr;

  71.     }

  72. 

  73.     public String getOs() {

  74.         return os;

  75.     }

  76. 

  77.     public void setOs(String os) {

  78.         this.os = os;

  79.     }

  80. 

  81.     public String getAr() {

  82.         return ar;

  83.     }

  84. 

  85.     public void setAr(String ar) {

  86.         this.ar = ar;

  87.     }

  88. 

  89.     public String getMd() {

  90.         return md;

  91.     }

  92. 

  93.     public void setMd(String md) {

  94.         this.md = md;

  95.     }

  96. 

  97.     public String getBa() {

  98.         return ba;

  99.     }

  100. 

  101.     public void setBa(String ba) {

  102.         this.ba = ba;

  103.     }

  104. 

  105.     public String getSv() {

  106.         return sv;

  107.     }

  108. 

  109.     public void setSv(String sv) {

  110.         this.sv = sv;

  111.     }

  112. 

  113.     public String getG() {

  114.         return g;

  115.     }

  116. 

  117.     public void setG(String g) {

  118.         this.g = g;

  119.     }

  120. 

  121.     public String getHw() {

  122.         return hw;

  123.     }

  124. 

  125.     public void setHw(String hw) {

  126.         this.hw = hw;

  127.     }

  128. 

  129.     public String getT() {

  130.         return t;

  131.     }

  132. 

  133.     public void setT(String t) {

  134.         this.t = t;

  135.     }

  136. 

  137.     public String getNw() {

  138.         return nw;

  139.     }

  140. 

  141.     public void setNw(String nw) {

  142.         this.nw = nw;

  143.     }

  144. 

  145.     public String getLn() {

  146.         return ln;

  147.     }

  148. 

  149.     public void setLn(String ln) {

  150.         this.ln = ln;

  151.     }

  152. 

  153.     public String getLa() {

  154.         return la;

  155.     }

  156. 

  157.     public void setLa(String la) {

  158.         this.la = la;

  159.     }

  160. }

  161. 

复制代码



评论 AppComment.java
  1. package com.zsy.bean;

  2. /**

  3.  * 评论

  4.  */

  5. public class AppComment {

  6. 

  7.     private int comment_id;//评论表

  8.     private int userid;//用户id

  9.     private  int p_comment_id;//父级评论id(为0则是一级评论,不为0则是回复)

  10.     private String content;//评论内容

  11.     private String addtime;//创建时间

  12.     private int other_id;//评论的相关id

  13.     private int praise_count;//点赞数量

  14.     private int reply_count;//回复数量

  15. 

  16.     public int getComment_id() {

  17.         return comment_id;

  18.     }

  19. 

  20.     public void setComment_id(int comment_id) {

  21.         this.comment_id = comment_id;

  22.     }

  23. 

  24.     public int getUserid() {

  25.         return userid;

  26.     }

  27. 

  28.     public void setUserid(int userid) {

  29.         this.userid = userid;

  30.     }

  31. 

  32.     public int getP_comment_id() {

  33.         return p_comment_id;

  34.     }

  35. 

  36.     public void setP_comment_id(int p_comment_id) {

  37.         this.p_comment_id = p_comment_id;

  38.     }

  39. 

  40.     public String getContent() {

  41.         return content;

  42.     }

  43. 

  44.     public void setContent(String content) {

  45.         this.content = content;

  46.     }

  47. 

  48.     public String getAddtime() {

  49.         return addtime;

  50.     }

  51. 

  52.     public void setAddtime(String addtime) {

  53.         this.addtime = addtime;

  54.     }

  55. 

  56.     public int getOther_id() {

  57.         return other_id;

  58.     }

  59. 

  60.     public void setOther_id(int other_id) {

  61.         this.other_id = other_id;

  62.     }

  63. 

  64.     public int getPraise_count() {

  65.         return praise_count;

  66.     }

  67. 

  68.     public void setPraise_count(int praise_count) {

  69.         this.praise_count = praise_count;

  70.     }

  71. 

  72.     public int getReply_count() {

  73.         return reply_count;

  74.     }

  75. 

  76.     public void setReply_count(int reply_count) {

  77.         this.reply_count = reply_count;

  78.     }

  79. }

  80. 

复制代码

商品点击日志 AppDisplay.java
  1. package com.zsy.bean;

  2. /**

  3.  * 商品点击日志

  4.  */

  5. public class AppDisplay {

  6. 

  7.     private String action;//动作：曝光商品=1，点击商品=2，

  8.     private String goodsid;//商品ID（服务端下发的ID）

  9.     private String place;//顺序（第几条商品，第一条为0，第二条为1，如此类推）

  10.     private String extend1;//曝光类型：1 - 首次曝光 2-重复曝光（没有使用）

  11.     private String category;//分类ID（服务端定义的分类ID）

  12. 

  13.     public String getAction() {

  14.         return action;

  15.     }

  16. 

  17.     public void setAction(String action) {

  18.         this.action = action;

  19.     }

  20. 

  21.     public String getGoodsid() {

  22.         return goodsid;

  23.     }

  24. 

  25.     public void setGoodsid(String goodsid) {

  26.         this.goodsid = goodsid;

  27.     }

  28. 

  29.     public String getPlace() {

  30.         return place;

  31.     }

  32. 

  33.     public void setPlace(String place) {

  34.         this.place = place;

  35.     }

  36. 

  37.     public String getExtend1() {

  38.         return extend1;

  39.     }

  40. 

  41.     public void setExtend1(String extend1) {

  42.         this.extend1 = extend1;

  43.     }

  44. 

  45.     public String getCategory() {

  46.         return category;

  47.     }

  48. 

  49.     public void setCategory(String category) {

  50.         this.category = category;

  51.     }

  52. }

  53. 

复制代码
错误日志 AppErrorLog.java
  1. package com.zsy.bean;

  2. /**

  3.  * 错误日志

  4.  */

  5. public class AppErrorLog {

  6. 

  7.     private String errorBrief;    //错误摘要

  8.     private String errorDetail;   //错误详情

  9. 

  10.     public String getErrorBrief() {

  11.         return errorBrief;

  12.     }

  13. 

  14.     public void setErrorBrief(String errorBrief) {

  15.         this.errorBrief = errorBrief;

  16.     }

  17. 

  18.     public String getErrorDetail() {

  19.         return errorDetail;

  20.     }

  21. 

  22.     public void setErrorDetail(String errorDetail) {

  23.         this.errorDetail = errorDetail;

  24.     }

  25. }

  26. 

复制代码
收藏 AppFavorites.java
  1. package com.zsy.bean;

  2. /**

  3.  * 收藏

  4.  */

  5. public class AppFavorites {

  6.     private int id;//主键

  7.     private int course_id;//商品id

  8.     private int userid;//用户ID

  9.     private String add_time;//创建时间

  10. 

  11.     public int getId() {

  12.         return id;

  13.     }

  14. 

  15.     public void setId(int id) {

  16.         this.id = id;

  17.     }

  18. 

  19.     public int getCourse_id() {

  20.         return course_id;

  21.     }

  22. 

  23.     public void setCourse_id(int course_id) {

  24.         this.course_id = course_id;

  25.     }

  26. 

  27.     public int getUserid() {

  28.         return userid;

  29.     }

  30. 

  31.     public void setUserid(int userid) {

  32.         this.userid = userid;

  33.     }

  34. 

  35.     public String getAdd_time() {

  36.         return add_time;

  37.     }

  38. 

  39.     public void setAdd_time(String add_time) {

  40.         this.add_time = add_time;

  41.     }

  42. }

  43. 

复制代码

商品列表 AppLoading.java
  1. package com.zsy.bean;

  2. /**

  3.  * 商品列表

  4.  */

  5. public class AppLoading {

  6.     private String action;//动作：开始加载=1，加载成功=2，加载失败=3

  7.     private String loading_time;//加载时长：计算下拉开始到接口返回数据的时间，（开始加载报0，加载成功或加载失败才上报时间）

  8.     private String loading_way;//加载类型：1-读取缓存，2-从接口拉新数据   （加载成功才上报加载类型）

  9.     private String extend1;//扩展字段 Extend1

  10.     private String extend2;//扩展字段 Extend2

  11.     private String type;//加载类型：自动加载=1，用户下拽加载=2，底部加载=3（底部条触发点击底部提示条/点击返回顶部加载）

  12.     private String type1;//加载失败码：把加载失败状态码报回来（报空为加载成功，没有失败）

  13. 

  14.     public String getAction() {

  15.         return action;

  16.     }

  17. 

  18.     public void setAction(String action) {

  19.         this.action = action;

  20.     }

  21. 

  22.     public String getLoading_time() {

  23.         return loading_time;

  24.     }

  25. 

  26.     public void setLoading_time(String loading_time) {

  27.         this.loading_time = loading_time;

  28.     }

  29. 

  30.     public String getLoading_way() {

  31.         return loading_way;

  32.     }

  33. 

  34.     public void setLoading_way(String loading_way) {

  35.         this.loading_way = loading_way;

  36.     }

  37. 

  38.     public String getExtend1() {

  39.         return extend1;

  40.     }

  41. 

  42.     public void setExtend1(String extend1) {

  43.         this.extend1 = extend1;

  44.     }

  45. 

  46.     public String getExtend2() {

  47.         return extend2;

  48.     }

  49. 

  50.     public void setExtend2(String extend2) {

  51.         this.extend2 = extend2;

  52.     }

  53. 

  54.     public String getType() {

  55.         return type;

  56.     }

  57. 

  58.     public void setType(String type) {

  59.         this.type = type;

  60.     }

  61. 

  62.     public String getType1() {

  63.         return type1;

  64.     }

  65. 

  66.     public void setType1(String type1) {

  67.         this.type1 = type1;

  68.     }

  69. }

  70. 

复制代码

商品详情 AppNewsDetail.java
  1. package com.zsy.bean;

  2. /**

  3.  * 商品详情

  4.  */

  5. public class AppNewsDetail {

  6. 

  7.     private String entry;//页面入口来源：应用首页=1、push=2、详情页相关推荐=3

  8.     private String action;//动作：开始加载=1，加载成功=2（pv），加载失败=3, 退出页面=4

  9.     private String goodsid;//商品ID（服务端下发的ID）

  10.     private String showtype;//商品样式：0、无图1、一张大图2、两张图3、三张小图4、一张小图5、一张大图两张小图    来源于详情页相关推荐的商品，上报样式都为0（因为都是左文右图）

  11.     private String news_staytime;//页面停留时长：从商品开始加载时开始计算，到用户关闭页面所用的时间。若中途用跳转到其它页面了，则暂停计时，待回到详情页时恢复计时。或中途划出的时间超过10分钟，则本次计时作废，不上报本次数据。如未加载成功退出，则报空。

  12.     private String loading_time;//加载时长：计算页面开始加载到接口返回数据的时间 （开始加载报0，加载成功或加载失败才上报时间）

  13.     private String type1;//加载失败码：把加载失败状态码报回来（报空为加载成功，没有失败）

  14.     private String category;//分类ID（服务端定义的分类ID）

  15. 

  16.     public String getEntry() {

  17.         return entry;

  18.     }

  19. 

  20.     public void setEntry(String entry) {

  21.         this.entry = entry;

  22.     }

  23. 

  24.     public String getAction() {

  25.         return action;

  26.     }

  27. 

  28.     public void setAction(String action) {

  29.         this.action = action;

  30.     }

  31. 

  32.     public String getGoodsid() {

  33.         return goodsid;

  34.     }

  35. 

  36.     public void setGoodsid(String goodsid) {

  37.         this.goodsid = goodsid;

  38.     }

  39. 

  40.     public String getShowtype() {

  41.         return showtype;

  42.     }

  43. 

  44.     public void setShowtype(String showtype) {

  45.         this.showtype = showtype;

  46.     }

  47. 

  48.     public String getNews_staytime() {

  49.         return news_staytime;

  50.     }

  51. 

  52.     public void setNews_staytime(String news_staytime) {

  53.         this.news_staytime = news_staytime;

  54.     }

  55. 

  56.     public String getLoading_time() {

  57.         return loading_time;

  58.     }

  59. 

  60.     public void setLoading_time(String loading_time) {

  61.         this.loading_time = loading_time;

  62.     }

  63. 

  64.     public String getType1() {

  65.         return type1;

  66.     }

  67. 

  68.     public void setType1(String type1) {

  69.         this.type1 = type1;

  70.     }

  71. 

  72.     public String getCategory() {

  73.         return category;

  74.     }

  75. 

  76.     public void setCategory(String category) {

  77.         this.category = category;

  78.     }

  79. }

  80. 

复制代码

消息通知日志 AppNotification.java
  1. package com.zsy.bean;

  2. /**

  3.  * 消息通知日志

  4.  */

  5. public class AppNotification {

  6.     private String action;//动作：通知产生=1，通知弹出=2，通知点击=3，常驻通知展示（不重复上报，一天之内只报一次）=4

  7.     private String type;//通知id：预警通知=1，天气预报（早=2，晚=3），常驻=4

  8.     private String ap_time;//客户端弹出时间

  9.     private String content;//备用字段

  10. 

  11.     public String getAction() {

  12.         return action;

  13.     }

  14. 

  15.     public void setAction(String action) {

  16.         this.action = action;

  17.     }

  18. 

  19.     public String getType() {

  20.         return type;

  21.     }

  22. 

  23.     public void setType(String type) {

  24.         this.type = type;

  25.     }

  26. 

  27.     public String getAp_time() {

  28.         return ap_time;

  29.     }

  30. 

  31.     public void setAp_time(String ap_time) {

  32.         this.ap_time = ap_time;

  33.     }

  34. 

  35.     public String getContent() {

  36.         return content;

  37.     }

  38. 

  39.     public void setContent(String content) {

  40.         this.content = content;

  41.     }

  42. }

  43. 

复制代码

点赞 AppPraise.java
  1. package com.zsy.bean;

  2. /**

  3.  * 点赞

  4.  */

  5. public class AppPraise {

  6.     private int id; //主键id

  7.     private int userid;//用户id

  8.     private int target_id;//点赞的对象id

  9.     private int type;//点赞类型 1问答点赞 2问答评论点赞 3 文章点赞数4 评论点赞

  10.     private String add_time;//添加时间

  11. 

  12.     public int getId() {

  13.         return id;

  14.     }

  15. 

  16.     public void setId(int id) {

  17.         this.id = id;

  18.     }

  19. 

  20.     public int getUserid() {

  21.         return userid;

  22.     }

  23. 

  24.     public void setUserid(int userid) {

  25.         this.userid = userid;

  26.     }

  27. 

  28.     public int getTarget_id() {

  29.         return target_id;

  30.     }

  31. 

  32.     public void setTarget_id(int target_id) {

  33.         this.target_id = target_id;

  34.     }

  35. 

  36.     public int getType() {

  37.         return type;

  38.     }

  39. 

  40.     public void setType(int type) {

  41.         this.type = type;

  42.     }

  43. 

  44.     public String getAdd_time() {

  45.         return add_time;

  46.     }

  47. 

  48.     public void setAdd_time(String add_time) {

  49.         this.add_time = add_time;

  50.     }

  51. }

  52. 

  53. 

复制代码

启动日志 AppStart.java
  1. package com.zsy.bean;

  2. /**

  3.  * 启动日志

  4.  */

  5. public class AppStart extends AppBase {

  6. 

  7.     private String entry;//入口： push=1，widget=2，icon=3，notification=4, lockscreen_widget =5

  8.     private String open_ad_type;//开屏广告类型:  开屏原生广告=1, 开屏插屏广告=2

  9.     private String action;//状态：成功=1  失败=2

  10.     private String loading_time;//加载时长：计算下拉开始到接口返回数据的时间，（开始加载报0，加载成功或加载失败才上报时间）

  11.     private String detail;//失败码（没有则上报空）

  12.     private String extend1;//失败的message（没有则上报空）

  13.     private String en;//启动日志类型标记

  14. 

  15.     public String getEntry() {

  16.         return entry;

  17.     }

  18. 

  19.     public void setEntry(String entry) {

  20.         this.entry = entry;

  21.     }

  22. 

  23.     public String getOpen_ad_type() {

  24.         return open_ad_type;

  25.     }

  26. 

  27.     public void setOpen_ad_type(String open_ad_type) {

  28.         this.open_ad_type = open_ad_type;

  29.     }

  30. 

  31.     public String getAction() {

  32.         return action;

  33.     }

  34. 

  35.     public void setAction(String action) {

  36.         this.action = action;

  37.     }

  38. 

  39.     public String getLoading_time() {

  40.         return loading_time;

  41.     }

  42. 

  43.     public void setLoading_time(String loading_time) {

  44.         this.loading_time = loading_time;

  45.     }

  46. 

  47.     public String getDetail() {

  48.         return detail;

  49.     }

  50. 

  51.     public void setDetail(String detail) {

  52.         this.detail = detail;

  53.     }

  54. 

  55.     public String getExtend1() {

  56.         return extend1;

  57.     }

  58. 

  59.     public void setExtend1(String extend1) {

  60.         this.extend1 = extend1;

  61.     }

  62. 

  63.     public String getEn() {

  64.         return en;

  65.     }

  66. 

  67.     public void setEn(String en) {

  68.         this.en = en;

  69.     }

  70. }

  71. 

复制代码

4.创建数据生成代码 AppMain.java
  1. package com.zsy.appclient;

  2. 

  3. import java.io.UnsupportedEncodingException;

  4. import java.util.Random;

  5. 

  6. import com.alibaba.fastjson.JSON;

  7. import com.alibaba.fastjson.JSONArray;

  8. import com.alibaba.fastjson.JSONObject;

  9. import com.zsy.bean.*;

  10. import org.slf4j.Logger;

  11. import org.slf4j.LoggerFactory;

  12. 

  13. /**

  14.  * 日志行为数据模拟

  15.  */

  16. public class AppMain {

  17. 

  18.     private final static Logger logger = LoggerFactory.getLogger(AppMain.class);

  19.     private static Random rand = new Random();

  20. 

  21.     // 设备id

  22.     private static int s_mid = 0;

  23.     // 用户id

  24.     private static int s_uid = 0;

  25.     // 商品id

  26.     private static int s_goodsid = 0;

  27. 

  28.     public static void main(String[] args) {

  29.         // 参数一：控制发送每条的延时时间，默认是0

  30.         Long delay = args.length > 0 ? Long.parseLong(args[0]) : 0L;

  31.         // 参数二：循环遍历次数

  32.         int loop_len = args.length > 1 ? Integer.parseInt(args[1]) : 1000;

  33.         // 生成数据

  34.         generateLog(delay, loop_len);

  35.     }

  36. 

  37.     private static void generateLog(Long delay, int loop_len) {

  38.         for (int i = 0; i < loop_len; i++) {

  39.             int flag = rand.nextInt(2);

  40.             switch (flag) {

  41.                 case (0):

  42.                     //应用启动

  43.                     AppStart appStart = generateStart();

  44.                     String jsonString = JSON.toJSONString(appStart);

  45.                     //控制台打印

  46.                     logger.info(jsonString);

  47.                     break;

  48.                 case (1):

  49.                     JSONObject json = new JSONObject();

  50.                     json.put("ap", "app");

  51.                     json.put("cm", generateComFields());

  52.                     JSONArray eventsArray = new JSONArray();

  53.                     // 事件日志

  54.                     // 商品点击，展示

  55.                     if (rand.nextBoolean()) {

  56.                         eventsArray.add(generateDisplay());

  57.                         json.put("et", eventsArray);

  58.                     }

  59.                     // 商品详情页

  60.                     if (rand.nextBoolean()) {

  61.                         eventsArray.add(generateNewsDetail());

  62.                         json.put("et", eventsArray);

  63.                     }

  64.                     // 商品列表页

  65.                     if (rand.nextBoolean()) {

  66.                         eventsArray.add(generateNewList());

  67.                         json.put("et", eventsArray);

  68.                     }

  69.                     // 广告

  70.                     if (rand.nextBoolean()) {

  71.                         eventsArray.add(generateAd());

  72.                         json.put("et", eventsArray);

  73.                     }

  74.                     // 消息通知

  75.                     if (rand.nextBoolean()) {

  76.                         eventsArray.add(generateNotification());

  77.                         json.put("et", eventsArray);

  78.                     }

  79.                     // 用户后台活跃

  80.                     if (rand.nextBoolean()) {

  81.                         eventsArray.add(generateBackground());

  82.                         json.put("et", eventsArray);

  83.                     }

  84.                     //故障日志

  85.                     if (rand.nextBoolean()) {

  86.                         eventsArray.add(generateError());

  87.                         json.put("et", eventsArray);

  88.                     }

  89.                     // 用户评论

  90.                     if (rand.nextBoolean()) {

  91.                         eventsArray.add(generateComment());

  92.                         json.put("et", eventsArray);

  93.                     }

  94.                     // 用户收藏

  95.                     if (rand.nextBoolean()) {

  96.                         eventsArray.add(generateFavorites());

  97.                         json.put("et", eventsArray);

  98.                     }

  99.                     // 用户点赞

  100.                     if (rand.nextBoolean()) {

  101.                         eventsArray.add(generatePraise());

  102.                         json.put("et", eventsArray);

  103.                     }

  104.                     //时间

  105.                     long millis = System.currentTimeMillis();

  106.                     //控制台打印

  107.                     logger.info(millis + "|" + json.toJSONString());

  108.                     break;

  109.             }

  110.             // 延迟

  111.             try {

  112.                 Thread.sleep(delay);

  113.             } catch (InterruptedException e) {

  114.                 e.printStackTrace();

  115.             }

  116.         }

  117.     }

  118. 

  119.     /**

  120.      * 公共字段设置

  121.      */

  122.     private static JSONObject generateComFields() {

  123.         AppBase appBase = new AppBase();

  124.         //设备id

  125.         appBase.setMid(s_mid + "");

  126.         s_mid++;

  127.         // 用户id

  128.         appBase.setUid(s_uid + "");

  129.         s_uid++;

  130.         // 程序版本号 5,6等

  131.         appBase.setVc("" + rand.nextInt(20));

  132.         //程序版本名 v1.1.1

  133.         appBase.setVn("1." + rand.nextInt(4) + "." + rand.nextInt(10));

  134.         // 安卓系统版本

  135.         appBase.setOs("8." + rand.nextInt(3) + "." + rand.nextInt(10));

  136.         // 语言  es,en,pt

  137.         int flag = rand.nextInt(3);

  138.         switch (flag) {

  139.             case (0):

  140.                 appBase.setL("es");

  141.                 break;

  142.             case (1):

  143.                 appBase.setL("en");

  144.                 break;

  145.             case (2):

  146.                 appBase.setL("pt");

  147.                 break;

  148.         }

  149.         // 渠道号   从哪个渠道来的

  150.         appBase.setSr(getRandomChar(1));

  151.         // 区域

  152.         flag = rand.nextInt(2);

  153.         switch (flag) {

  154.             case 0:

  155.                 appBase.setAr("BR");

  156.             case 1:

  157.                 appBase.setAr("MX");

  158.         }

  159.         // 手机品牌 ba ,手机型号 md，就取2位数字了

  160.         flag = rand.nextInt(3);

  161.         switch (flag) {

  162.             case 0:

  163.                 appBase.setBa("Sumsung");

  164.                 appBase.setMd("sumsung-" + rand.nextInt(20));

  165.                 break;

  166.             case 1:

  167.                 appBase.setBa("Huawei");

  168.                 appBase.setMd("Huawei-" + rand.nextInt(20));

  169.                 break;

  170.             case 2:

  171.                 appBase.setBa("HTC");

  172.                 appBase.setMd("HTC-" + rand.nextInt(20));

  173.                 break;

  174.         }

  175.         // 嵌入sdk的版本

  176.         appBase.setSv("V2." + rand.nextInt(10) + "." + rand.nextInt(10));

  177.         // gmail

  178.         appBase.setG(getRandomCharAndNumr(8) + "@gmail.com");

  179.         // 屏幕宽高 hw

  180.         flag = rand.nextInt(4);

  181.         switch (flag) {

  182.             case 0:

  183.                 appBase.setHw("640*960");

  184.                 break;

  185.             case 1:

  186.                 appBase.setHw("640*1136");

  187.                 break;

  188.             case 2:

  189.                 appBase.setHw("750*1134");

  190.                 break;

  191.             case 3:

  192.                 appBase.setHw("1080*1920");

  193.                 break;

  194.         }

  195.         // 客户端产生日志时间

  196.         long millis = System.currentTimeMillis();

  197.         appBase.setT("" + (millis - rand.nextInt(99999999)));

  198.         // 手机网络模式 3G,4G,WIFI

  199.         flag = rand.nextInt(3);

  200.         switch (flag) {

  201.             case 0:

  202.                 appBase.setNw("3G");

  203.                 break;

  204.             case 1:

  205.                 appBase.setNw("4G");

  206.                 break;

  207.             case 2:

  208.                 appBase.setNw("WIFI");

  209.                 break;

  210.         }

  211.         // 拉丁美洲 西经34°46′至西经117°09；北纬32°42′至南纬53°54′

  212.         // 经度

  213.         appBase.setLn((-34 - rand.nextInt(83) - rand.nextInt(60) / 10.0) + "");

  214.         // 纬度

  215.         appBase.setLa((32 - rand.nextInt(85) - rand.nextInt(60) / 10.0) + "");

  216.         return (JSONObject) JSON.toJSON(appBase);

  217.     }

  218. 

  219.     /**

  220.      * 商品展示事件

  221.      */

  222.     private static JSONObject generateDisplay() {

  223.         AppDisplay appDisplay = new AppDisplay();

  224.         boolean boolFlag = rand.nextInt(10) < 7;

  225.         // 动作：曝光商品=1，点击商品=2，

  226.         if (boolFlag) {

  227.             appDisplay.setAction("1");

  228.         } else {

  229.             appDisplay.setAction("2");

  230.         }

  231.         // 商品id

  232.         String goodsId = s_goodsid + "";

  233.         s_goodsid++;

  234.         appDisplay.setGoodsid(goodsId);

  235.         // 顺序  设置成6条吧

  236.         int flag = rand.nextInt(6);

  237.         appDisplay.setPlace("" + flag);

  238.         // 曝光类型

  239.         flag = 1 + rand.nextInt(2);

  240.         appDisplay.setExtend1("" + flag);

  241.         // 分类

  242.         flag = 1 + rand.nextInt(100);

  243.         appDisplay.setCategory("" + flag);

  244.         JSONObject jsonObject = (JSONObject) JSON.toJSON(appDisplay);

  245.         return packEventJson("display", jsonObject);

  246.     }

  247. 

  248.     /**

  249.      * 商品详情页

  250.      */

  251.     private static JSONObject generateNewsDetail() {

  252.         AppNewsDetail appNewsDetail = new AppNewsDetail();

  253.         // 页面入口来源

  254.         int flag = 1 + rand.nextInt(3);

  255.         appNewsDetail.setEntry(flag + "");

  256.         // 动作

  257.         appNewsDetail.setAction("" + (rand.nextInt(4) + 1));

  258.         // 商品id

  259.         appNewsDetail.setGoodsid(s_goodsid + "");

  260.         // 商品来源类型

  261.         flag = 1 + rand.nextInt(3);

  262.         appNewsDetail.setShowtype(flag + "");

  263.         // 商品样式

  264.         flag = rand.nextInt(6);

  265.         appNewsDetail.setShowtype("" + flag);

  266.         // 页面停留时长

  267.         flag = rand.nextInt(10) * rand.nextInt(7);

  268.         appNewsDetail.setNews_staytime(flag + "");

  269.         // 加载时长

  270.         flag = rand.nextInt(10) * rand.nextInt(7);

  271.         appNewsDetail.setLoading_time(flag + "");

  272.         // 加载失败码

  273.         flag = rand.nextInt(10);

  274.         switch (flag) {

  275.             case 1:

  276.                 appNewsDetail.setType1("102");

  277.                 break;

  278.             case 2:

  279.                 appNewsDetail.setType1("201");

  280.                 break;

  281.             case 3:

  282.                 appNewsDetail.setType1("325");

  283.                 break;

  284.             case 4:

  285.                 appNewsDetail.setType1("433");

  286.                 break;

  287.             case 5:

  288.                 appNewsDetail.setType1("542");

  289.                 break;

  290.             default:

  291.                 appNewsDetail.setType1("");

  292.                 break;

  293.         }

  294.         // 分类

  295.         flag = 1 + rand.nextInt(100);

  296.         appNewsDetail.setCategory("" + flag);

  297.         JSONObject eventJson = (JSONObject) JSON.toJSON(appNewsDetail);

  298.         return packEventJson("newsdetail", eventJson);

  299.     }

  300. 

  301.     /**

  302.      * 商品列表

  303.      */

  304.     private static JSONObject generateNewList() {

  305. 

  306.         AppLoading appLoading = new AppLoading();

  307. 

  308.         // 动作

  309.         int flag = rand.nextInt(3) + 1;

  310.         appLoading.setAction(flag + "");

  311. 

  312.         // 加载时长

  313.         flag = rand.nextInt(10) * rand.nextInt(7);

  314.         appLoading.setLoading_time(flag + "");

  315. 

  316.         // 失败码

  317.         flag = rand.nextInt(10);

  318.         switch (flag) {

  319.             case 1:

  320.                 appLoading.setType1("102");

  321.                 break;

  322.             case 2:

  323.                 appLoading.setType1("201");

  324.                 break;

  325.             case 3:

  326.                 appLoading.setType1("325");

  327.                 break;

  328.             case 4:

  329.                 appLoading.setType1("433");

  330.                 break;

  331.             case 5:

  332.                 appLoading.setType1("542");

  333.                 break;

  334.             default:

  335.                 appLoading.setType1("");

  336.                 break;

  337.         }

  338. 

  339.         // 页面  加载类型

  340.         flag = 1 + rand.nextInt(2);

  341.         appLoading.setLoading_way("" + flag);

  342. 

  343.         // 扩展字段1

  344.         appLoading.setExtend1("");

  345. 

  346.         // 扩展字段2

  347.         appLoading.setExtend2("");

  348. 

  349.         // 用户加载类型

  350.         flag = 1 + rand.nextInt(3);

  351.         appLoading.setType("" + flag);

  352. 

  353.         JSONObject jsonObject = (JSONObject) JSON.toJSON(appLoading);

  354. 

  355.         return packEventJson("loading", jsonObject);

  356.     }

  357. 

  358.     /**

  359.      * 广告相关字段

  360.      */

  361.     private static JSONObject generateAd() {

  362. 

  363.         AppAd appAd = new AppAd();

  364. 

  365.         // 入口

  366.         int flag = rand.nextInt(3) + 1;

  367.         appAd.setEntry(flag + "");

  368. 

  369.         // 动作

  370.         flag = rand.nextInt(5) + 1;

  371.         appAd.setAction(flag + "");

  372. 

  373.         // 内容类型类型

  374.         flag = rand.nextInt(6) + 1;

  375.         appAd.setContentType(flag + "");

  376. 

  377.         // 展示样式

  378.         flag = rand.nextInt(120000) + 1000;

  379.         appAd.setDisplayMills(flag + "");

  380. 

  381.         flag = rand.nextInt(1);

  382.         if (flag == 1) {

  383.             appAd.setContentType(flag + "");

  384.             flag = rand.nextInt(6);

  385.             appAd.setItemId(flag + "");

  386.         } else {

  387.             appAd.setContentType(flag + "");

  388.             flag = rand.nextInt(1) + 1;

  389.             appAd.setActivityId(flag + "");

  390.         }

  391. 

  392.         JSONObject jsonObject = (JSONObject) JSON.toJSON(appAd);

  393. 

  394.         return packEventJson("ad", jsonObject);

  395.     }

  396. 

  397.     /**

  398.      * 启动日志

  399.      */

  400.     private static AppStart generateStart() {

  401. 

  402.         AppStart appStart = new AppStart();

  403. 

  404.         //设备id

  405.         appStart.setMid(s_mid + "");

  406.         s_mid++;

  407. 

  408.         // 用户id

  409.         appStart.setUid(s_uid + "");

  410.         s_uid++;

  411. 

  412.         // 程序版本号 5,6等

  413.         appStart.setVc("" + rand.nextInt(20));

  414. 

  415.         //程序版本名 v1.1.1

  416.         appStart.setVn("1." + rand.nextInt(4) + "." + rand.nextInt(10));

  417. 

  418.         // 安卓系统版本

  419.         appStart.setOs("8." + rand.nextInt(3) + "." + rand.nextInt(10));

  420. 

  421.         //设置日志类型

  422.         appStart.setEn("start");

  423. 

  424.         //    语言  es,en,pt

  425.         int flag = rand.nextInt(3);

  426.         switch (flag) {

  427.             case (0):

  428.                 appStart.setL("es");

  429.                 break;

  430.             case (1):

  431.                 appStart.setL("en");

  432.                 break;

  433.             case (2):

  434.                 appStart.setL("pt");

  435.                 break;

  436.         }

  437. 

  438.         // 渠道号   从哪个渠道来的

  439.         appStart.setSr(getRandomChar(1));

  440. 

  441.         // 区域

  442.         flag = rand.nextInt(2);

  443.         switch (flag) {

  444.             case 0:

  445.                 appStart.setAr("BR");

  446.             case 1:

  447.                 appStart.setAr("MX");

  448.         }

  449. 

  450.         // 手机品牌 ba ,手机型号 md，就取2位数字了

  451.         flag = rand.nextInt(3);

  452.         switch (flag) {

  453.             case 0:

  454.                 appStart.setBa("Sumsung");

  455.                 appStart.setMd("sumsung-" + rand.nextInt(20));

  456.                 break;

  457.             case 1:

  458.                 appStart.setBa("Huawei");

  459.                 appStart.setMd("Huawei-" + rand.nextInt(20));

  460.                 break;

  461.             case 2:

  462.                 appStart.setBa("HTC");

  463.                 appStart.setMd("HTC-" + rand.nextInt(20));

  464.                 break;

  465.         }

  466. 

  467.         // 嵌入sdk的版本

  468.         appStart.setSv("V2." + rand.nextInt(10) + "." + rand.nextInt(10));

  469.         // gmail

  470.         appStart.setG(getRandomCharAndNumr(8) + "@gmail.com");

  471. 

  472.         // 屏幕宽高 hw

  473.         flag = rand.nextInt(4);

  474.         switch (flag) {

  475.             case 0:

  476.                 appStart.setHw("640*960");

  477.                 break;

  478.             case 1:

  479.                 appStart.setHw("640*1136");

  480.                 break;

  481.             case 2:

  482.                 appStart.setHw("750*1134");

  483.                 break;

  484.             case 3:

  485.                 appStart.setHw("1080*1920");

  486.                 break;

  487.         }

  488. 

  489.         // 客户端产生日志时间

  490.         long millis = System.currentTimeMillis();

  491.         appStart.setT("" + (millis - rand.nextInt(99999999)));

  492. 

  493.         // 手机网络模式 3G,4G,WIFI

  494.         flag = rand.nextInt(3);

  495.         switch (flag) {

  496.             case 0:

  497.                 appStart.setNw("3G");

  498.                 break;

  499.             case 1:

  500.                 appStart.setNw("4G");

  501.                 break;

  502.             case 2:

  503.                 appStart.setNw("WIFI");

  504.                 break;

  505.         }

  506. 

  507.         // 拉丁美洲 西经34°46′至西经117°09；北纬32°42′至南纬53°54′

  508.         // 经度

  509.         appStart.setLn((-34 - rand.nextInt(83) - rand.nextInt(60) / 10.0) + "");

  510.         // 纬度

  511.         appStart.setLa((32 - rand.nextInt(85) - rand.nextInt(60) / 10.0) + "");

  512. 

  513.         // 入口

  514.         flag = rand.nextInt(5) + 1;

  515.         appStart.setEntry(flag + "");

  516. 

  517.         // 开屏广告类型

  518.         flag = rand.nextInt(2) + 1;

  519.         appStart.setOpen_ad_type(flag + "");

  520. 

  521.         // 状态

  522.         flag = rand.nextInt(10) > 8 ? 2 : 1;

  523.         appStart.setAction(flag + "");

  524. 

  525.         // 加载时长

  526.         appStart.setLoading_time(rand.nextInt(20) + "");

  527. 

  528.         // 失败码

  529.         flag = rand.nextInt(10);

  530.         switch (flag) {

  531.             case 1:

  532.                 appStart.setDetail("102");

  533.                 break;

  534.             case 2:

  535.                 appStart.setDetail("201");

  536.                 break;

  537.             case 3:

  538.                 appStart.setDetail("325");

  539.                 break;

  540.             case 4:

  541.                 appStart.setDetail("433");

  542.                 break;

  543.             case 5:

  544.                 appStart.setDetail("542");

  545.                 break;

  546.             default:

  547.                 appStart.setDetail("");

  548.                 break;

  549.         }

  550. 

  551.         // 扩展字段

  552.         appStart.setExtend1("");

  553. 

  554.         return appStart;

  555.     }

  556. 

  557.     /**

  558.      * 消息通知

  559.      */

  560.     private static JSONObject generateNotification() {

  561. 

  562.         AppNotification appNotification = new AppNotification();

  563. 

  564.         int flag = rand.nextInt(4) + 1;

  565. 

  566.         // 动作

  567.         appNotification.setAction(flag + "");

  568. 

  569.         // 通知id

  570.         flag = rand.nextInt(4) + 1;

  571.         appNotification.setType(flag + "");

  572. 

  573.         // 客户端弹时间

  574.         appNotification.setAp_time((System.currentTimeMillis() - rand.nextInt(99999999)) + "");

  575. 

  576.         // 备用字段

  577.         appNotification.setContent("");

  578. 

  579.         JSONObject jsonObject = (JSONObject) JSON.toJSON(appNotification);

  580. 

  581.         return packEventJson("notification", jsonObject);

  582.     }

  583. 

  584.     /**

  585.      * 后台活跃

  586.      */

  587.     private static JSONObject generateBackground() {

  588. 

  589.         AppActive_background appActive_background = new AppActive_background();

  590. 

  591.         // 启动源

  592.         int flag = rand.nextInt(3) + 1;

  593.         appActive_background.setActive_source(flag + "");

  594. 

  595.         JSONObject jsonObject = (JSONObject) JSON.toJSON(appActive_background);

  596. 

  597.         return packEventJson("active_background", jsonObject);

  598.     }

  599. 

  600.     /**

  601.      * 错误日志数据

  602.      */

  603.     private static JSONObject generateError() {

  604.         AppErrorLog appErrorLog = new AppErrorLog();

  605.         String[] errorBriefs = {"at cn.lift.dfdf.web.AbstractBaseController.validInbound(AbstractBaseController.java:72)", "at cn.lift.appIn.control.CommandUtil.getInfo(CommandUtil.java:67)"};        //错误摘要

  606.         String[] errorDetails = {"java.lang.NullPointerException\\n    " + "at cn.lift.appIn.web.AbstractBaseController.validInbound(AbstractBaseController.java:72)\\n " + "at cn.lift.dfdf.web.AbstractBaseController.validInbound", "at cn.lift.dfdfdf.control.CommandUtil.getInfo(CommandUtil.java:67)\\n " + "at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\\n" + " at java.lang.reflect.Method.invoke(Method.java:606)\\n"};        //错误详情

  607.         //错误摘要

  608.         appErrorLog.setErrorBrief(errorBriefs[rand.nextInt(errorBriefs.length)]);

  609.         //错误详情

  610.         appErrorLog.setErrorDetail(errorDetails[rand.nextInt(errorDetails.length)]);

  611.         JSONObject jsonObject = (JSONObject) JSON.toJSON(appErrorLog);

  612.         return packEventJson("error", jsonObject);

  613.     }

  614. 

  615.     /**

  616.      * 为各个事件类型的公共字段（时间、事件类型、Json数据）拼接

  617.      */

  618.     private static JSONObject packEventJson(String eventName, JSONObject jsonObject) {

  619.         JSONObject eventJson = new JSONObject();

  620.         eventJson.put("ett", (System.currentTimeMillis() - rand.nextInt(99999999)) + "");

  621.         eventJson.put("en", eventName);

  622.         eventJson.put("kv", jsonObject);

  623.         return eventJson;

  624.     }

  625. 

  626.     /**

  627.      * 获取随机字母组合

  628.      *

  629.      * @param length 字符串长度

  630.      */

  631.     private static String getRandomChar(Integer length) {

  632.         StringBuilder str = new StringBuilder();

  633.         Random random = new Random();

  634.         for (int i = 0; i < length; i++) {

  635.             // 字符串

  636.             str.append((char) (65 + random.nextInt(26)));// 取得大写字母

  637.         }

  638.         return str.toString();

  639.     }

  640. 

  641.     /**

  642.      * 获取随机字母数字组合

  643.      *

  644.      * @param length 字符串长度

  645.      */

  646.     private static String getRandomCharAndNumr(Integer length) {

  647.         StringBuilder str = new StringBuilder();

  648.         Random random = new Random();

  649.         for (int i = 0; i < length; i++) {

  650.             boolean b = random.nextBoolean();

  651.             if (b) { // 字符串

  652.                 // int choice = random.nextBoolean() ? 65 : 97; 取得65大写字母还是97小写字母

  653.                 str.append((char) (65 + random.nextInt(26)));// 取得大写字母

  654.             } else { // 数字

  655.                 str.append(String.valueOf(random.nextInt(10)));

  656.             }

  657.         }

  658.         return str.toString();

  659.     }

  660. 

  661.     /**

  662.      * 收藏

  663.      */

  664.     private static JSONObject generateFavorites() {

  665.         AppFavorites favorites = new AppFavorites();

  666.         favorites.setCourse_id(rand.nextInt(10));

  667.         favorites.setUserid(rand.nextInt(10));

  668.         favorites.setAdd_time((System.currentTimeMillis() - rand.nextInt(99999999)) + "");

  669.         JSONObject jsonObject = (JSONObject) JSON.toJSON(favorites);

  670.         return packEventJson("favorites", jsonObject);

  671.     }

  672. 

  673.     /**

  674.      * 点赞

  675.      */

  676.     private static JSONObject generatePraise() {

  677.         AppPraise praise = new AppPraise();

  678.         praise.setId(rand.nextInt(10));

  679.         praise.setUserid(rand.nextInt(10));

  680.         praise.setTarget_id(rand.nextInt(10));

  681.         praise.setType(rand.nextInt(4) + 1);

  682.         praise.setAdd_time((System.currentTimeMillis() - rand.nextInt(99999999)) + "");

  683.         JSONObject jsonObject = (JSONObject) JSON.toJSON(praise);

  684.         return packEventJson("praise", jsonObject);

  685.     }

  686. 

  687.     /**

  688.      * 评论

  689.      */

  690.     private static JSONObject generateComment() {

  691.         AppComment comment = new AppComment();

  692.         comment.setComment_id(rand.nextInt(10));

  693.         comment.setUserid(rand.nextInt(10));

  694.         comment.setP_comment_id(rand.nextInt(5));

  695.         comment.setContent(getCONTENT());

  696.         comment.setAddtime((System.currentTimeMillis() - rand.nextInt(99999999)) + "");

  697.         comment.setOther_id(rand.nextInt(10));

  698.         comment.setPraise_count(rand.nextInt(1000));

  699.         comment.setReply_count(rand.nextInt(200));

  700.         JSONObject jsonObject = (JSONObject) JSON.toJSON(comment);

  701.         return packEventJson("comment", jsonObject);

  702.     }

  703. 

  704.     /**

  705.      * 生成单个汉字

  706.      */

  707.     private static char getRandomChar() {

  708.         String str = "";

  709.         int hightPos; //

  710.         int lowPos;

  711.         Random random = new Random();

  712.         //随机生成汉子的两个字节

  713.         hightPos = (176 + Math.abs(random.nextInt(39)));

  714.         lowPos = (161 + Math.abs(random.nextInt(93)));

  715.         byte[] b = new byte[2];

  716.         b[0] = (Integer.valueOf(hightPos)).byteValue();

  717.         b[1] = (Integer.valueOf(lowPos)).byteValue();

  718.         try {

  719.             str = new String(b, "GBK");

  720.         } catch (UnsupportedEncodingException e) {

  721.             e.printStackTrace();

  722.             System.out.println("错误");

  723.         }

  724.         return str.charAt(0);

  725.     }

  726. 

  727.     /**

  728.      * 拼接成多个汉字

  729.      */

  730.     private static String getCONTENT() {

  731.         StringBuilder str = new StringBuilder();

  732.         for (int i = 0; i < rand.nextInt(100); i++) {

  733.             str.append(getRandomChar());

  734.         }

  735.         return str.toString();

  736.     }

  737. }

  738. 

复制代码

5）配置日志打印Logback
简介：Logback主要用于在磁盘和控制台打印日志
使用
  • 1）在resource文件夹下创建logback.xml文件
  • 2）在logback.xml文件添加如下配置
  1. <?xml version="1.0" encoding="UTF-8"?>

  2. <configuration debug="false">

  3.     <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径 -->

  4.     <property name="LOG_HOME" value="/opt/tmp/logs"/>

  5.     <!-- 控制台输出 -->

  6.     <appender name="STDOUT"

  7.               class="ch.qos.logback.core.ConsoleAppender">

  8.         <encoder

  9.                 class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">

  10.             <!--格式化输出：%d 表示日期，%thread 表示线程名，%-5level：级别从左显示 5 个字符宽度%msg：

  11.             日志消息，%n 是换行符 -->

  12.             <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>

  13.         </encoder>

  14.     </appender>

  15.     <!-- 按照每天生成日志文件。存储事件日志 -->

  16.     <appender name="FILE"

  17.               class="ch.qos.logback.core.rolling.RollingFileAppender">

  18.         <!-- <File>${LOG_HOME}/app.log</File>设置日志不超过${log.max.size}时的保存路径，注意，

  19.         如果是 web 项目会保存到 Tomcat 的 bin 目录 下 -->

  20.         <rollingPolicy

  21.                 class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">

  22.             <!--日志文件输出的文件名 -->

  23.             <FileNamePattern>${LOG_HOME}/app-%d{yyyy-MM-dd}.log</FileNamePattern>

  24.             <!--日志文件保留天数 -->

  25.             <MaxHistory>30</MaxHistory>

  26.         </rollingPolicy>

  27.         <encoder

  28.                 class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">

  29.             <pattern>%msg%n</pattern>

  30.         </encoder>

  31.         <!--日志文件最大的大小 -->

  32.         <triggeringPolicy

  33.                 class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">

  34.             <MaxFileSize>10MB</MaxFileSize>

  35.         </triggeringPolicy>

  36.     </appender>

  37.     <!--异步打印日志-->

  38.     <appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">

  39.         <!-- 不丢失日志.默认的,如果队列的 80%已满,则会丢弃 TRACT、DEBUG、INFO 级别的日志 -->

  40.         <discardingThreshold>0</discardingThreshold>

  41.         <!-- 更改默认的队列的深度,该值会影响性能.默认值为 256 -->

  42.         <queueSize>512</queueSize>

  43.         <!-- 添加附加的 appender,最多只能添加一个 -->

  44.         <appender-ref ref="FILE"/>

  45.     </appender>

  46.     <!-- 日志输出级别 -->

  47.     <root level="INFO">

  48.         <appender-ref ref="STDOUT"/>

  49.         <appender-ref ref="ASYNC_FILE"/>

  50.         <appender-ref ref="error"/>

  51.     </root>

  52. </configuration>

复制代码
6.代码整体架构
2020-09-09_230557.jpg

7.项目打包准备后续放在服务器上运行产生测试数据

作者：together
来源：https://together.blog.csdn.net/article/details/105805852

最新经典文章，欢迎关注公众号
回复

使用道具 举报

自定义广告语

没找到任何评论，期待你打破沉寂

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

发表新帖
levycui

超级版主

关注

  • 653

    主题

  • 1166

    帖子

  • 97

    粉丝

TA的主题
关闭

推荐上一条 /2 下一条

关于我们· 联系我们· 加入我们· 小黑屋· 合作伙伴   

Copyright © 2001-2024 About云-梭伦科技 Powered by Discuz! X3.4 Licensed Discuz Team.

简书 / Smrz 京ICP备2020039040号 Wxb 简书网举报电话：021-34700000