概念 Flume是一个分布式、可靠、和高可用的海量日志采集、聚合和传输的系统。 模型 a)Source：采集组件，用于跟数据源对接，以获取数据 b)Sink：下沉组件，用于往下一级agent传递数据或者往最终存储系统传递数据 c)Channel：传输通道组件，用于从source将数据传递到sink ...
分类：
Web程序 时间：
2020-06-07 21:04:35
阅读次数：
67
2、Go语言基础之数据类型 Go语言中有丰富的数据类型，除了基本的整型、浮点型、布尔型、字符串外，还有数组、切片、结构体、函数、map、通道（channel）等。 基本数据类型 1.1整型 整型分为以下两个大类： 按长度分为：int8、int16、int32、int64 对应的无符号整型：uint8 ...
分类：
编程语言 时间：
2020-06-07 14:44:13
阅读次数：
68
1.服务端 public class GroupChatServer { private Selector selector; private ServerSocketChannel listenChannel; private static final int PORT = 6677; //初始化 ...
分类：
其他好文 时间：
2020-06-07 10:51:54
阅读次数：
61
1.简单介绍 选择器提供选择执行已经就绪的任务的能力.从底层来看，Selector提供了询问通道是否已经准备好执行每个I/O操作的能力。Selector 允许单线程处理多个Channel。仅用单个线程来处理多个Channels的好处是，只需要更少的线程来处理通道。事实上，可以只用一个线程处理所有的通 ...
分类：
其他好文 时间：
2020-06-07 09:20:18
阅读次数：
80
package main import "fmt" func main() { // make函数 makeSlice() // 创建切片 makeMap() // 创建集合 makeChan() // 创建channel } func makeSlice(){ sl := make([]strin ...
分类：
其他好文 时间：
2020-06-06 20:08:38
阅读次数：
224
package main import ( "time" "fmt" ) func main() { c := make(chan string) go func() { time.Sleep(1 * time.Second) c <- "hello from chan" // 数据发送到chann ...
分类：
其他好文 时间：
2020-06-06 18:45:24
阅读次数：
51
急速入门 - 消息生成与消费 1. ConnectionFactory ： 获取连接工厂 2. Connection ： 一个连接 3. Channel：数据通信信道，可发送和接收消息 4. Queue：具体的消息存储队列 5. Producer & Consumer 生产者和消费者 RabbitM ...
分类：
其他好文 时间：
2020-06-06 13:17:57
阅读次数：
56
使用Zxing的扫描二维码库，修改成从相册识别二维码图片，根据网上的demo修改，继而在我使用的fragment报错Channel is unrecoverably broken and will be disposed! 网上demo写的原始代码：👇👇 在使用的fragment重写onActi ...
分类：
移动开发 时间：
2020-06-05 12:49:47
阅读次数：
107
■ 基本流程 打开设备 设置参数 获取fd poll 写入数据/读取数据 关闭 ■ 写入数据 snd_pcm_open(&u->pcm_handle, dev = pa_modargs_get_value(ma, "device", DEFAULT_DEVICE), SND_PCM_STREAM_P ...
分类：
其他好文 时间：
2020-06-05 00:47:51
阅读次数：
101
1.Rabbitmq是如何在接收消息之后将队列中的消息删除呢？ channel.basicConsume("myQueue",true,new DefaultConsumer(channel){})//第二个参数是true，代表的就是接收消息之后自动删除队列中的消息。 手动确认消息是怎么实现的呢？ ...
分类：
其他好文 时间：
2020-06-04 13:57:09
阅读次数：
55
