普通消费

本示例中，创建一个PullLogsDemo.java文件，并调用接口读取日志数据，完成普通消费的演示。示例如下：

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。更多信息，请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。
    private static final String accessKeyId = "your_access_id";
    private static final String accessKeySecret = "your_access_key";
    //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;
        }

    }
}

更多关于日志服务SDK的信息请参见日志服务SDK参考。