Java端模拟日志数据

package com.xxxx.appclient;

import java.io.UnsupportedEncodingException;

import java.util.Random;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONArray;

import com.alibaba.fastjson.JSONObject;

import com.xxxx.bean.*;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

* 日志行为数据模拟

public class AppMain {

private final static Loggerlogger = LoggerFactory.getLogger(AppMain.class);

private static Randomrand =new Random();

// 设备id

private static int s_mid =0;

// 用户id

private static int s_uid =0;

// 商品id

private static int s_goodsid =0;

public static void main(String[] args) {

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

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

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

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

// 生成数据

generateLog(delay, loop_len);

}

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

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

int flag =rand.nextInt(2);

switch (flag) {

case (0):

//应用启动

AppStart appStart =generateStart();

String jsonString = JSON.toJSONString(appStart);

//控制台打印

logger.info(jsonString);

break;

case (1):

JSONObject json =new JSONObject();

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

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

JSONArray eventsArray =new JSONArray();

// 事件日志

// 商品点击，展示

if (rand.nextBoolean()) {

eventsArray.add(generateDisplay());

json.put("et", eventsArray);

}

// 商品详情页

if (rand.nextBoolean()) {

eventsArray.add(generateNewsDetail());

json.put("et", eventsArray);

}

// 商品列表页

if (rand.nextBoolean()) {

eventsArray.add(generateNewList());

json.put("et", eventsArray);

}

// 广告

if (rand.nextBoolean()) {

eventsArray.add(generateAd());

json.put("et", eventsArray);

}

// 消息通知

if (rand.nextBoolean()) {

eventsArray.add(generateNotification());

json.put("et", eventsArray);

}

// 用户后台活跃

if (rand.nextBoolean()) {

eventsArray.add(generateBackground());

json.put("et", eventsArray);

}

//故障日志

if (rand.nextBoolean()) {

eventsArray.add(generateError());

json.put("et", eventsArray);

}

// 用户评论

if (rand.nextBoolean()) {

eventsArray.add(generateComment());

json.put("et", eventsArray);

}

// 用户收藏

if (rand.nextBoolean()) {

eventsArray.add(generateFavorites());

json.put("et", eventsArray);

}

// 用户点赞

if (rand.nextBoolean()) {

eventsArray.add(generatePraise());

json.put("et", eventsArray);

}

//时间

long millis = System.currentTimeMillis();

//控制台打印

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

break;

}

// 延迟

try {

Thread.sleep(delay);

}catch (InterruptedException e) {

e.printStackTrace();

}

/**

* 公共字段设置

private static JSONObjectgenerateComFields() {

AppBase appBase =new AppBase();

//设备id

appBase.setMid(s_mid +"");

s_mid++;

// 用户id

appBase.setUid(s_uid +"");

s_uid++;

// 程序版本号 5,6等

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

//程序版本名v1.1.1

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

// 安卓系统版本

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

// 语言es,en,pt

int flag =rand.nextInt(3);

switch (flag) {

case (0):

appBase.setL("es");

break;

case (1):

appBase.setL("en");

break;

case (2):

appBase.setL("pt");

break;

}

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

appBase.setSr(getRandomChar(1));

// 区域

flag =rand.nextInt(2);

switch (flag) {

case 0:

appBase.setAr("BR");

case 1:

appBase.setAr("MX");

}

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

flag =rand.nextInt(3);

switch (flag) {

case 0:

appBase.setBa("Sumsung");

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

break;

case 1:

appBase.setBa("Huawei");

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

break;

case 2:

appBase.setBa("HTC");

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

break;

}

// 嵌入sdk的版本

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

// gmail

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

// 屏幕宽高hw

flag =rand.nextInt(4);

switch (flag) {

case 0:

appBase.setHw("640*960");

break;

case 1:

appBase.setHw("640*1136");

break;

case 2:

appBase.setHw("750*1134");

break;

case 3:

appBase.setHw("1080*1920");

break;

}

// 客户端产生日志时间

long millis = System.currentTimeMillis();

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

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

flag =rand.nextInt(3);

switch (flag) {

case 0:

appBase.setNw("3G");

break;

case 1:

appBase.setNw("4G");

break;

case 2:

appBase.setNw("WIFI");

break;

}

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

// 经度

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

// 纬度

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

return (JSONObject) JSON.toJSON(appBase);

}

/**

* 商品展示事件

private static JSONObjectgenerateDisplay() {

AppDisplay appDisplay =new AppDisplay();

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

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

if (boolFlag) {

appDisplay.setAction("1");

}else {

appDisplay.setAction("2");

}

// 商品id

String goodsId =s_goodsid +"";

s_goodsid++;

appDisplay.setGoodsid(goodsId);

// 顺序设置成6条吧

int flag =rand.nextInt(6);

appDisplay.setPlace("" + flag);

// 曝光类型

flag =1 +rand.nextInt(2);

appDisplay.setExtend1("" + flag);

// 分类

flag =1 +rand.nextInt(100);

appDisplay.setCategory("" + flag);

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

return packEventJson("display", jsonObject);

}

/**

* 商品详情页

private static JSONObjectgenerateNewsDetail() {

AppNewsDetail appNewsDetail =new AppNewsDetail();

// 页面入口来源

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

appNewsDetail.setEntry(flag +"");

// 动作

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

// 商品id

appNewsDetail.setGoodsid(s_goodsid +"");

// 商品来源类型

flag =1 +rand.nextInt(3);

appNewsDetail.setShowtype(flag +"");

// 商品样式

flag =rand.nextInt(6);

appNewsDetail.setShowtype("" + flag);

// 页面停留时长

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

appNewsDetail.setNews_staytime(flag +"");

// 加载时长

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

appNewsDetail.setLoading_time(flag +"");

// 加载失败码

flag =rand.nextInt(10);

switch (flag) {

case 1:

appNewsDetail.setType1("102");

break;

case 2:

appNewsDetail.setType1("201");

break;

case 3:

appNewsDetail.setType1("325");

break;

case 4:

appNewsDetail.setType1("433");

break;

case 5:

appNewsDetail.setType1("542");

break;

default:

appNewsDetail.setType1("");

break;

}

// 分类

flag =1 +rand.nextInt(100);

appNewsDetail.setCategory("" + flag);

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

return packEventJson("newsdetail", eventJson);

}

/**

* 商品列表

private static JSONObjectgenerateNewList() {

AppLoading appLoading =new AppLoading();

// 动作

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

appLoading.setAction(flag +"");

// 加载时长

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

appLoading.setLoading_time(flag +"");

// 失败码

flag =rand.nextInt(10);

switch (flag) {

case 1:

appLoading.setType1("102");

break;

case 2:

appLoading.setType1("201");

break;

case 3:

appLoading.setType1("325");

break;

case 4:

appLoading.setType1("433");

break;

case 5:

appLoading.setType1("542");

break;

default:

appLoading.setType1("");

break;

}

// 页面加载类型

flag =1 +rand.nextInt(2);

appLoading.setLoading_way("" + flag);

// 扩展字段1

appLoading.setExtend1("");

// 扩展字段2

appLoading.setExtend2("");

// 用户加载类型

flag =1 +rand.nextInt(3);

appLoading.setType("" + flag);

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

return packEventJson("loading", jsonObject);

}

/**

* 广告相关字段

private static JSONObjectgenerateAd() {

AppAd appAd =new AppAd();

// 入口

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

appAd.setEntry(flag +"");

// 动作

flag =rand.nextInt(5) +1;

appAd.setAction(flag +"");

// 内容类型类型

flag =rand.nextInt(6)+1;

appAd.setContentType(flag+"");

// 展示样式

flag =rand.nextInt(120000)+1000;

appAd.setDisplayMills(flag+"");

flag=rand.nextInt(1);

if(flag==1){

appAd.setContentType(flag+"");

flag =rand.nextInt(6);

appAd.setItemId(flag+"");

}else{

appAd.setContentType(flag+"");

flag =rand.nextInt(1)+1;

appAd.setActivityId(flag+"");

}

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

return packEventJson("ad", jsonObject);

}

/**

* 启动日志

private static AppStartgenerateStart() {

AppStart appStart =new AppStart();

//设备id

appStart.setMid(s_mid +"");

s_mid++;

// 用户id

appStart.setUid(s_uid +"");

s_uid++;

// 程序版本号 5,6等

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

//程序版本名v1.1.1

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

// 安卓系统版本

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

//设置日志类型

appStart.setEn("start");

// 语言es,en,pt

int flag =rand.nextInt(3);

switch (flag) {

case (0):

appStart.setL("es");

break;

case (1):

appStart.setL("en");

break;

case (2):

appStart.setL("pt");

break;

}

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

appStart.setSr(getRandomChar(1));

// 区域

flag =rand.nextInt(2);

switch (flag) {

case 0:

appStart.setAr("BR");

case 1:

appStart.setAr("MX");

}

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

flag =rand.nextInt(3);

switch (flag) {

case 0:

appStart.setBa("Sumsung");

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

break;

case 1:

appStart.setBa("Huawei");

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

break;

case 2:

appStart.setBa("HTC");

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

break;

}

// 嵌入sdk的版本

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

// gmail

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

// 屏幕宽高hw

flag =rand.nextInt(4);

switch (flag) {

case 0:

appStart.setHw("640*960");

break;

case 1:

appStart.setHw("640*1136");

break;

case 2:

appStart.setHw("750*1134");

break;

case 3:

appStart.setHw("1080*1920");

break;

}

// 客户端产生日志时间

long millis = System.currentTimeMillis();

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

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

flag =rand.nextInt(3);

switch (flag) {

case 0:

appStart.setNw("3G");

break;

case 1:

appStart.setNw("4G");

break;

case 2:

appStart.setNw("WIFI");

break;

}

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

// 经度

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

// 纬度

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

// 入口

flag =rand.nextInt(5) +1;

appStart.setEntry(flag +"");

// 开屏广告类型

flag =rand.nextInt(2) +1;

appStart.setOpen_ad_type(flag +"");

// 状态

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

appStart.setAction(flag +"");

// 加载时长

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

// 失败码

flag =rand.nextInt(10);

switch (flag) {

case 1:

appStart.setDetail("102");

break;

case 2:

appStart.setDetail("201");

break;

case 3:

appStart.setDetail("325");

break;

case 4:

appStart.setDetail("433");

break;

case 5:

appStart.setDetail("542");

break;

default:

appStart.setDetail("");

break;

}

// 扩展字段

appStart.setExtend1("");

return appStart;

}

/**

* 消息通知

private static JSONObjectgenerateNotification() {

AppNotification appNotification =new AppNotification();

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

// 动作

appNotification.setAction(flag +"");

// 通知id

flag =rand.nextInt(4) +1;

appNotification.setType(flag +"");

// 客户端弹时间

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

// 备用字段

appNotification.setContent("");

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

return packEventJson("notification", jsonObject);

}

/**

* 后台活跃

private static JSONObjectgenerateBackground() {

AppActive_background appActive_background =new AppActive_background();

// 启动源

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

appActive_background.setActive_source(flag +"");

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

return packEventJson("active_background", jsonObject);

}

/**

* 错误日志数据

private static JSONObjectgenerateError() {

AppErrorLog appErrorLog =new AppErrorLog();

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

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"}; //错误详情

//错误摘要

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

//错误详情

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

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

return packEventJson("error", jsonObject);

}

/**

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

private static JSONObjectpackEventJson(String eventName, JSONObject jsonObject) {

JSONObject eventJson =new JSONObject();

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

eventJson.put("en", eventName);

eventJson.put("kv", jsonObject);

return eventJson;

}

/**

* 获取随机字母组合

* @param length 字符串长度

private static StringgetRandomChar(Integer length) {

StringBuilder str =new StringBuilder();

Random random =new Random();

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

// 字符串

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

}

return str.toString();

}

/**

* 获取随机字母数字组合

* @param length 字符串长度

private static StringgetRandomCharAndNumr(Integer length) {

StringBuilder str =new StringBuilder();

Random random =new Random();

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

boolean b = random.nextBoolean();

if (b) {// 字符串

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

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

}else {// 数字

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

}

return str.toString();

}

/**

* 收藏

private static JSONObjectgenerateFavorites() {

AppFavorites favorites =new AppFavorites();

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

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

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

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

return packEventJson("favorites", jsonObject);

}

/**

* 点赞

private static JSONObjectgeneratePraise() {

AppPraise praise =new AppPraise();

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

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

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

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

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

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

return packEventJson("praise", jsonObject);

}

/**

* 评论

private static JSONObjectgenerateComment() {

AppComment comment =new AppComment();

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

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

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

comment.setContent(getCONTENT());

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

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

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

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

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

return packEventJson("comment", jsonObject);

}

/**

* 生成单个汉字

private static char getRandomChar() {

String str ="";

int hightPos; //

int lowPos;

Random random =new Random();

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

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

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

byte[] b =new byte[2];

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

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

try {

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

}catch (UnsupportedEncodingException e) {

e.printStackTrace();

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

}

return str.charAt(0);

}

/**

* 拼接成多个汉字

private static StringgetCONTENT() {

StringBuilder str =new StringBuilder();

for (int i =0; i

str.append(getRandomChar());

}

return str.toString();

}

下面是bean对象，一个类对应一张表：