美文网首页
Android 阿里云日志接入流程

Android 阿里云日志接入流程

作者: __素颜__ | 来源:发表于2019-10-12 13:58 被阅读0次

    参考文档：

    1.阿里云日志服务器Android SDK
    2.Android Demo
    3.中文版
    4.STS方式

    1.添加jar包

    把demo里面的jar包拷进自己项目,日志服务 Android SDK依赖于fastjson,greenDAO。

        compile 'com.alibaba:fastjson:1.2.35'
    compile 'org.greenrobot:greendao:3.2.2'
    compile files('libs/aliyun-log-sdk-android-2.1.0.jar')

    2.添加权限

    <uses-permission android:name="android.permission.INTERNET"></uses-permission>
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"></uses-permission>

    3.在application中初始化

    import com.aliyun.sls.android.sdk.SLSDatabaseManager;

public class MyApplication extends Application {
    @Override
    public void onCreate() {
        super.onCreate();

        SLSDatabaseManager.getInstance().setupDB(getApplicationContext());
    }
}

    然后在AndroidManifest.xml中<application android:name=".XXApplication /application>"

    4.向app服务器请求accessKeyId，secretKeyId，securityToken

    1.应用向用户的应用服务器申请一个临时访问凭证。
    Android/iOS应用不能直接存储AccessKeyID/AccessKeySecret，这样会存在泄密的风险。所以应用必须向用户的应用服务器申请一个临时上传凭证（下文将此临时上传凭证称为Token）。这个Token是有时效性的，如果这个Token的过期时间是30分钟（这个时间可以由应用服务器指定），那么在这30分钟里面，该Android/iOS应用可以使用这个Token访问日志服务， 30分钟后再重新获取。

    2.用户的应用服务器检测上述请求的合法性，然后返回Token给应用。

    3.手机拿到这个Token后就可以访问日志服务了。

    app服务器返回的数据格式样式：

    //正确返回
{
    "StatusCode":200,
    "AccessKeyId":"STS.3p***dgagdasdg",
    "AccessKeySecret":"rpnwO9***tGdrddgsR2YrTtI",
   "SecurityToken":"CAES+wMIARKAAZhjH0EUOIhJMQBMjRywXq7MQ/cjLYg80Aho1ek0Jm63XMhr9Oc5s˙∂˙∂3qaPer8p1YaX1NTDiCFZWFkvlHf1pQhuxfKBc+mRR9KAbHUefqH+rdjZqjTF7p2m1wJXP8S6k+G2MpHrUe6TYBkJ43GhhTVFMuM3BZajY3VjZWOXBIODRIR1FKZjIiEjMzMzE0MjY0NzM5MTE4NjkxMSoLY2xpZGSSDgSDGAGESGTETqOio6c2RrLWRlbW8vKgoUYWNzOm9zczoqOio6c2RrLWRlbW9KEDExNDg5MzAxMDcyNDY4MThSBTI2ODQyWg9Bc3N1bWVkUm9sZVVzZXJgAGoSMzMzMTQyNjQ3MzkxMTg2OTExcglzZGstZGVtbzI=",
   "Expiration":"2017-11-12T07:49:09Z",
}

//错误返回
{
    "StatusCode":500,
    "ErrorCode":"InvalidAccessKeyId.NotFound",
    "ErrorMessage":"Specified access key is not found."
}

    5.初始化LOGClient

    StsTokenCredentialProvider credentialProvider =
                new StsTokenCredentialProvider(accessKeyId, secretKeyId, securityToken);
        com.aliyun.sls.android.sdk.ClientConfiguration conf = new com.aliyun.sls.android.sdk.ClientConfiguration();
        conf.setConnectionTimeout(15 * 1000); // 连接超时，默认15秒
        conf.setSocketTimeout(15 * 1000); // socket超时，默认15秒
        conf.setMaxConcurrentRequest(5); // 最大并发请求书，默认5个
        conf.setMaxErrorRetry(2); // 失败后最大重试次数，默认2次
        conf.setCachable(false);
        conf.setConnectType(com.aliyun.sls.android.sdk.ClientConfiguration.NetworkPolicy.WWAN_OR_WIFI);
        SLSLog.enableLog(); // log打印在控制台
        logClient = new LOGClient(AppApplication.getContext(), endpoint, credentialProvider, conf);

    注意LOGClient的生命周期和app保持一致。

    6.异步发送日志

      // 1. 创建logGroup
        LogGroup logGroup = new LogGroup("sls test", TextUtils.isEmpty(ip) ? " no ip " : ip);

        // 2. 创建一条log
        Log log = new Log();
        log.PutContent("current time ", "" + System.currentTimeMillis() / 1000);
        log.PutContent("content", "this is a log");
        
        // 3. 将log加入到group
        logGroup.PutLog(log);

        // 4. 发送log到sls服务器
        try {
            PostLogRequest request = new PostLogRequest(project, logStore, logGroup);
            logClient.asyncPostLog(request, new CompletedCallback<PostLogRequest, PostLogResult>() {
                @Override
                public void onSuccess(PostLogRequest request, PostLogResult result) {
                    Message message = Message.obtain(handler);
                    message.what = HANDLER_MESSAGE_UPLOAD_SUCCESS;
                    message.sendToTarget();
                }

                @Override
                public void onFailure(PostLogRequest request, LogException exception) {
                    Message message = Message.obtain(handler);
                    message.what = HANDLER_MESSAGE_UPLOAD_FAILED;
                    message.obj = exception.getMessage();
                    message.sendToTarget();
                }
            });
        } catch (LogException e) {
            e.printStackTrace();
        }

    demo

    package com.qingclass.yiban.utils;

import android.content.Context;
import android.os.Message;

import com.alibaba.sdk.android.oss.ClientConfiguration;
import com.alibaba.sdk.android.oss.ClientException;
import com.alibaba.sdk.android.oss.OSS;
import com.alibaba.sdk.android.oss.OSSClient;
import com.alibaba.sdk.android.oss.ServiceException;
import com.alibaba.sdk.android.oss.callback.OSSCompletedCallback;
import com.alibaba.sdk.android.oss.callback.OSSProgressCallback;
import com.alibaba.sdk.android.oss.common.OSSLog;
import com.alibaba.sdk.android.oss.common.auth.OSSAuthCredentialsProvider;
import com.alibaba.sdk.android.oss.common.auth.OSSCredentialProvider;
import com.alibaba.sdk.android.oss.common.auth.OSSStsTokenCredentialProvider;
import com.alibaba.sdk.android.oss.model.PutObjectRequest;
import com.alibaba.sdk.android.oss.model.PutObjectResult;
import com.aliyun.sls.android.sdk.LOGClient;
import com.aliyun.sls.android.sdk.LogException;
import com.aliyun.sls.android.sdk.SLSLog;
import com.aliyun.sls.android.sdk.core.auth.PlainTextAKSKCredentialProvider;
import com.aliyun.sls.android.sdk.core.auth.StsTokenCredentialProvider;
import com.aliyun.sls.android.sdk.core.callback.CompletedCallback;
import com.aliyun.sls.android.sdk.model.Log;
import com.aliyun.sls.android.sdk.model.LogGroup;
import com.aliyun.sls.android.sdk.request.PostLogRequest;
import com.aliyun.sls.android.sdk.result.PostLogResult;
import com.qingclass.yiban.AppApplication;
import com.qingclass.yiban.api.IHomeApiService;
import com.qingclass.yiban.baselibrary.log.QCLog;
import com.qingclass.yiban.baselibrary.net.NetWorkingHelper;
import com.qingclass.yiban.baselibrary.net.entity.MAPIResult;
import com.qingclass.yiban.common.store.BasicConfigStore;
import com.qingclass.yiban.entity.home.StsBean;
import com.qingclass.yiban.entity.note.BookNoteBean;
import com.qingclass.yiban.ui.activity.home.HomeWriteNotesActivity;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

/**
 * 姓名：suyan
 * 类说明：阿里日志
 * <p>
 * STS方式:  https://help.aliyun.com/document_detail/62681.html
 * <p>
 * 调用：例如：SLSUtils.getInstance().requestData("测试内容",null);
 */

public class SLSUtils {
    private volatile static SLSUtils instance;

    public String project = "**********";
    public String logStore = "*********";
    //client的生命周期和app保持一致,
    public LOGClient logClient;

    public SLSUtils() {
    }

    public static SLSUtils getInstance() {
        if (instance == null) {//双重锁
            synchronized (SLSUtils.class) {
                if (instance == null) {
                    return new SLSUtils();

                }
            }
        }
        return instance;
    }

    /**
     * 1.初始化logClient
     *
     * @param accessKeyId   服务器下发的
     * @param secretKeyId   服务器下发的
     * @param securityToken 服务器下发的
     * @param endpoint      服务器下发的
     */
    private void setupSLSClient(String accessKeyId, String secretKeyId, String securityToken, String endpoint) {
        QCLog.e("suyan===========5");
        StsTokenCredentialProvider credentialProvider =
                new StsTokenCredentialProvider(accessKeyId, secretKeyId, securityToken);
        com.aliyun.sls.android.sdk.ClientConfiguration conf = new com.aliyun.sls.android.sdk.ClientConfiguration();
        conf.setConnectionTimeout(15 * 1000); // 连接超时，默认15秒
        conf.setSocketTimeout(15 * 1000); // socket超时，默认15秒
        conf.setMaxConcurrentRequest(5); // 最大并发请求书，默认5个
        conf.setMaxErrorRetry(2); // 失败后最大重试次数，默认2次
        conf.setCachable(false);
        conf.setConnectType(com.aliyun.sls.android.sdk.ClientConfiguration.NetworkPolicy.WWAN_OR_WIFI);
        SLSLog.enableLog(); // log打印在控制台
        logClient = new LOGClient(AppApplication.getContext(), endpoint, credentialProvider, conf);
    }

    /*
     *  2.发送日志
     * 推荐使用的方式，直接调用异步接口，通过callback 获取回调信息
     */
    private void asyncUploadLog(String accessKeyId, String secretKeyId, String securityToken, String endpoint, String logInfo, final SLSUtils.SLSUpCallback mSLSUpCallback) {
        QCLog.e("suyan===========4");
        setupSLSClient(accessKeyId, secretKeyId, securityToken, endpoint);
        // 1. 创建logGroup
        LogGroup logGroup = new LogGroup("sls test", logInfo);
        // 2. 创建一条log
        Log log = new Log();
        log.PutContent("current time ", "" + System.currentTimeMillis() / 1000);
        log.PutContent("content", "this is a log");
        // 3. 将log加入到group
        logGroup.PutLog(log);
        // 4. 发送log到sls服务器
        try {
            PostLogRequest request = new PostLogRequest(project, logStore, logGroup);
            logClient.asyncPostLog(request, new CompletedCallback<PostLogRequest, PostLogResult>() {
                @Override
                public void onSuccess(PostLogRequest request, PostLogResult result) {
                    if (mSLSUpCallback != null) {
                        QCLog.e("suyan===========7");
                        mSLSUpCallback.success();

                    }
                }

                @Override
                public void onFailure(PostLogRequest request, LogException exception) {
                    if (mSLSUpCallback != null) {
                        QCLog.e("suyan===========6");
                        mSLSUpCallback.failure();
                    }
                }
            });
        } catch (LogException e) {
            e.printStackTrace();
        }
    }

    /**
     * 4.上传成功与失败回掉
     */
    public interface SLSUpCallback {
        void success();

        void failure();
    }


    /**
     * 5.向服务器请求阿里日志上传密钥
     */
    public void requestData(String loginfo, final SLSUtils.SLSUpCallback mSLSUpCallback) {
        NetWorkingHelper.getInstance().getNetService(IHomeApiService.class).getSts("2", BasicConfigStore.getInstance(AppApplication.getContext()).getUserId() + "")
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<MAPIResult<StsBean>>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        QCLog.e("suyan===========1");
                    }

                    @Override
                    public void onNext(MAPIResult<StsBean> result) {
                        QCLog.e("suyan===========2");
                        if (result != null && result.isSuccess()) {
                            StsBean mStsBean = result.getData();
                            QCLog.e("suyan===========3");
                            asyncUploadLog(mStsBean.getAccessKeyId(), mStsBean.getAccessKeySecret(), mStsBean.getSecurityToken(), mStsBean.getEndPoint(), loginfo, mSLSUpCallback);
                        }
                    }

                    @Override
                    public void onError(Throwable e) {
                    }

                    @Override
                    public void onComplete() {
                    }
                });
    }
}

    相关文章

      网友评论

          本文标题：Android 阿里云日志接入流程

          本文链接：https://www.haomeiwen.com/subject/mirqmctx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|Android 阿里云日志接入流程|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！