开发者社区> 问答> 正文

SDK for Java如何引入?

引入 POM 依赖

    <dependency>
      <groupId>com.aliyun.openservices</groupId>
      <artifactId>aliyun-log</artifactId>
      <version>0.6.6</version>
    </dependency>
开始一个 Java 程序

```java
public class LogstashForJavaDemo {
    public static void main(String[] args) throws LogException {
        DateFormat dateFormat = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        /**
         * endpoint: 数据写入存储所在区域
         * project,logstore: 构成基本数据存储目标
         * accessKeyId,accessKeySecret: 构成访问密钥
         *
         * 注意: 请用户根据实际情况填写
         */
        String endpoint = "cn-hangzhou.log.aliyuncs.com";
        String project = "proj-arms-7dd6ecb06d21e02aed9eeb56b79e9f";
        String logstore = "logstore-56f96ec5546fb6555ef97dd057acb4e9";
        String accessKeyId = "uamEirofbYdTLexL";
        String accessKeySecret = "PBjsdr2dggBoYBrrprc9w02tX9UxBH";
        int logGroupSize = 10;// 建议100-2000,每个batch发送数据上限
        List<String> examples = new ArrayList<String>();
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=杭州&eventTeyp=1&性别=1&价格=2140|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=家居&区域=上海&eventTeyp=3&性别=0&价格=8305|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=深圳&eventTeyp=3&性别=1&价格=7121|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=上海&eventTeyp=3&性别=1&价格=2917|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=上海&eventTeyp=1&性别=1&价格=4285|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=杭州&eventTeyp=3&性别=1&价格=7864|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=女装&区域=杭州&eventTeyp=5&性别=0&价格=2983|");
        examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=深圳&eventTeyp=5&性别=1&价格=3201|");
        // 构建一个客户端实例
        Client client = new Client(endpoint, accessKeyId, accessKeySecret);
        // 连续发送10个数据包,每个数据包有10条日志
        long currentTime = System.currentTimeMillis();
        String formatedTime = dateFormat.format(new Date(currentTime));
        for (int i = 0; i < 10; i++) {
            Vector<LogItem> logGroup = new Vector<LogItem>();
            for (int j = 0; j < logGroupSize; j++) {
                LogItem logItem = new LogItem();
                logItem.PushBack("content", formatedTime + examples.get(j % examples.size()) + UUID.randomUUID());
                logGroup.add(logItem);
            }
            PutLogsRequest req = new PutLogsRequest(project, logstore, "", "", logGroup);
            client.PutLogs(req);
        }
        System.out.println("send data success");
    }
}
```
重要参数说明

参数    说明
endpoint    数据写入区域(endpoint 列表)
accessKeyId    写入数据时的秘钥 id
accessKeySecret    写入数据时的秘钥密码
project    写入数据的 project id
logstore    写入数据的 logstore id
注意:

ARMS 颁发的 accessKeyId,accessKeySecret 非用户阿里云 AK/SK,需要从 ARMS 获取,请查阅读获取方式。
project id 和 logstore id 唯一确定一个数据源。

展开
收起
猫饭先生 2017-10-31 10:29:54 2840 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
The Reactive Cloud Native Arch 立即下载
JAVA开发手册1.5.0 立即下载