落叶下的光-CSDN博客

原创 storm发送数据到redis中

storm发送数据到redis中依赖<dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>1.1.1</version></depende

2018-10-19 17:59:35 1380

原创 influxDB的端口和配置

influxDB的端口和配置此文档包含infuxDB的常用信息,比如:监控的端口,配置文件位置,常用的配置等,方便以后查找和修改.端口默认influxDB使用以下端口8086: 用于客户端和服务端交互的HTTP API8088: 用于提供备份和恢复的RPC服务配置配置文件通过安装包安装,在linux上默认位置:/etc/influxdb/influxdb.conf查...

2018-10-19 17:58:51 16030 11

原创 influxDB HTTP API使用

influxDB HTTP API使用数据库操作# 创建数据库curl -i -XPOST http://localhost:8086/query --data-urlencode "q=CREATE DATABASE mydb"# 查看数据库curl -G 'http://localhost:8086/query?pretty=true' --data-urlencode "db=my...

2018-10-19 17:58:28 10494

原创 influxDB命令行基本使用

influxDB命令行基本使用通过命令行可以连接influxDB,类似于mysql的命令行工具连接数据库数据库安装在本机:influx -precision rfc3339连接远程数据库influx -host sample.host -precision rfc3339参数:-precision为设置显示时间格式,如果没有设置,返回的时间类型字段显示为时间戳,使用rfc33...

2018-10-19 17:58:04 15384

原创 influxDB的介绍和安装

influxDB介绍(翻译自官网)InfluxDB是一个时间序列数据库，旨在处理高写入和查询负载。它是TICK堆栈的组成部分。 InfluxDB旨在用作涉及大量带时间戳数据的任何用例的后备存储，包括DevOps监控，应用程序指标，物联网传感器数据和实时分析。以下是InfluxDB目前支持的一些功能，使其成为处理时间序列数据的绝佳选择:专为时间序列数据编写的自定义高性能数据存储。 TSM...

2018-10-19 17:50:37 372

翻译 RBMQ消息的消费,确认,防丢失

RBMQ消息的消费,确认,防丢失参考翻译自: RabbitMQ官网向多消费者分发消息当有多个消费者时:使用Round-robin方法,也就是循环发送,一个消息发送给一个消费者,下一条消息发送给下一个消费者,依次循环.每个消息只发送给一个消费者消息确认机制每个消费者消费后,需要反馈给MQ,确认消息已经被消费,MQ可以删除掉如果一个消费者挂掉(channel关闭,connect...

2018-10-19 17:49:30 1431

翻译 RBMQ发布和订阅消息

RBMQ发布和订阅消息exchange参考翻译自: RabbitMQ官网生产者并非将消息直接发送到queue,而是发送到exchange中,具体将消息发送到特定的队列还是多个队列,或者是丢弃,取决于exchange的类型exchange的类型directtopicheadersfanoutbindings(绑定队列)当生产/消费exchange时,可以绑定队列到excha...

2018-10-19 17:48:23 2015

原创 lua基础使用

lua 基础变量#####三种类型：全局变量局部变量表中的域。Lua 中的变量全是全局变量，那怕是语句块或是函数里，除非用 local 显式声明为局部变量。默认值为 nil赋值a = "hello" .. "hello"a,b = 10, 2a,b = b, a索引t[i]t.i -- 当索引为字符串类型时的一种简化写法get...

2018-10-19 17:45:45 176

contextgolang 中的创建一个新的 goroutine , 并不会返回像c语言类似的pid，所有我们不能从外部杀死某个goroutine，所有我就得让它自己结束，之前我们用 channel ＋ select 的方式，来解决这个问题，但是有些场景实现起来比较麻烦，例如由一个请求衍生出的各个 goroutine 之间需要满足一定的约束关系，以实现一些诸如有效期，中止routine树，传递请...

2018-10-19 17:45:03 649

原创 go应用性能分析

性能分析对golang应用运行时占用内存和cpu的大小和时间进行统计分析工具go自带 net/http/pprof方法web应用运行时开启监控_ "net/http/pprof"go func() { log.Println(http.ListenAndServe("localhost:6060", nil))}()使用beego 自带了这个功能,需要配置如下:...

2018-10-19 17:44:14 636

原创 kafka的go版本api使用

概述go语言版本的kafakaAPI准备golangsarama简单使用生产和消费的过程都是通过一个配置开始的.生产者//设置配置 config := sarama.NewConfig() //等待服务器所有副本都保存成功后的响应 config.Producer.RequiredAcks = sarama.WaitForAll //随机的分区类型 con

2017-11-30 13:29:36 20429 2

原创 log4net之syslog和logstash结合

概述使用log4net通过网络传输syslog日志配置<?xml version="1.0" encoding="utf-8" ?><configuration> <configSections> <section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/> <

2017-11-27 16:18:36 1923 1

原创 logstash使用之日期处理

概述日期插件Date filter plugin用于对logstash接收到的字段中的日期进行处理,可以使用处理后的日期作为logstash的timestamp.日期进行处理后,可以在kibana中用于统计和分析.参考logstash帮助文档简单使用input{ stdin{ }}filter{ date{ match => ["messa

2017-11-24 13:50:45 17009

原创 logstash使用之简单使用

概述logstash作为日志消息的中间件,获取数据后经过过滤再发送到别的地方.简单实用比如,获取数据从控制台,然后输出到控制台.编写配置文件log_std.confinput{ stdin{}}output{ stdout{}}stdin/stdout: 为控制台的输入和输出测试配置文件通过命令测试配置文件是否正确:bin/logstash -f first

2017-11-24 11:15:03 1199

原创 logstash配置之自动重载配置文件

自动重新加载配置为了可以自动检测配置文件的变动和自动重新加载配置文件,需要在启动的时候使用以下命令:./bin/lagstash -f configfile.conf --config.reload.automatic默认,检测配置文件的间隔时间是3秒,可以通过以下命令改变--config.reload.interval <second>如果已经运行了没有提供自动重启的logstash,可以发送一个

2017-11-24 11:13:28 20519 1

原创 logstash使用之json输入输出

概述如果发送给logstash的数据内容为json格式,那么可以通过解析json内容,根据具体内容生成字段.方便分析和储存,比如:有一个json内容为: {"name":"nihao"},我们需要获取这个记录然后通过logstash分析后,放到mysql数据库中.一个简单的logstash输出内容为:{ "@version" => "1", "host" => "lo

2017-11-24 11:08:38 19851 1

原创 logstash使用之输入阶段和过滤阶段处理数据的区别

概述阅读此文之前,先阅读logstash入门之工作流程,了解下codec和filter.codec相当于一个编码解码的工具.对输入和输出的数据进行处理,而filter中也有好多类似于这个功能的插件.比如: * codec中有json codec plugin,filter中有json filter plugincodec作用于输入阶段可以对输入的内容比如json进行解析,而filter中同样也有可

2017-11-24 11:06:57 3538

原创 logstash入门之工作流程

概述logstash 执行分为三个阶段:input -> filter -> output.input阶段生成事件,过滤阶段修改事件内容,输出阶段将内容输出到别的地方 .input和output支持codec(编码).codec可以将输入的内容解码,输出的内容编码.这样可以不用使用filter阶段的编码过滤器.Inputs使用Inputs获取数据到logstash中,比如: * file: 从文

2017-11-24 11:04:39 950

翻译消息日志标准之syslog

参考Wikipedia-syslog摘要syslog是一个消息日志的标准.允许软件生成消息交由系统储存,再由别的软件进行传达和分析.组成Facility : 设备标识,指明生成日志的软件标识Severity level : 日志级别Message : 消息Facility表明生成日志的程序类型,不同类型可能会有不同的处理方式,下面是可用设备标识列表(定义在RFC 3164) Facili

2017-11-23 18:39:33 3560

原创 lua自定义迭代器

自定义迭代器#!/usr/bin/luatab = { i = 0, name = "Nihao", age = 23}function getName(self) self.i = self.i + 1 if self.i > 2 then return nil end return "name", self.nameendlocal met

2017-11-23 18:35:40 386

原创 lua的元表

概述Lua 提供了元表(Metatable)，允许我们改变table的行为，每个行为关联了对应的元方法。本质元表本质为给table添加了一个键值对,键为__metatable,值为一个表,当对原始表操作的时候,就会去这个表中找键值对,比如__index,__call等键,然后找到对应的值,值可以是一个值或方法,结构大致如下:{ "name": "hewe", "age": 12,

2017-11-23 18:35:01 283

原创 lua语法糖

moduleName:func(param)当调用一个模块的方法时,需要把自己作为参数比如:function getName(self) return self.nameendperson.getName(person)每次这样写比较麻烦,所以使用:,省略了self参数:function getName(self) return self.nameendperson:getNam

2017-11-23 18:34:18 2425

原创 lua函数之load

load 用于加载一个数据块.从字符串或者函数中加载一个代码块为方法并返回.name = "zhang"local localname = "hewe"local content = [[ print("nihao") local parms = name print(#parms)]]--不要忘了最后加()assert(loadstring(content)

2017-11-23 18:32:36 12104

原创 lua模块之cjson模块-json解析

lua json的解析和编译参考lua-cjson-manuallua-cjson摘要(Synopsis)local cjson = require "cjson"-- Module instantiation-- 实例化模块local cjson2 = cjson.new()local cjson_safe = require "cjson.safe"-- Translate Lua

2017-11-23 18:29:00 11726

原创 golang sync.Cond的介绍和源码观察

sync.Cond方法介绍,Cond用于在并发环境下routine的等待和通知

2017-07-24 14:11:19 3168 1

原创 golang 字符串中的双引号显示

golang 字符串中的双引号显示字符串中的双引号显示本人已知有以下几种方法：不带双引号字符串str1 := "www.hewe.vip"fmt.Println(len(str1))fmt.Println(str1)//输出结果12www.hewe.vip使用反引号str2 := `"www.hewe.vip"`fmt.Println(len(str2))fmt.Println(s

2017-07-21 13:47:20 25722 1

原创 mybatis源码之解析xml文件

解析xml文件(简单版)简述本文是对mybatis解析xml文件的简单版,目的是为了能初步了解mybatis加载xml文件的过程.比如有一个mybatis-config.xml文件,里面是一些配置信息.当然还会有什么属性文件啦什么的,这些本文就先不考虑.介绍过程通过一个序列图,告诉你走完这个流程需要的关键类之间的调用关系,只是告诉你类之间的协调关系贴出部分代码,告诉你方法之间的调用建议

2017-05-17 16:27:54 1558

原创 shmvc之aop

环境搭建需要spring-aop,这里没有标明,需要可以看上一篇开发环境搭建里面有spring-aop相关的dependency 基于springframework的环境下,需要额外的jar包  <depend

2016-11-16 22:53:08 397

原创 shmvc之test

使用junit测试spring环境lib <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.1

2016-11-16 17:04:25 438

原创 shmvc之环境搭建

准备条件开发环境myeclipse2014mysql5.6.24框架mavenspringframeworkhibernatelibjunitjavax servlet-api jsp-api jstl elspringframework aop context web webmvc jdbc orm

2016-11-16 16:51:59 243

原创使用BeanUtils复制bean的属性,和将request的属性设置到bean中

使用目的 javaweb开发中,需要将request中的属性添加的bean中,或者需要将表单bean中的属性复制到model中,为了省事,可以使用BeanUtils类需要的jar包 commons-beanUtils.jar,commons-logging.jar提取request中的属性//创建一个Bean UserModelUserModel bean = new UserMod

2016-09-25 19:43:09 2220

原创 java 字符串转化成Date类型,校验格式

java 字符串转化成Date类型,并校验格式

2016-09-25 19:24:42 1492

原创 javaMail发送qq邮箱文件

百度找了各种使用javaMail发送邮件,大多数是使用163邮箱,不需要ssl加密,但使用qq邮箱的时候需要使用.这里将我个人使用经验分享给大家也算是我的个人笔记了.好了,这里正式开始!!!!首先,我的使用背景是javaweb项目,使用的是spring框架(spring框架封装了javaMail,这里没有使用,感兴趣的可以自己百度,后续可能我会使用)第一步:开通qq邮箱POP3/IMA

2016-09-19 23:43:18 766

原创 SSH,webprojact使用自己的json包遇到ClassNotFound问题

新手学习webproject ,使用的是ssh框架,运行是没用报错,当遇到JSON js = JSON.parse(obj)时遇到ClassNotfound,研究后发现,原来我的jar包没有放到web_root 下的lib中,这个是运行时动态调用的库目录,所以我把jar包放到web_root下的lib中,就这样就行,然后运行,访问,没问题了

2016-06-26 19:10:05 298

落叶下的光

原创 flink总结笔记之窗口