开发者社区> 问答> 正文

【阿里云产品公测】用SLS SDK搭建中转服务记录应用日志

用SLS记录应用日志


前言


应用里面报错是最为头疼的了。很多时候,程序猿为了省事,就直接来个console.log或者print之类的,好一点的写个类,然后以文件的形式写入到本地系统中。我想绝大多数程序猿都这么干的吧。然后想看日志的时候就登陆到服务器上,cat一下或者tail下,把日志打出来看。
如果只是个小网站,小应用还好说,可能只有一台服务器,登陆上去也简单。但如果网站变大了,服务器多了,难不成一台台登陆上去看么?如果想做个统计什么的,那估计要死人了。当然也有一些变通的办法,比如linux上的一些好用的工具什么的,或者也可以用一些软件搭建自己的日志收集平台,不过,都不如阿里云的SLS来得快速方便。


SLS的优势

  • 有logtail类的客户端支持,可以快速配置,收集日志
  • 不用自己搭建日志收集平台,有现成的平台可用
  • 有SDK可用,自己可以定义更加丰富的收集内容
  • 查询语法支持AND、OR等操作符,能实时查询

SLS的使用


本例是拿Java SDK来收集应用的错误日志。
首先吐槽下,阿里云的SLS目前只有Java的SDK,没有其他语言的SDK,对于我这种从来没写过Java代码的程序猿来说,上手有点难。好在有其他语言的经验,根据SDK的sample,硬是憋出了一个简单的收集服务来。
我的应用使用的程序是NodeJS或者PHP,既然没有对应的SDK,我能想到的是使用SLS的Java的SDK做一个简单的HTTP服务,供我的NodeJS和PHP调用。在NodeJS和PHP内封装好对应的日志类,有错误,通过http post的形式发送到Java SDK写的http server上,然后这个http server使用Java SDK将日志发送到SLS。
所以,作为程序猿,不得不再次吐槽下SLS的SDK,实在太少,如果阿里云的工程师太忙没时间写其他语言的SDK,至少把API开放出来,我相信开源社区肯定有很多人会贡献出相应的SDK的。
因为不懂Java,写这个http server费了不少时间,懂的人,可能很快用jetty等弄好了,但是我没用过,所以在网上找了一些现成的代码来处理http请求。以下都是我的个人理解,如果有哪些地方不对,还请Java大牛指正,毕竟这是我第一次写Java代码。
首先,我使用了sun.net包里面的httpserver:
  
public static void main(String args[]) throws IOException,
            InterruptedException {

        HttpServer server = HttpServer.create(new InetSocketAddress(8080), 8080);
        HttpContext context = server.createContext("/", new LogHandler());
        context.getFilters().add(new ParameterFilter());
        server.setExecutor(null); // creates a default executor
        server.start();

    }





ParameterFilter这个类是用来实现对请求的处理的,限于篇幅,我就不贴出代码了。大家在网上都可以搜到很多实例代码。
接下来就是实现对应的LogHandler类,用来处理/这个路由下的请求。因为我这个http server不做别的,就做这个简单的事情,所以我就直接用了/这个路由。LogHandler类需要实现handle方法,用来处理请求。为了简单,我直接在这里面初始化了SLS的SDK:

String accessId = "这里是你阿里云的accessID,可以在用户中心查看";
        String accessKey = "这里是你阿里云的accessKey,可以在用户中心查看";

        String project = "testproject";
        String host = "http://cn-hangzhou.sls.aliyuncs.com";
        // or create a client with a setting endpoint address
        SLSClient client = new SLSClient(accessId, accessKey, host);
        // generate two logs

        Vector<LogItem> logGroup = new Vector<LogItem>();
        LogItem logItem = new LogItem((int) (new Date().getTime() / 1000));





这里基本参照SDK的sample来做就行了。然后需要记录你想记录的日志字段,比如我这里需要记录user的id:


logItem.PushBack("userId", (String) params.get("userId"));




这样就把需要的字段加入到logItem里面了。等把需要的字段都加入到logItem后,需要将这个item加入到Group中:
logGroup.add(logItem);


这一步我其实不是很理解,毕竟那个SDK的api文档看的云里雾里的,应该是可以多个item放在一个group里面发送给sls。大家可以自己试验下。
最后,使用client的PutData方法将数据发送给SLS:
client.PutData(project, "这里是Category的名字", "", logGroup);


第三个参数我没太看懂是什么,不过貌似不影响使用。第二个是Category,就是在SLS的project下看到的类目列表。
发送出去后,http server需要告诉应用发送成功了,http server得有返回值嘛,要不然就一起卡那儿等超时了。
String response = "{\"result\": true}";
t.sendResponseHeaders(200, response.length());
OutputStream os = t.getResponseBody();
os.write(response.getBytes());
os.close();



为了方便,我使用的是json格式返回的,方便其他语言解析。
好了,到此这个SLS的logger服务就做好了,接下来是需要编译。这也是Java的麻烦之处。SLS的SDK是放在了maven库里面,所以需要配置pom.xml来编译。你的pom文件应该有:
<dependencies>
        <dependency>
            <groupId>com.aliyun.openservices</groupId>
            <artifactId>aliyun-openservices-sls-v0.3</artifactId>
            <version>0.1.0</version>
        </dependency>
    </dependencies>



还想吐槽下,这个SDK的名字里面有个v0.3,下面的version还是0.1.0,让人甚是奇怪,搞两个version是干嘛的?
因为我用的是idea编辑器,可以直接在编辑器里面make project,把这个服务编译好。最后编译出来的是一个jar文件,直接把这个jar扔到ecs上运行即可。前提是需要安装好java环境。
这样,我们就在ECS上启动了一个SLS的中转服务。地址是127.0.0.1:8080,应用只需要向这个程序post数据即可。
比如NodeJS可以单独写一个错误处理的模块:
var request = require("request");
        request.post("http://127.0.0.1:8080", { form: { "userId": "xxxxx" } }, function(err, response, body){
            if(!err && response && response.statusCode === 200 && body){
                var result = JSON.parse(body);
                if(result.result !== true){
                    console.log(result.code);
                }
            }
            if(callback){
                callback(err, body);
            }
        });


这样,就可以把日志通过我们写的SLS中转服务发送到SLS中了。
虽然我不懂Java,但是还是可以通过SDK的sample快速弄出来一个中转服务,服务于自己的其他应用,所以,SLS SDK上手应该还是很快的。大家也可以尝试自己写一个试一试。


最后,还是建议SLS多一些其他语言的SDK,方便用户使用。

展开
收起
橘子 2014-11-05 21:03:57 15190 0
1 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Python第四讲——使用IPython/Jupyter Notebook与日志服务玩转超大规模数据分析与可视化 立即下载
大规模日志数据平台架构面临的问题与挑战 立即下载
一个跨平台的云服务SDK需要什么 立即下载