普通消费

本示例中，创建一个PullLogsDemo.java文件，并调用接口读取日志数据，完成普通消费的演示。示例如下所示。关于日志服务SDK的更多信息，请参见日志服务SDK参考。

import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.Consts;
import com.aliyun.openservices.log.common.LogGroupData;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.request.PullLogsRequest;
import com.aliyun.openservices.log.response.PullLogsResponse;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

public class PullLogsDemo {
    // 日志服务的服务接入点。此处以杭州为例，其它地域请根据实际情况填写。
    private static final String endpoint = "cn-hangzhou.log.aliyuncs.com";
    // 本示例从环境变量中获取AccessKey ID和AccessKey Secret。
    private static final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
    // Project名称。
    private static final String project = "your_project";
    // Logstore名称。
    private static final String logStore = "your_logstore";

    public static void main(String[] args) throws Exception{

        // 创建日志服务Client。
        Client client = new Client(endpoint, accessKeyId, accessKeySecret);
        // 查询Logstore的Shard数量。
        int shardCount = client.GetLogStore(project, logStore).GetLogStore().GetShardCount();
        System.out.println(String.format("%s has %d shards", logStore, shardCount));

        // 从头开始消费，获取游标。（如果是从尾部开始消费，使用Consts.CursorMode.END）
        List<String> cursors = new ArrayList<String>(shardCount);
        for (int i = 0; i < shardCount; i++) {
            cursors.add(i, client.GetCursor(project, logStore, i, Consts.CursorMode.BEGIN).GetCursor());
        }
        // 按照Shard进行日志消费。
        try{
            do {
                for (int i = 0; i < shardCount; i++) {
                    // 从每个Shard中获取日志。
                    PullLogsRequest request = new PullLogsRequest(project, logStore, i, 1000, cursors.get(i));
                    PullLogsResponse response = client.pullLogs(request);
                    // 日志都在日志组（LogGroup）中，按照逻辑拆分即可。
                    List<LogGroupData> logGroups = response.getLogGroups();
                    System.out.println(String.format("Get %d logGroup from logStore:%s:\tShard:%d", logGroups.size(), logStore, i));
                    // 打印完成后，移动游标。
                    cursors.set(i, response.getNextCursor());
                }
                TimeUnit.SECONDS.sleep(3);
            } while (true);
        }catch (LogException e) {
            System.out.println("error code :" + e.GetErrorCode());
            System.out.println("error message :" + e.GetErrorMessage());
            throw e;
        }

    }
}