<dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>aliyun-log</artifactId>
    <version>0.6.69</version> <!-- 替換為最新版本 -->
</dependency>

import com.aliyun.openservices.log.Client;

public class SLSClientInit {
    // 替換為實(shí)際配置
    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"; // 項(xiàng)目名稱
    private static final String LOG_STORE = "your_log_store_name"; // 日志庫(kù)名稱

    // 初始化客戶端
    public static Client getSLSClient() {
        return new Client(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
    }
}

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 {
            // 發(fā)送日志
            sendLogsToSLS(client);
        } catch (LogException e) {
            System.err.println("日志發(fā)送失敗：" + e.getMessage());
            e.printStackTrace();
        }
    }

    /**
     * 向SLS發(fā)送日志
     */
    private static void sendLogsToSLS(Client client) throws LogException {
        // 1. 創(chuàng)建日志條目列表
        List<LogItem> logItems = new ArrayList<>();
        
        // 2. 添加普通INFO級(jí)別日志
        LogItem infoLog = new LogItem((int)(System.currentTimeMillis() / 1000)); // 時(shí)間戳（秒）
        infoLog.PushBack("level", "INFO");
        infoLog.PushBack("message", "用戶登錄成功");
        infoLog.PushBack("user_id", "user_123");
        infoLog.PushBack("action", "login");
        logItems.add(infoLog);
        
        // 3. 添加ERROR級(jí)別日志（示例多條日志）
        LogItem errorLog = new LogItem((int)(System.currentTimeMillis() / 1000));
        errorLog.PushBack("level", "ERROR");
        errorLog.PushBack("message", "數(shù)據(jù)庫(kù)連接超時(shí)");
        errorLog.PushBack("error_code", "DB_TIMEOUT_001");
        errorLog.PushBack("service", "order_service");
        logItems.add(errorLog);
        
        // 4. 構(gòu)建發(fā)送請(qǐng)求
        PutLogsRequest request = new PutLogsRequest(
            SLSClientInit.PROJECT,  // 項(xiàng)目名稱
            SLSClientInit.LOG_STORE, // 日志庫(kù)名稱
            "", // 日志主題（可選，無(wú)主題則留空）
            "", // 日志來(lái)源（可選，如應(yīng)用服務(wù)器IP）
            logItems // 日志列表
        );
        
        // 5. 發(fā)送日志并獲取響應(yīng)
        PutLogsResponse response = client.PutLogs(request);
        System.out.println("日志發(fā)送成功！請(qǐng)求ID：" + response.GetRequestId());
    }
}

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級(jí)別日志
            queryLogsFromSLS(client);
        } catch (LogException e) {
            System.err.println("日志查詢失敗：" + e.getMessage());
            e.printStackTrace();
        }
    }

    /**
     * 從SLS查詢?nèi)罩?
     */
    private static void queryLogsFromSLS(Client client) throws LogException {
        // 1. 計(jì)算查詢時(shí)間范圍（最近15分鐘）
        long currentTime = System.currentTimeMillis() / 1000; // 當(dāng)前時(shí)間（秒）
        int fromTime = (int)(currentTime - 15 * 60); // 開(kāi)始時(shí)間（15分鐘前）
        int toTime = (int)currentTime; // 結(jié)束時(shí)間（當(dāng)前）
        
        // 2. 構(gòu)建查詢請(qǐng)求
        GetLogsRequest request = new GetLogsRequest(
            SLSClientInit.PROJECT,
            SLSClientInit.LOG_STORE,
            fromTime, // 開(kāi)始時(shí)間戳（秒）
            toTime,   // 結(jié)束時(shí)間戳（秒）
            "", // 日志主題（無(wú)則留空）
            "level:ERROR", // 查詢條件（SLS查詢語(yǔ)法，如“l(fā)evel:ERROR AND service:order_service”）
            100, // 最大返回日志條數(shù)
            0, // 偏移量（從第0條開(kāi)始）
            false // 是否返回日志上下文（false則僅返回匹配日志）
        );
        
        // 3. 執(zhí)行查詢
        GetLogsResponse response = client.GetLogs(request);
        
        // 4. 解析并打印查詢結(jié)果
        System.out.println("查詢到" + response.GetCount() + "條日志：");
        List<LogItem> logItems = response.GetLogs();
        for (LogItem logItem : logItems) {
            System.out.println("\n日志時(shí)間：" + logItem.GetTime()); // 時(shí)間戳（秒）
            List<LogContent> contents = logItem.GetLogContents();
            for (LogContent content : contents) {
                System.out.println(content.GetKey() + "：" + content.GetValue());
            }
        }
    }
}

import com.aliyun.openservices.log.request.CreateLogStoreRequest;
import com.aliyun.openservices.log.exception.LogException;

// 在指定項(xiàng)目下創(chuàng)建日志庫(kù)
public static void createLogStore(Client client) throws LogException {
    // 參數(shù)：項(xiàng)目名稱、日志庫(kù)名稱、數(shù)據(jù)保存時(shí)間（天）、分片數(shù)
    CreateLogStoreRequest request = new CreateLogStoreRequest(
        SLSClientInit.PROJECT, "new_log_store", 30, 2
    );
    client.CreateLogStore(request);
    System.out.println("日志庫(kù)創(chuàng)建成功");
}

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("日志庫(kù)刪除成功");
}