094实战关于js SDK的程序，java SDK的程序

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

一：JS SDK

1.修改配置workspace

2.导入

3.Demo.html

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>测试页面1</title>

<script type="text/javascript" src="./js/analytics.js"></script>
</head>
<body>
测试页面1<br/>
跳转到:
<a href="demo.html">demo</a>
<a href="demo2.html">demo2</a>
<a href="demo3.html">demo3</a>
<a href="demo4.html">demo4</a>
</body>
</html>

4.效果

5.产生新的日志

tail -f access.log

二：重点

1.关于js的产生

参考程序analytics.js的JS SDK

2.同时在access.log收集日志

三：JAVA SDK

1.原理图

2.程序的重点

将日志数据发送到队列

取数据，将数据发送到nginx服务器

3.程序AnalyticsEngineSDK

package com.ibeifeng.sdk.java.logmake; import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger; /**
* 分析引擎sdk java服务器端数据收集
*
* @author ibeifeng
* @version 1.0
*
*/
public class AnalyticsEngineSDK {
// 日志打印对象
private static final Logger log = Logger.getGlobal();
// 请求url的主体部分
public static final String accessUrl = "http://linux-hadoop3.ibeifeng.com/BEIfeng.gif";
private static final String platformName = "java_server";
private static final String sdkName = "jdk";
private static final String version = "1"; /**
* 触发订单支付成功事件，发送事件数据到服务器
*
* @param orderId
* 订单支付id
* @param memberId
* 订单支付会员id
* @return 如果发送数据成功(加入到发送队列中)，那么返回true；否则返回false(参数异常&添加到发送队列失败).
*/
public static boolean onChargeSuccess(String orderId, String memberId) {
try {
if (isEmpty(orderId) || isEmpty(memberId)) {
// 订单id或者memberid为空
log.log(Level.WARNING, "订单id和会员id不能为空");
return false;
}
// 代码执行到这儿，表示订单id和会员id都不为空。
Map<String, String> data = new HashMap<String, String>();
data.put("u_mid", memberId);
data.put("oid", orderId);
data.put("c_time", String.valueOf(System.currentTimeMillis()));
data.put("ver", version);
data.put("en", "e_cs");
data.put("pl", platformName);
data.put("sdk", sdkName);
// 创建url
String url = buildUrl(data);
// 发送url&将url加入到队列
SendDataMonitor.addSendUrl(url);
return true;
} catch (Throwable e) {
log.log(Level.WARNING, "发送数据异常", e);
}
return false;
} /**
* 触发订单退款事件，发送退款数据到服务器
*
* @param orderId
* 退款订单id
* @param memberId
* 退款会员id
* @return 如果发送数据成功，返回true。否则返回false。
*/
public static boolean onChargeRefund(String orderId, String memberId) {
try {
if (isEmpty(orderId) || isEmpty(memberId)) {
// 订单id或者memberid为空
log.log(Level.WARNING, "订单id和会员id不能为空");
return false;
}
// 代码执行到这儿，表示订单id和会员id都不为空。
Map<String, String> data = new HashMap<String, String>();
data.put("u_mid", memberId);
data.put("oid", orderId);
data.put("c_time", String.valueOf(System.currentTimeMillis()));
data.put("ver", version);
data.put("en", "e_cr");
data.put("pl", platformName);
data.put("sdk", sdkName);
// 构建url
String url = buildUrl(data);
// 发送url&将url添加到队列中
SendDataMonitor.addSendUrl(url);
return true;
} catch (Throwable e) {
log.log(Level.WARNING, "发送数据异常", e);
}
return false;
} /**
* 根据传入的参数构建url
*
* @param data
* @return
* @throws UnsupportedEncodingException
*/
private static String buildUrl(Map<String, String> data) throws UnsupportedEncodingException {
StringBuilder sb = new StringBuilder();
sb.append(accessUrl).append("?");
for (Map.Entry<String, String> entry : data.entrySet()) {
if (isNotEmpty(entry.getKey()) && isNotEmpty(entry.getValue())) {
// key和value不为空
sb.append(entry.getKey().trim()).append("=").append(URLEncoder.encode(entry.getValue().trim(), "utf-8"))
.append("&");
// 解码
// URLDecoder.decode("需要解码的内容", "utf-8");
}
}
return sb.substring(0, sb.length() - 1);// 去掉最后&
} /**
* 判断字符串是否为空，如果为空，返回true。否则返回false。
*
* @param value
* @return
*/
private static boolean isEmpty(String value) {
return value == null || value.trim().isEmpty();
} /**
* 判断字符串是否非空，如果不是空，返回true。如果是空，返回false。
*
* @param value
* @return
*/
private static boolean isNotEmpty(String value) {
return !isEmpty(value);
}
}

4.程序SendDataMonitor

package com.ibeifeng.sdk.java.logmake; import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.logging.Level;
import java.util.logging.Logger; /**
* 发送url数据的监控者，用于启动一个单独的线程来发送数据
*
* @author ibeifeng
*
*/
public class SendDataMonitor {
// 日志记录对象
private static final Logger log = Logger.getGlobal();
// 队列，用户存储发送url，并发控制的Int.maxSize大小的阻塞队列
private BlockingQueue<String> queue = new LinkedBlockingQueue<String>();
// 用于单列的一个类对象
private static SendDataMonitor monitor = null; private SendDataMonitor() {
// 私有构造方法，进行单列模式的创建
} /**
* 获取单例的monitor对象实例
*
* @return
*/
public static SendDataMonitor getSendDataMonitor() {
if (monitor == null) {
synchronized (SendDataMonitor.class) {
if (monitor == null) {
monitor = new SendDataMonitor(); Thread thread = new Thread(new Runnable() { @Override
public void run() {
// 线程中调用具体的处理方法
SendDataMonitor.monitor.run();
}
});
// 测试的时候，不设置为守护模式
// thread.setDaemon(true);
thread.start();
}
}
}
return monitor;
} /**
* 添加一个url到队列中去
*
* @param url
* @throws InterruptedException
*/
public static void addSendUrl(String url) throws InterruptedException {
getSendDataMonitor().queue.put(url);
} /**
* 具体执行发送url的方法
*
*/
private void run() {
while (true) {
try {
// take 方法是阻塞方法，队列上有数据则取出，队列上没有数据则等待
String url = this.queue.take();
// 正式的发送url
HttpRequestUtil.sendData(url);
} catch (Throwable e) {
log.log(Level.WARNING, "发送url异常", e);
}
}
} /**
* 内部类，用户发送数据的http工具类
*
* @author ibeifeng
*
*/
public static class HttpRequestUtil {
/**
* 具体发送url的方法
*
* @param url
* @throws IOException
*/
public static void sendData(String url) throws IOException {
HttpURLConnection con = null;
BufferedReader in = null; try {
URL obj = new URL(url); // 创建url对象
con = (HttpURLConnection) obj.openConnection(); // 打开url连接
// 设置连接参数
con.setConnectTimeout(5000); // 连接过期时间
con.setReadTimeout(5000); // 读取数据过期时间
con.setRequestMethod("GET"); // 设置请求类型为get System.out.println("发送url:" + url);
// 发送连接请求
in = new BufferedReader(new InputStreamReader(con.getInputStream()));
// TODO: 这里考虑是否可以
} finally {
try {
if (in != null) {
in.close();
}
} catch (Throwable e) {
// nothing
}
try {
con.disconnect();
} catch (Throwable e) {
// nothing
}
}
}
}
}

5.测试

6.结果

7.程序Test

package com.ibeifeng.sdk.java.logmake.test; import java.util.HashSet;
import java.util.Random;
import java.util.Set; import com.ibeifeng.sdk.java.logmake.AnalyticsEngineSDK; public class Test {
private static Random random = new Random(System.currentTimeMillis());
private static Set<Order> orders = new HashSet<>(); public static void main(String[] args) throws InterruptedException {
Order order = null;
while (true) {
order = getSuccessOrder();
// 发送订单付款行为数据
AnalyticsEngineSDK.onChargeSuccess(order.orderId, order.memberId);
Thread.sleep(random.nextInt(500));
if (random.nextInt(100) > 75) {
// 25%的订单发生退款行为
order = getRefundOrder();
if (order != null) {
// 发送订单退款行为数据
AnalyticsEngineSDK.onChargeRefund(order.orderId, order.memberId);
Thread.sleep(random.nextInt(500));
}
}
}
} private static Order getSuccessOrder() {
while (true) {
int orderId = random.nextInt(Math.max(200000, orders.size() * 2));
Order order = new Order();
order.orderId = "orderid" + orderId;
if (!orders.contains(order)) {
// 该order是一个新的order对象
order.memberId = "ibeifeng" + random.nextInt(1000);
orders.add(order);
return order;
}
}
} private static Order getRefundOrder() {
int count = 0;
Order[] os = orders.toArray(new Order[0]);
while (true) {
count++;
int index = random.nextInt(os.length); // 获取下标位置
Order order = os[index]; // 获取对应下标位置的数据
if (!order.refund) {
order.refund = true; // 设置为已经退款操作
return order;
} else if (count >= os.length) {
// 设置最多重试次数
return null;
}
}
} static class Order {
public String orderId;
public String memberId;
public boolean refund = false; @Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((orderId == null) ? 0 : orderId.hashCode());
return result;
} @Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null)
return false;
if (getClass() != obj.getClass())
return false;
Order other = (Order) obj;
if (orderId == null) {
if (other.orderId != null)
return false;
} else if (!orderId.equals(other.orderId))
return false;
return true;
}
}
}