官方文档：
doc:http://udn.yyuap.com/doc/logstash-best-practice-cn/filter/index.html
code:https://github.com/elastic/logstash
一. 学习插件 Logstash HTTP input plugin
1 修改配置文件
input
{
http
{
host => "127.0.0.1"
port => 31311 #接受http请求
additional_codecs => {"application/json"=>"json"}
codec => "plain"
threads => 4
ssl => false
}
}
filter
{
#过滤不需要请求
}
output
{
stdout { codec => rubydebug}
}
logstash -f /home/wangchuanyi/ob_rel/logstash-5.4.1/config/logstashHttp.conf
2 curl测试
curl -H "content-type: application/json"
-XPUT 'http://127.0.0.1:31311/test/'
-d '{ "name" : "troy", "pwd" : "今天发苹果吃了 " }'
查看logstash日志：
logstash输出到屏幕上.png
总结：Flume 和logstash 都可以接受http请求 前者写代码 后者通过配置来控制
参考
1 https://www.elastic.co/blog/introducing-logstash-input-http-plugin#sthash.alyYTzAS.dpbs
2 http://www.cnblogs.com/xing901022/p/5256227.html
