Java中使用阿里云日志服务(SLS)的全过程_Java

引言

阿里云日志服务（sls）是一款针对日志数据的一站式服务，支持日志的采集、存储、查询与分析等功能。在 java 开发中，借助阿里云提供的官方 sdk，能便捷地将应用日志接入 sls。本文将从准备工作到核心操作，详细介绍 java 中使用 sls 的全过程。

一、准备工作：搭建 sls 使用基础环境

在编写代码前，需完成 sls 的前期配置与依赖引入，为后续开发做好铺垫。

1. 配置 sls 基础资源

创建 sls 项目与日志库：登录阿里云控制台，进入 “日志服务 sls” 页面。先创建一个 “项目”（project），项目需关联具体地域；再在项目下创建 “日志库”（logstore），日志库将用于存储实际的日志数据。
获取关键访问信息：
- accesskey：进入阿里云 “访问控制 ram” 控制台，创建或使用已有的 accesskey（包含 accesskey id 和 accesskey secret），需确保该 accesskey 拥有 sls 的操作权限（如日志写入、查询等）。
- endpoint：在 sls 项目详情页中获取 endpoint，格式通常为 “地域标识.log.aliyuncs.com”（例如：cn-beijing.log.aliyuncs.com，地域需与项目所在地域一致）。

2. 引入 sls java sdk 依赖

sls 提供了 java 语言的官方 sdk，通过 maven 或 gradle 可快速引入项目。以 maven 为例，在pom.xml中添加如下依赖（建议使用最新版本，可通过阿里云官方仓库查询最新版本号）：

<dependency>
    <groupid>com.aliyun.openservices</groupid>
    <artifactid>aliyun-log</artifactid>
    <version>0.6.69</version> <!-- 替换为最新版本 -->
</dependency>

二、核心操作：java 中 sls 的常用功能实现

完成基础准备后，通过 sdk 可实现日志发送、日志查询等核心操作，以下为具体实现步骤与示例。

1. 初始化 sls 客户端

所有 sls 操作都需通过client对象完成，初始化时需传入 endpoint、accesskey id 和 accesskey secret，代码如下：

import com.aliyun.openservices.log.client;

public class slsclientinit {
    // 替换为实际配置
    private static final string endpoint = "your_endpoint"; // 如：cn-beijing.log.aliyuncs.com
    private static final string access_key_id = "your_access_key_id";
    private static final string access_key_secret = "your_access_key_secret";
    private static final string project = "your_project_name"; // 项目名称
    private static final string log_store = "your_log_store_name"; // 日志库名称

    // 初始化客户端
    public static client getslsclient() {
        return new client(endpoint, access_key_id, access_key_secret);
    }
}

client对象是与 sls 服务交互的入口，后续的日志发送、查询等操作均需基于此对象。

2. 发送日志到 sls

应用运行中产生的日志，可通过 sdk 封装为logitem对象，再批量发送到 sls 日志库。每条logitem包含日志时间戳和若干键值对（日志字段与内容）。

实现步骤：

创建logitem列表，用于存放多条日志；
为每条logitem设置时间戳（单位：秒），并通过pushback方法添加日志字段（如日志级别、消息内容等）；
构建putlogsrequest请求，指定项目、日志库及日志列表；
调用client的putlogs方法发送日志。

示例代码：

import com.aliyun.openservices.log.client;
import com.aliyun.openservices.log.common.logitem;
import com.aliyun.openservices.log.exception.logexception;
import com.aliyun.openservices.log.request.putlogsrequest;
import com.aliyun.openservices.log.response.putlogsresponse;

import java.util.arraylist;
import java.util.list;

public class slslogsender {
    public static void main(string[] args) {
        // 获取sls客户端
        client client = slsclientinit.getslsclient();
        
        try {
            // 发送日志
            sendlogstosls(client);
        } catch (logexception e) {
            system.err.println("日志发送失败：" + e.getmessage());
            e.printstacktrace();
        }
    }

    /**
     * 向sls发送日志
     */
    private static void sendlogstosls(client client) throws logexception {
        // 1. 创建日志条目列表
        list<logitem> logitems = new arraylist<>();
        
        // 2. 添加普通info级别日志
        logitem infolog = new logitem((int)(system.currenttimemillis() / 1000)); // 时间戳（秒）
        infolog.pushback("level", "info");
        infolog.pushback("message", "用户登录成功");
        infolog.pushback("user_id", "user_123");
        infolog.pushback("action", "login");
        logitems.add(infolog);
        
        // 3. 添加error级别日志（示例多条日志）
        logitem errorlog = new logitem((int)(system.currenttimemillis() / 1000));
        errorlog.pushback("level", "error");
        errorlog.pushback("message", "数据库连接超时");
        errorlog.pushback("error_code", "db_timeout_001");
        errorlog.pushback("service", "order_service");
        logitems.add(errorlog);
        
        // 4. 构建发送请求
        putlogsrequest request = new putlogsrequest(
            slsclientinit.project,  // 项目名称
            slsclientinit.log_store, // 日志库名称
            "", // 日志主题（可选，无主题则留空）
            "", // 日志来源（可选，如应用服务器ip）
            logitems // 日志列表
        );
        
        // 5. 发送日志并获取响应
        putlogsresponse response = client.putlogs(request);
        system.out.println("日志发送成功！请求id：" + response.getrequestid());
    }
}

注意事项：

日志时间戳需精确到秒（logitem构造函数接收秒级时间戳）；
单条日志的字段数量建议控制在合理范围（避免过多字段影响查询效率）；
若需高频发送日志，可考虑批量攒批发送（减少请求次数）。

3. 从 sls 查询日志

除了发送日志，sls sdk 还支持从日志库中查询日志，可根据时间范围、关键词等条件筛选所需日志。

实现步骤：

构建getlogsrequest请求，指定查询的项目、日志库、时间范围、查询条件等；
调用client的getlogs方法执行查询，获取getlogsresponse响应；
从响应中解析日志数据（如日志时间、字段内容等）。

示例代码：

import com.aliyun.openservices.log.client;
import com.aliyun.openservices.log.common.logcontent;
import com.aliyun.openservices.log.common.logitem;
import com.aliyun.openservices.log.exception.logexception;
import com.aliyun.openservices.log.request.getlogsrequest;
import com.aliyun.openservices.log.response.getlogsresponse;

import java.util.list;

public class slslogquery {
    public static void main(string[] args) {
        client client = slsclientinit.getslsclient();
        
        try {
            // 查询最近15分钟的error级别日志
            querylogsfromsls(client);
        } catch (logexception e) {
            system.err.println("日志查询失败：" + e.getmessage());
            e.printstacktrace();
        }
    }

    /**
     * 从sls查询日志
     */
    private static void querylogsfromsls(client client) throws logexception {
        // 1. 计算查询时间范围（最近15分钟）
        long currenttime = system.currenttimemillis() / 1000; // 当前时间（秒）
        int fromtime = (int)(currenttime - 15 * 60); // 开始时间（15分钟前）
        int totime = (int)currenttime; // 结束时间（当前）
        
        // 2. 构建查询请求
        getlogsrequest request = new getlogsrequest(
            slsclientinit.project,
            slsclientinit.log_store,
            fromtime, // 开始时间戳（秒）
            totime,   // 结束时间戳（秒）
            "", // 日志主题（无则留空）
            "level:error", // 查询条件（sls查询语法，如“level:error and service:order_service”）
            100, // 最大返回日志条数
            0, // 偏移量（从第0条开始）
            false // 是否返回日志上下文（false则仅返回匹配日志）
        );
        
        // 3. 执行查询
        getlogsresponse response = client.getlogs(request);
        
        // 4. 解析并打印查询结果
        system.out.println("查询到" + response.getcount() + "条日志：");
        list<logitem> logitems = response.getlogs();
        for (logitem logitem : logitems) {
            system.out.println("\n日志时间：" + logitem.gettime()); // 时间戳（秒）
            list<logcontent> contents = logitem.getlogcontents();
            for (logcontent content : contents) {
                system.out.println(content.getkey() + "：" + content.getvalue());
            }
        }
    }
}

说明：

查询条件语法：支持类似 sql 的查询语法，例如level:error and error_code:db_timeout_001（查询级别为 error 且错误码为 db_timeout_001 的日志）；
分页查询：若日志量较大，可通过调整offset参数实现分页（如offset=100表示从第 100 条开始查询）。

4. 其他常用操作（扩展）

除了日志发送与查询，sls sdk 还支持创建日志库、删除日志等管理类操作，以下为部分示例：

创建日志库

import com.aliyun.openservices.log.request.createlogstorerequest;
import com.aliyun.openservices.log.exception.logexception;

// 在指定项目下创建日志库
public static void createlogstore(client client) throws logexception {
    // 参数：项目名称、日志库名称、数据保存时间（天）、分片数
    createlogstorerequest request = new createlogstorerequest(
        slsclientinit.project, "new_log_store", 30, 2
    );
    client.createlogstore(request);
    system.out.println("日志库创建成功");
}

删除日志库

import com.aliyun.openservices.log.request.deletelogstorerequest;
import com.aliyun.openservices.log.exception.logexception;

public static void deletelogstore(client client) throws logexception {
    deletelogstorerequest request = new deletelogstorerequest(
        slsclientinit.project, "log_store_to_delete"
    );
    client.deletelogstore(request);
    system.out.println("日志库删除成功");
}

三、总结

在 java 中使用阿里云日志服务（sls）的核心流程可概括为：准备 sls 资源与依赖→初始化客户端→调用 sdk 接口实现日志收发与管理。通过本文介绍的步骤，能快速将 java 应用与 sls 对接，实现日志的高效存储与灵活查询。

实际开发中，可根据业务需求扩展功能，例如结合 sls 的 “索引配置” 实现更精准的日志检索，或通过 “消费组” 实现日志的实时消费。

以上就是java中使用阿里云日志服务(sls)的全过程的详细内容，更多关于java使用阿里云日志服务sls的资料请关注代码网其它相关文章！

Java中使用阿里云日志服务(SLS)的全过程

2025年09月30日 • Java •我要评论

引言

一、准备工作：搭建 sls 使用基础环境

1. 配置 sls 基础资源

2. 引入 sls java sdk 依赖

二、核心操作：java 中 sls 的常用功能实现

1. 初始化 sls 客户端

2. 发送日志到 sls

实现步骤：

示例代码：

注意事项：

3. 从 sls 查询日志

实现步骤：

示例代码：

说明：

4. 其他常用操作（扩展）

创建日志库

删除日志库

三、总结

相关文章:

MyBatis延迟加载与多级缓存全解析

JAVA并发Monitor工作原理图解

发表评论


验证码：